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 e1c11ad20c8 [FLINK-24932][state] Bump frocksdbjni to
6.20.3-ververica-2.0
new 833c4d25c88 [FLINK-30755][connector] Support getting attempt number
from Sink context
new 2690fb17ea3 [FLINK-30755][api] Introduce
SupportsConcurrentExecutionAttempts interface
new 242987c75e5 [FLINK-30755][runtime] Support
SupportsConcurrentExecutionAttempts property of StreamGraph and JobGraph
new a9e1738a2e1 [FLINK-30755][runtime] Support
SupportsConcurrentExecutionAttempts property of Transformation
new b3589afff64 [FLINK-30755][runtime] Support
SupportsConcurrentExecutionAttempts property of SinkV2
new d336dad9345 [FLINK-30755][runtime] Remove legacy codes of marking not
support speculative executions
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../base/sink/writer/TestSinkInitContext.java | 5 +
.../connector/kafka/sink/KafkaWriterITCase.java | 5 +
.../SupportsConcurrentExecutionAttempts.java} | 18 +-
.../org/apache/flink/api/connector/sink2/Sink.java | 7 +
.../executiongraph/SpeculativeExecutionVertex.java | 8 +-
.../apache/flink/runtime/jobgraph/JobVertex.java | 27 ++-
.../adaptivebatch/SpeculativeScheduler.java | 2 +-
.../flink/streaming/api/graph/StreamGraph.java | 24 +--
.../flink/streaming/api/graph/StreamNode.java | 11 ++
.../api/graph/StreamingJobGraphGenerator.java | 24 +--
.../transformations/LegacySinkTransformation.java | 5 +
.../transformations/PhysicalTransformation.java | 11 ++
.../runtime/operators/sink/SinkWriterOperator.java | 5 +
.../AbstractOneInputTransformationTranslator.java | 8 +
.../AbstractTwoInputTransformationTranslator.java | 8 +
.../LegacySinkTransformationTranslator.java | 3 +
.../LegacySourceTransformationTranslator.java | 3 +
.../MultiInputTransformationTranslator.java | 3 +
.../translators/SinkTransformationTranslator.java | 45 +++--
.../SourceTransformationTranslator.java | 4 +
.../streaming/api/functions/PrintSinkTest.java | 5 +
.../StreamingJobGraphGeneratorSourceSinkTest.java | 162 ------------------
.../api/graph/StreamingJobGraphGeneratorTest.java | 182 +++++++++++++++++++++
.../scheduling/SpeculativeSchedulerITCase.java | 147 +++++++++++++++++
24 files changed, 482 insertions(+), 240 deletions(-)
copy flink-core/src/main/java/org/apache/flink/{core/io/Versioned.java =>
api/common/SupportsConcurrentExecutionAttempts.java} (67%)
delete mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorSourceSinkTest.java
