You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/02/15 12:29:00 UTC

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

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)