mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r965717885
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java:
##########
@@ -589,10 +589,6 @@ public void updateCurrentEffectiveWatermark(long
watermark) {
@Override
public void updateCurrentSplitWatermark(String splitId, long watermark) {
splitCurrentWatermarks.put(splitId, watermark);
- if (currentMaxDesiredWatermark < watermark &&
!currentlyPausedSplits.contains(splitId)) {
- pauseOrResumeSplits(Collections.singletonList(splitId),
Collections.emptyList());
- currentlyPausedSplits.add(splitId);
- }
Review Comment:
Yes, I didn't remove this but I fixed a bug which @mas-chen pointed out
which would pause the split when there is just a single split.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
