Yufei Zhang created FLINK-26161: ----------------------------------- Summary: Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning Key: FLINK-26161 URL: https://issues.apache.org/jira/browse/FLINK-26161 Project: Flink Issue Type: Bug Components: Connectors / Pulsar Reporter: Yufei Zhang
Currently we add a split to finishedSplit in the read for loop, but if the split is empty and never enters for loop it should be checked whether to add to finishedSplit as well. This is an edge case and priority is low. {{// current code}} {{ if (stopCursor.shouldStop(message)) { builder.addFinishedSplit(splitId); break; }}} -- This message was sent by Atlassian Jira (v8.20.1#820001)