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(-)