This is an automated email from the ASF dual-hosted git repository.
renqs pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 18b4759cc34 [Flink-32356][doc] Add doc for call statement This closes
#23130
add eab68f31193 [FLINK-31268][metrics] Change not to initialize operator
coordinator metric group lazily (#22048)
No new revisions were added by this update.
Summary of changes:
.../source/lib/util/IteratorSourceEnumerator.java | 1 +
.../executiongraph/DefaultExecutionGraph.java | 19 +++++---
.../DefaultExecutionGraphBuilder.java | 6 ++-
.../runtime/executiongraph/ExecutionGraph.java | 16 +++++--
.../runtime/executiongraph/ExecutionJobVertex.java | 20 ++++++--
.../SpeculativeExecutionJobVertex.java | 12 ++++-
.../coordination/OperatorCoordinatorHolder.java | 53 +++++++++-------------
.../scheduler/DefaultExecutionGraphFactory.java | 3 +-
.../DefaultOperatorCoordinatorHandler.java | 14 ++----
.../scheduler/OperatorCoordinatorHandler.java | 8 +---
.../flink/runtime/scheduler/SchedulerBase.java | 3 +-
.../scheduler/adaptive/CreatingExecutionGraph.java | 2 +-
.../adaptivebatch/AdaptiveBatchScheduler.java | 11 +++--
.../DefaultExecutionGraphConstructionTest.java | 38 +++++++++-------
.../executiongraph/EdgeManagerBuildUtilTest.java | 22 +++++++--
.../executiongraph/ExecutionJobVertexTest.java | 4 +-
.../executiongraph/PointwisePatternTest.java | 4 +-
.../TestingDefaultExecutionGraphBuilder.java | 4 +-
.../executiongraph/VertexSlotSharingTest.java | 5 +-
.../OperatorCoordinatorHolderTest.java | 8 ++--
.../DefaultOperatorCoordinatorHandlerTest.java | 10 ++--
.../runtime/scheduler/SchedulerTestingUtils.java | 5 +-
.../SsgNetworkMemoryCalculationUtilsTest.java | 20 ++++++--
.../adapter/DefaultExecutionTopologyTest.java | 19 +++++---
.../runtime/scheduler/adaptive/ExecutingTest.java | 4 +-
.../adaptive/StateTrackingMockExecutionGraph.java | 8 +++-
.../TestingOperatorCoordinatorHandler.java | 8 +---
.../topology/BuildExecutionGraphBenchmark.java | 4 +-
.../partitioner/RescalePartitionerTest.java | 5 +-
29 files changed, 204 insertions(+), 132 deletions(-)
