nifi JoinEnrichment 仅返回原始内容

huangapple go评论54阅读模式
英文:

nifi JoinEnrichment returns only original

问题

我正在尝试使用JoinEnrichment,但在结果中没有获得丰富化的内容,只有原始内容。我尝试使用所有的丰富化模式,但结果都相同。

日志:

2023-07-13 09:33:56,462 INFO [Timer-Driven Process Thread-9] o.a.n.processors.standard.LogAttribute LogAttribute[id=103c1277-1040-10c7-9cc8-e23dbb000fba] 记录流文件 StandardFlowFileRecord[uuid=62500046-90e4-4b96-a973-1d9dc2c8852e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1689240288569-126, container=default, section=126], offset=19896, length=120],offset=0,name=c02d147c-d9ab-4b44-8963-6fb31f4fbf93,size=120]
--------------------------------------------------
流文件属性映射内容
键: 'enrichment.group.id'
	值: '16086913-2fe8-4a12-9937-8d4eadb642b4'
键: 'enrichment.role'
	值: 'ORIGINAL'
--------------------------------------------------
{
  "cisloParcely" : "4401/2",
  "celkovaVymeraParcely" : 1940,
  "listVlastnictva" : 5242,
  "druhPozemku" : "Vinica"
}
2023-07-13 09:33:59,502 INFO [Timer-Driven Process Thread-5] o.a.n.processors.standard.LogAttribute LogAttribute[id=103c1277-1040-10c7-9cc8-e23dbb000fba] 记录流文件 StandardFlowFileRecord[uuid=42faa4e1-67bd-44fb-98a8-1b0f2a34c3ca,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1689240288569-126, container=default, section=126], offset=20016, length=995],offset=0,name=c02d147c-d9ab-4b44-8963-6fb31f4fbf93,size=995]
--------------------------------------------------
流文件属性映射内容
键: 'enrichment.group.id'
	值: '16086913-2fe8-4a12-9937-8d4eadb642b4'
键: 'enrichment.role'
	值: 'ENRICHMENT'
--------------------------------------------------
{
  "uzivatelia" : [ {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 1,
    "podielVlastnikaMenovatel" : 6,
    "typVlastnika" : "Vlastník",
    "poradieVlastnika" : 1
  }, {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 1,
    "podielVlastnikaMenovatel" : 6,
    "typVlastnika" : "Vlastník",
    "poradieVlastnika" : 2
  }, {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 1,
    "podielVlastnikaMenovatel" : 3,
    "typVlastnika" : "Vlastník",
    "poradieVlastnika" : 3
  }, {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 1,
    "podielVlastnikaMenovatel" : 3,
    "typVlastnika" : "Vlastník",
    "poradieVlastnika" : 4
  }, {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 0,
    "podielVlastnikaMenovatel" : 0,
    "typVlastnika" : "Správca",
    "poradieVlastnika" : 5
  } ]
}
2023-07-13 09:34:00,002 INFO [Timer-Driven Process Thread-2] o.a.n.processors.standard.LogAttribute LogAttribute[id=103c1277-1040-10c7-9cc8-e23dbb000fba] 记录流文件 StandardFlowFileRecord[uuid=939b4716-9200-417e-b400-1bf58a471b9b,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1689240359382-127, container=default, section=127], offset=24779, length=153],offset=0,name=4e267690-2917-4f90-b974-90fe0ea4f618,size=153]
--------------------------------------------------
流文件属性映射内容
键: 'enrichment.group.id'
	值: '16086913-2fe8-4a12-9937-8d4eadb642b4'
--------------------------------------------------
[ {
  "original" : {
    "cisloParcely" : "4401/2",
    "celkovaVymeraParcely" : 1940,
    "listVlastnictva" : 5242,
    "druhPozemku" : "Vinica"
  }
} ]

谢谢你。

英文:

Im trying to use JoinEnrichment, but dont get the enrichment in the result, just the original. I was trying to use all enrichment modes with same result.

nifi JoinEnrichment 仅返回原始内容

Log:

2023-07-13 09:33:56,462 INFO [Timer-Driven Process Thread-9] o.a.n.processors.standard.LogAttribute LogAttribute[id=103c1277-1040-10c7-9cc8-e23dbb000fba] logging for flow file StandardFlowFileRecord[uuid=62500046-90e4-4b96-a973-1d9dc2c8852e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1689240288569-126, container=default, section=126], offset=19896, length=120],offset=0,name=c02d147c-d9ab-4b44-8963-6fb31f4fbf93,size=120]
--------------------------------------------------
FlowFile Attribute Map Content
Key: 'enrichment.group.id'
	Value: '16086913-2fe8-4a12-9937-8d4eadb642b4'
Key: 'enrichment.role'
	Value: 'ORIGINAL'
--------------------------------------------------
{
  "cisloParcely" : "4401/2",
  "celkovaVymeraParcely" : 1940,
  "listVlastnictva" : 5242,
  "druhPozemku" : "Vinica"
}
2023-07-13 09:33:59,502 INFO [Timer-Driven Process Thread-5] o.a.n.processors.standard.LogAttribute LogAttribute[id=103c1277-1040-10c7-9cc8-e23dbb000fba] logging for flow file StandardFlowFileRecord[uuid=42faa4e1-67bd-44fb-98a8-1b0f2a34c3ca,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1689240288569-126, container=default, section=126], offset=20016, length=995],offset=0,name=c02d147c-d9ab-4b44-8963-6fb31f4fbf93,size=995]
--------------------------------------------------
FlowFile Attribute Map Content
Key: 'enrichment.group.id'
	Value: '16086913-2fe8-4a12-9937-8d4eadb642b4'
Key: 'enrichment.role'
	Value: 'ENRICHMENT'
--------------------------------------------------
{
  "uzivatelia" : [ {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 1,
    "podielVlastnikaMenovatel" : 6,
    "typVlastnika" : "Vlastník",
    "poradieVlastnika" : 1
  }, {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 1,
    "podielVlastnikaMenovatel" : 6,
    "typVlastnika" : "Vlastník",
    "poradieVlastnika" : 2
  }, {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 1,
    "podielVlastnikaMenovatel" : 3,
    "typVlastnika" : "Vlastník",
    "poradieVlastnika" : 3
  }, {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 1,
    "podielVlastnikaMenovatel" : 3,
    "typVlastnika" : "Vlastník",
    "poradieVlastnika" : 4
  }, {
    "meno" : "XYZ",
    "podielVlastnikaCitatel" : 0,
    "podielVlastnikaMenovatel" : 0,
    "typVlastnika" : "Správca",
    "poradieVlastnika" : 5
  } ]
}
2023-07-13 09:34:00,002 INFO [Timer-Driven Process Thread-2] o.a.n.processors.standard.LogAttribute LogAttribute[id=103c1277-1040-10c7-9cc8-e23dbb000fba] logging for flow file StandardFlowFileRecord[uuid=939b4716-9200-417e-b400-1bf58a471b9b,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1689240359382-127, container=default, section=127], offset=24779, length=153],offset=0,name=4e267690-2917-4f90-b974-90fe0ea4f618,size=153]
--------------------------------------------------
FlowFile Attribute Map Content
Key: 'enrichment.group.id'
	Value: '16086913-2fe8-4a12-9937-8d4eadb642b4'
--------------------------------------------------
[ {
  "original" : {
    "cisloParcely" : "4401/2",
    "celkovaVymeraParcely" : 1940,
    "listVlastnictva" : 5242,
    "druhPozemku" : "Vinica"
  }
} ]

Thank you

Lorem Ipsum is simply dummy text of the printing and typesetting industry. Lorem Ipsum has been the industry's standard dummy text ever since the 1500s, when an unknown printer took a galley of type and scrambled it to make a type specimen book. It has survived not only five centuries, but also the leap into electronic typesetting, remaining essentially unchanged. It was popularised in the 1960s with the release of Letraset sheets containing Lorem Ipsum passages, and more recently with desktop publishing software like Aldus PageMaker including versions of Lorem Ipsum.

答案1

得分: 1

我在最新版本的NiFi(1.22.0)上创建并测试了类似的流程,运行正常!
模板

我建议升级NiFi(从1.20.01.22.0

英文:

I created and tested a similar flow on the latest version NiFi (1.22.0) and worked!
template

I suggest upgrading NiFi (1.20.0 to 1.22.0)

huangapple
  • 本文由 发表于 2023年7月13日 17:41:34
  • 转载请务必保留本文链接:https://go.coder-hub.com/76677989.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定