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 dcbb20688c0 [FLINK-30727][table-planner] Fix
JoinReorderITCaseBase.testBushyTreeJoinReorder failed
add 74ef6be4c08 [FLINK-30798][runtime] Refactor OutputFormat#open to
expose attempt number
add 642d28ec83c [FLINK-30798][runtime] Refactor
FinalizeOnMaster#finalizeGlobal to expose finished task attempts
add f6694ca057e [FLINK-30798][runtime] Make OutputFormat support
speculative execution through implementing SupportsConcurrentExecutionAttempts
interface
add 9a5c2dbb85f [FLINK-30828][table-planner] Let SortAggITCase#testLeadLag
run in ALL_EXCHANGES_PIPELINED mode
No new revisions were added by this update.
Summary of changes:
.../flink/api/common/io/FinalizeOnMaster.java | 36 +++++++++-
.../apache/flink/api/common/io/OutputFormat.java | 41 +++++++++++-
.../executiongraph/DefaultExecutionGraph.java | 34 +++++++++-
.../runtime/jobgraph/InputOutputFormatVertex.java | 17 ++++-
.../apache/flink/runtime/jobgraph/JobVertex.java | 25 ++++++-
.../flink/runtime/operators/DataSinkTask.java | 19 +++++-
.../executiongraph/FinalizeOnMasterTest.java | 7 +-
.../flink/runtime/jobgraph/JobTaskVertexTest.java | 19 +++++-
.../runtime/minicluster/MiniClusterITCase.java | 4 +-
.../functions/sink/OutputFormatSinkFunction.java | 19 +++++-
.../transformations/LegacySinkTransformation.java | 12 ++++
.../api/graph/StreamingJobGraphGeneratorTest.java | 65 ++++++++++++++++++
.../batch/sql/agg/AggregateITCaseBase.scala | 6 ++
.../planner/runtime/utils/StreamTestSink.scala | 2 +-
.../scheduling/SpeculativeSchedulerITCase.java | 77 ++++++++++++++++++++++
pom.xml | 4 ++
16 files changed, 369 insertions(+), 18 deletions(-)
