【问题标题】:Nifi MergeRecord not working on avro flow filesNifi MergeRecord 不适用于 avro 流文件
【发布时间】:2018-05-20 17:32:14
【问题描述】:

【问题讨论】:

  • 请参阅stackoverflow.com/help/how-to-ask 页面以获得澄清此问题的帮助。
  • 请添加更多有关流程和处理器详细信息的详细信息。快速检查将检查 Min number of recordsAttribute Strategy 属性设置为什么?
  • 请点击 NiFi Flow 读取 json 文件推断 avro 架构...上面你可以看到我的 nifi 流图片.. 最小记录数:1 & 属性策略:仅保留通用属性
  • Merge Strategy 设置为什么?你给Correlation Attribute Name设置了什么?
  • 合并策略设置为碎片整理我没有为关联属性名称设置任何内容

标签: avro apache-nifi


【解决方案1】:

将合并策略值 Bin-Packing Algorithm 更改为 MergeRecord 处理器的碎片整理并开始工作。

【讨论】:

  • 是的。原因是Defragment 策略要求流文件具有标识符属性fragment.identifierfragment.count。 NiFi 文档页面澄清了这方面的许多事情:nifi.apache.org/docs/nifi-docs
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 2018-04-16
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多