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

Posted to commits@flink.apache.org by zh...@apache.org on 2024/03/22 13:03:46 UTC

(flink) branch master updated (779459168c4 -> 8dcb0ae9063)

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

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


    from 779459168c4 [FLINK-34516][checkpoint] Rename the new introduced API to get/setCheckpointingConsistencyMode
     add 8c20e0f8053 [hotfix][tests] Migrate TransformationTest to Junit5
     add 8dcb0ae9063 [FLINK-32513][core] Add predecessor caching

No new revisions were added by this update.

Summary of changes:
 .../org/apache/flink/api/dag/Transformation.java   |  28 +++-
 .../apache/flink/api/dag/TransformationTest.java   |  77 +++++-----
 .../AbstractBroadcastStateTransformation.java      |  12 +-
 .../AbstractMultipleInputTransformation.java       |  12 +-
 .../api/transformations/CacheTransformation.java   |   2 +-
 .../transformations/CoFeedbackTransformation.java  |   2 +-
 .../transformations/FeedbackTransformation.java    |   2 +-
 .../transformations/LegacySinkTransformation.java  |   2 +-
 .../LegacySourceTransformation.java                |   2 +-
 .../transformations/OneInputTransformation.java    |   2 +-
 .../transformations/PartitionTransformation.java   |   2 +-
 .../api/transformations/ReduceTransformation.java  |   2 +-
 .../transformations/SideOutputTransformation.java  |   2 +-
 .../api/transformations/SinkTransformation.java    |   2 +-
 .../api/transformations/SourceTransformation.java  |   2 +-
 .../SourceTransformationWrapper.java               |   2 +-
 .../TimestampsAndWatermarksTransformation.java     |   2 +-
 .../transformations/TwoInputTransformation.java    |  18 ++-
 .../api/transformations/UnionTransformation.java   |  16 +-
 .../api/graph/StreamGraphGeneratorTest.java        |   2 +-
 .../GetTransitivePredecessorsTest.java             | 162 +++++++++++++++++++++
 .../TableOperatorWrapperGeneratorTest.java         |   2 +-
 22 files changed, 281 insertions(+), 74 deletions(-)
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/transformations/GetTransitivePredecessorsTest.java