NiFi StandardFlowFileRecord 在此会话中未知
NiFi StandardFlowFileRecord is not known in this session
我正在评估 NiFi 并创建了一个基本的工作流程，它侦听本地目录，应用一些转换，然后将流程放入 kafka，但是当将消息放入 kafka 时，我遇到了以下错误。
错误跟踪
09:46:35 UTC ERROR1b6ae25f-e517-47d9-90a2-103109a47b90 localhost:10084
PutKafka[id=1b6ae25f-e517-47d9-90a2-103109a47b90] Failed to process session due to org.apache.nifi.processor.exception.FlowFileHandlingException:
StandardFlowFileRecord[uuid=746f505e-54ec-4b9f-a970-1f88cda08a2e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1455788674669-223, container=default, section=223], offset=0, length=131876],offset=0,name=1_edr_http_EAST.COMPLETED.9,size=131876] is not known in this session (StandardProcessSession[id=134420]):
org.apache.nifi.processor.exception.FlowFileHandlingException: StandardFlowFileRecord[uuid=746f505e-54ec-4b9f-a970-1f88cda08a2e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1455788674669-223, container=default, section=223], offset=0, length=131876],offset=0,name=1_edr_http_EAST.COMPLETED.9,size=131876] is not known in this session (StandardProcessSession[id=134420])
我的工作流程是这样的
BasicFieldSplitProcessor 是我的自定义处理器，它是 ReplaceText 的修改版本。
"Field Split out queue"
的配置
- FlowFile 过期Info:120 秒
- 背压对象阈值
Info:500000
- 背压数据大小阈值Info:200MB
好的，感谢您提供的所有帮助以获取详细信息。我们已经能够复制，并且社区成员现在正在努力解决它。现在我们相信您可以简单地将 运行 持续时间设置为 0 秒并看到更好的行为。请确认。 https://issues.apache.org/jira/browse/NIFI-1534
我正在评估 NiFi 并创建了一个基本的工作流程，它侦听本地目录，应用一些转换，然后将流程放入 kafka，但是当将消息放入 kafka 时，我遇到了以下错误。
错误跟踪
09:46:35 UTC ERROR1b6ae25f-e517-47d9-90a2-103109a47b90 localhost:10084
PutKafka[id=1b6ae25f-e517-47d9-90a2-103109a47b90] Failed to process session due to org.apache.nifi.processor.exception.FlowFileHandlingException:
StandardFlowFileRecord[uuid=746f505e-54ec-4b9f-a970-1f88cda08a2e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1455788674669-223, container=default, section=223], offset=0, length=131876],offset=0,name=1_edr_http_EAST.COMPLETED.9,size=131876] is not known in this session (StandardProcessSession[id=134420]):
org.apache.nifi.processor.exception.FlowFileHandlingException: StandardFlowFileRecord[uuid=746f505e-54ec-4b9f-a970-1f88cda08a2e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1455788674669-223, container=default, section=223], offset=0, length=131876],offset=0,name=1_edr_http_EAST.COMPLETED.9,size=131876] is not known in this session (StandardProcessSession[id=134420])
我的工作流程是这样的
BasicFieldSplitProcessor 是我的自定义处理器，它是 ReplaceText 的修改版本。
"Field Split out queue"
的配置- FlowFile 过期Info:120 秒
- 背压对象阈值 Info:500000
- 背压数据大小阈值Info:200MB
好的，感谢您提供的所有帮助以获取详细信息。我们已经能够复制，并且社区成员现在正在努力解决它。现在我们相信您可以简单地将 运行 持续时间设置为 0 秒并看到更好的行为。请确认。 https://issues.apache.org/jira/browse/NIFI-1534