[
https://issues.apache.org/jira/browse/NIFI-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15167264#comment-15167264
]
Joseph Witt commented on NIFI-1534:
-----------------------------------
The ticket title should not be changed. The bug is indeed with the PutKafka
processor as it is misusing 'SupportsBatching' annotation. That processor,
given the way it works, should NOT allow the framework to use the batching
feature. The description of the annotation itself calls out the case that this
processor is doing. The bug is that this annotation is wrong on that processor
and should be removed. We should add additional explanation and examples to
both the annotation itself AND to the developer guide.
We should out of precaution also look at other processors that leverage this
feature to ensure they're not using this annotation inappropriately as well.
I also recommend restoring the priority of this back to major.
> Processors that utilize batching with Run Duration > 0 fail
> -----------------------------------------------------------
>
> Key: NIFI-1534
> URL: https://issues.apache.org/jira/browse/NIFI-1534
> Project: Apache NiFi
> Issue Type: Bug
> Reporter: Oleg Zhurakousky
> Assignee: Oleg Zhurakousky
> Priority: Critical
> Fix For: 0.6.0
>
>
> The following error shows up in the bulletin
> {code}
> PutKafka[id=80e8946f-349c-4716-9da9-5e766582f788] Failed to process session
> due to org.apache.nifi.processor.exception.FlowFileHandlingException:
> StandardFlowFileRecord[uuid=27030bf8-c217-4b59-a0ba-46f1b30ff093,claim=StandardContentClaim
> [resourceClaim=StandardResourceClaim[id=1455807429050-246,
> container=default, section=246], offset=563929,
> length=431],offset=0,name=hh77.33,size=431] is not known in this session
> {code}
> After some debugging I also see this
> {code}
> ERROR [Timer-Driven Process Thread-14] o.apache.nifi.processors.kafka.PutKafka
> org.apache.nifi.processor.exception.FlowFileHandlingException:
> StandardFlowFileRecord[uuid=dd373d71-ebd2-432e-bcf5-9980d7df4da4,claim=StandardContentClaim
> [resourceClaim=StandardResourceClaim[id=1454688235111-5, container=content2,
> section=5], offset=0, length=4778852],offset=0,name=boo,size=4778852]
> transfer relationship not specified
> at
> org.apache.nifi.controller.repository.StandardProcessSession.checkpoint(StandardProcessSession.java:210)
>
> at
> org.apache.nifi.controller.repository.StandardProcessSession.commit(StandardProcessSession.java:280)
> at
> org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:179)
> . . . .
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
