计算节点从以前的流计算数据。

Question

我的流程是这样的：

File Input -> File Read -> Compute -> Mapping -> Compute -> File Output

从文件读取节点，我将数据保存到${LocalEnvironment}。也尝试过${Environment}。这就是计算节点背后发生的事情：

1. 发送文件A-A环境内的数据计算(应答->未计算后编辑，流意外停止)。
2. 发送文件B-计算A环境内的数据.
3. 发送文件C-计算B环境内的数据.
4. 计算C环境下的发送文件D-数据.

这种偏移是如何可能的？${LocalEnvironment}应该在请求流的时候重新设置。

编辑：

不要使用环境变量。局部变量应该存储在$LocalEnvironment/Variables中。

解释

明白了。即使现在我觉得我的变量还没有被清除。文件读取仍然会产生以前运行的$LocalEnvironment/Variables/BLOB/BLOB。

EDIT2 2：*节点设置:文件输入：

Input directory: C:\Users\User1\Documents\In
File pattern: *
Action on successful processing: move to mqsiarchive
Message domain: XMLNS (I know it should be XMLNSC but it works)
Use XMLNSC compact parser...: check

文件读：

Input directory: C:\Users\User1\Documents\In\mqsiarchive
File name or pattern: *
Action: Delete
Request directory property location: $LocalEnvironment/Destination/File/Directory
Request filename property location: $LocalEnvironment/Destination/File/Name
Offset property location: $LocalEnvironment/Destination/File/Offset
Length property location: $LocalEnvironment/Destination/File/Length
Result data location: $ResultRoot
Output data location: $OutputLocalEnvironment/Variables
Copy local environment: check
Record selection expression: true()

计算节点：

Compute mode: LocalEnvironment and Message

文件输出(这一项并不重要，因为即使没有问题也会出现问题)：

Output directory: C:\Users\User1\Documents\Out
Filename or pattern: test.txt
Stage in mqsitransit...: check
Data location: $Body
Request directory property location: $LocalEnvironment/Destination/File/Directory
Request filename property location: $LocalEnvironment/Destination/File/Name

我没有提到的属性:默认

Answer 1

我认为它是这样运作的：

• 在1事务中，File节点没有什么可读取的，因为归档目录是空的。因此，文件输入中的消息A将被处理。
• 在2.事务中，File节点从1.Transaction中找到消息A。因此，消息B将被存档，来自File节点的消息A将被处理(再次)。