This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8be1058 [FLINK-23003][runtime] Fix resource leak in
RocksIncrementalSnapshotStrategy
add 2b2f943 [hotfix] Rename Input#emitStreamStatus to processStreamStatus
No new revisions were added by this update.
Summary of changes:
.../output/operators/StateBootstrapWrapperOperator.java | 4 ++--
.../flink/streaming/api/operators/AbstractInput.java | 4 ++--
.../streaming/api/operators/AbstractStreamOperator.java | 12 ++++++------
.../api/operators/AbstractStreamOperatorV2.java | 2 +-
.../org/apache/flink/streaming/api/operators/Input.java | 11 +++++++++--
.../streaming/api/operators/TwoInputStreamOperator.java | 16 ++++++++++++++--
.../runtime/io/StreamMultipleInputProcessorFactory.java | 2 +-
.../runtime/io/StreamTwoInputProcessorFactory.java | 4 ++--
.../flink/streaming/runtime/tasks/ChainingOutput.java | 2 +-
.../streaming/runtime/tasks/OneInputStreamTask.java | 2 +-
.../api/operators/AbstractStreamOperatorTest.java | 8 ++++----
.../api/operators/AbstractStreamOperatorV2Test.java | 12 ++++++------
.../runtime/tasks/SubtaskCheckpointCoordinatorTest.java | 2 +-
.../util/MultiInputStreamOperatorTestHarness.java | 4 ++--
.../util/TwoInputStreamOperatorTestHarness.java | 8 ++++----
.../multipleinput/input/FirstInputOfTwoInput.java | 4 ++--
.../runtime/operators/multipleinput/input/OneInput.java | 4 ++--
.../multipleinput/input/SecondInputOfTwoInput.java | 4 ++--
...CopyingSecondInputOfTwoInputStreamOperatorOutput.java | 2 +-
.../output/FirstInputOfTwoInputStreamOperatorOutput.java | 2 +-
.../output/OneInputStreamOperatorOutput.java | 2 +-
.../SecondInputOfTwoInputStreamOperatorOutput.java | 2 +-
.../streaming/runtime/SortingBoundedInputITCase.java | 2 +-
23 files changed, 67 insertions(+), 48 deletions(-)
