[jira] [Created] (FLINK-26161) Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning

[Yufei Zhang (Jira)]

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)