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

Posted to commits@flink.apache.org by pn...@apache.org on 2022/02/04 10:18:46 UTC

[flink] branch master updated (96c2500 -> 27911f8)

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 96c2500  [FLINK-25331][tests] FlinkImageBuilder checks for Java 17
     add 61ac291  [hotfix][test] Extract SourceOperatorTestBase from SourceOperatorTest
     add 06312b5  [hotfix][test] Fix SourceOperatorTest#testSameAvailabilityFuture
     add d95dc86  [FLINK-25827][task] Move and rename MultipleInputAvailabilityHelper
     add 27911f8  [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

No new revisions were added by this update.

Summary of changes:
 .../streaming/api/operators/SourceOperator.java    |  27 ++--
 .../io/MultipleFuturesAvailabilityHelper.java      |  80 +++++++++++
 .../runtime/io/StreamMultipleInputProcessor.java   |  61 +--------
 .../api/operators/SourceOperatorIdleTest.java      |  69 ++++++++++
 .../api/operators/SourceOperatorTest.java          | 146 ++++++---------------
 .../api/operators/SourceOperatorTestContext.java   | 138 +++++++++++++++++++
 6 files changed, 341 insertions(+), 180 deletions(-)
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/MultipleFuturesAvailabilityHelper.java
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorIdleTest.java
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorTestContext.java