[ https://issues.apache.org/jira/browse/NIFI-5642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796476#comment-17796476 ]
André Gomes Lamas Otero commented on NIFI-5642: ----------------------------------------------- [~mattyb149] check the logic at AbstractCassandraProcessor. It is precisely what you are describing. The code updates from levilentz ([https://github.com/apache/nifi/pull/6848)] were made on top of the old 2018 history, thus the misleading commit messages from the old history. > QueryCassandra processor : output FlowFiles as soon fetch_size is reached > ------------------------------------------------------------------------- > > Key: NIFI-5642 > URL: https://issues.apache.org/jira/browse/NIFI-5642 > Project: Apache NiFi > Issue Type: Bug > Affects Versions: 1.7.1 > Reporter: André Gomes Lamas Otero > Assignee: Levi Lentz > Priority: Major > Fix For: 2.0.0-M1, 1.22.0 > > Time Spent: 4h 10m > Remaining Estimate: 0h > > When I'm using QueryCassandra alongside with fetch_size parameter I expected > that as soon my reader reaches the fetch_size the processor outputs some data > to be processed by the next processor, but QueryCassandra reads all the data, > then output the flow files. > I'll start to work on a patch for this situation, I'll appreciate any > suggestion. -- This message was sent by Atlassian Jira (v8.20.10#820010)