This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
from 637d08e97f4 [FLINK-27089][table-planner] Fix bug with TRY_CAST in batch mode add 7d22a0c832b [hotfix][tests] Close TaskExecutor/TMServices add f1867d31686 [FLINK-27045][tests] Remove shared executor No new revisions were added by this update. Summary of changes: .../ApplicationDispatcherBootstrapITCase.java | 13 +- .../org/apache/flink/testutils/TestingUtils.java | 18 +- .../flink/util/concurrent/FutureUtilsTest.java | 35 ++-- ...sMultipleComponentLeaderElectionDriverTest.java | 8 +- .../jobmanager/JMXJobManagerMetricTest.java | 9 +- .../itcases/AbstractQueryableStateTestBase.java | 3 +- .../handlers/JarHandlerParameterTest.java | 4 - .../webmonitor/handlers/JarHandlerTest.java | 11 +- .../runtime/webmonitor/handlers/JarHandlers.java | 7 +- .../handlers/JarPlanHandlerParameterTest.java | 10 +- .../handlers/JarRunHandlerParameterTest.java | 11 +- .../webmonitor/handlers/JarSubmissionITCase.java | 13 +- .../CheckpointCoordinatorFailureTest.java | 18 +- .../CheckpointCoordinatorMasterHooksTest.java | 22 ++- .../CheckpointCoordinatorRestoringTest.java | 64 ++++---- .../checkpoint/CheckpointCoordinatorTest.java | 182 +++++++++------------ .../CheckpointCoordinatorTestingUtils.java | 30 ++-- .../CheckpointCoordinatorTriggeringTest.java | 45 ++--- .../CheckpointSettingsSerializableTest.java | 9 +- .../checkpoint/CheckpointStateRestoreTest.java | 19 ++- .../checkpoint/CheckpointStatsTrackerTest.java | 14 +- .../DefaultCheckpointPlanCalculatorTest.java | 14 +- .../checkpoint/DefaultCheckpointPlanTest.java | 15 +- .../DefaultSchedulerCheckpointCoordinatorTest.java | 14 +- .../FailoverStrategyCheckpointCoordinatorTest.java | 11 +- .../checkpoint/StateAssignmentOperationTest.java | 11 +- .../checkpoint/VertexFinishedStateCheckerTest.java | 12 +- .../TaskDeploymentDescriptorFactoryTest.java | 9 +- .../ExecutionGraphInfoStoreTestUtils.java | 23 ++- .../FileExecutionGraphInfoStoreTest.java | 36 +++- .../runtime/dispatcher/JobDispatcherITCase.java | 8 +- .../MemoryExecutionGraphInfoStoreTest.java | 13 +- .../runner/DefaultDispatcherRunnerITCase.java | 8 +- .../ZooKeeperDefaultDispatcherRunnerTest.java | 8 +- .../executiongraph/AllVerticesIteratorTest.java | 12 +- .../executiongraph/ArchivedExecutionGraphTest.java | 12 +- .../DefaultExecutionGraphConstructionTest.java | 11 +- .../DefaultExecutionGraphDeploymentTest.java | 31 ++-- ...hDeploymentWithSmallBlobCacheSizeLimitTest.java | 4 +- .../DefaultExecutionGraphRescalingTest.java | 25 ++- .../executiongraph/EdgeManagerBuildUtilTest.java | 9 +- .../runtime/executiongraph/EdgeManagerTest.java | 12 +- .../ExecutionGraphCoLocationRestartTest.java | 14 +- .../executiongraph/ExecutionGraphFinishTest.java | 14 +- .../ExecutionGraphPartitionReleaseTest.java | 13 +- .../executiongraph/ExecutionGraphRestartTest.java | 38 ++++- .../executiongraph/ExecutionGraphSuspendTest.java | 19 ++- .../executiongraph/ExecutionGraphTestUtils.java | 26 +-- .../ExecutionGraphVariousFailuesTest.java | 14 +- .../executiongraph/ExecutionJobVertexTest.java | 12 +- .../ExecutionPartitionLifecycleTest.java | 13 +- .../runtime/executiongraph/ExecutionTest.java | 31 ++-- .../executiongraph/ExecutionVertexCancelTest.java | 11 +- .../executiongraph/ExecutionVertexTest.java | 20 ++- .../executiongraph/FinalizeOnMasterTest.java | 15 +- .../IntermediateResultPartitionTest.java | 24 ++- .../executiongraph/PointwisePatternTest.java | 9 +- .../RemoveCachedShuffleDescriptorTest.java | 10 +- .../TestingDefaultExecutionGraphBuilder.java | 32 ++-- .../executiongraph/VertexSlotSharingTest.java | 9 +- .../runtime/heartbeat/HeartbeatManagerTest.java | 32 ++-- .../highavailability/AbstractHAJobRunITCase.java | 10 +- .../nonha/embedded/EmbeddedLeaderServiceTest.java | 10 +- .../partition/consumer/RemoteInputChannelTest.java | 9 +- .../scheduler/UpdatePartitionConsumersTest.java | 14 +- .../jobmaster/JobMasterPartitionReleaseTest.java | 2 - .../flink/runtime/jobmaster/JobMasterTest.java | 1 - .../TestingJobManagerSharedServicesBuilder.java | 24 +-- .../runtime/jobmaster/utils/JobMasterBuilder.java | 7 +- .../LeaderChangeClusterComponentsTest.java | 9 +- .../runtime/leaderelection/LeaderElectionTest.java | 9 +- .../ZooKeeperLeaderRetrievalTest.java | 9 +- .../runtime/metrics/util/MetricUtilsTest.java | 62 +++---- .../OperatorCoordinatorSchedulerTest.java | 15 +- .../registration/RetryingRegistrationTest.java | 15 +- .../ResourceManagerTaskExecutorTest.java | 9 +- .../resourcemanager/ResourceManagerTest.java | 3 +- .../slotmanager/DeclarativeSlotManagerBuilder.java | 15 +- .../slotmanager/DeclarativeSlotManagerTest.java | 25 ++- .../slotmanager/DefaultSlotStatusSyncerTest.java | 15 +- .../FineGrainedSlotManagerTestBase.java | 11 +- .../slotmanager/TaskExecutorManagerBuilder.java | 12 +- .../slotmanager/TaskExecutorManagerTest.java | 15 +- .../utils/MockResourceManagerRuntimeServices.java | 3 +- .../runtime/rest/RestClientMultipartTest.java | 4 +- .../apache/flink/runtime/rest/RestClientTest.java | 10 +- .../runtime/rest/RestExternalHandlersITCase.java | 16 +- .../runtime/rest/RestServerEndpointITCase.java | 17 +- .../runtime/rest/RestServerSSLAuthITCase.java | 3 +- .../rest/handler/job/JobConfigHandlerTest.java | 3 +- .../rest/handler/job/JobExceptionsHandlerTest.java | 3 +- .../rest/handler/job/JobSubmitHandlerTest.java | 12 +- .../SubtaskCurrentAttemptDetailsHandlerTest.java | 6 +- ...askExecutionAttemptAccumulatorsHandlerTest.java | 4 +- .../SubtaskExecutionAttemptDetailsHandlerTest.java | 6 +- .../metrics/AggregatingMetricsHandlerTestBase.java | 9 +- .../DefaultExecutionGraphFactoryTest.java | 10 +- .../DefaultOperatorCoordinatorHandlerTest.java | 9 +- .../DefaultSchedulerBatchSchedulingTest.java | 10 +- .../runtime/scheduler/DefaultSchedulerTest.java | 15 +- ...GraphToInputsLocationsRetrieverAdapterTest.java | 23 ++- ...LocalInputPreferredSlotSharingStrategyTest.java | 11 +- .../runtime/scheduler/SchedulerTestingUtils.java | 63 ++++--- .../SsgNetworkMemoryCalculationUtilsTest.java | 14 +- .../adapter/DefaultExecutionTopologyTest.java | 16 +- .../DefaultSchedulingPipelinedRegionTest.java | 11 +- .../adaptive/AdaptiveSchedulerBuilder.java | 23 +-- .../scheduler/adaptive/AdaptiveSchedulerTest.java | 100 ++++++----- .../runtime/scheduler/adaptive/ExecutingTest.java | 16 +- .../adaptivebatch/AdaptiveBatchSchedulerTest.java | 12 +- .../AdaptiveBatchSchedulerTestUtils.java | 8 +- .../forwardgroup/ForwardGroupComputeUtilTest.java | 10 +- .../benchmark/SchedulerBenchmarkBase.java | 7 +- .../benchmark/SchedulerBenchmarkUtils.java | 3 +- .../e2e/SchedulerEndToEndBenchmarkBase.java | 7 +- .../topology/BuildExecutionGraphBenchmark.java | 4 +- .../FailureHandlingResultSnapshotTest.java | 11 +- .../RootExceptionHistoryEntryTest.java | 11 +- .../PipelinedRegionSchedulingStrategyTest.java | 19 ++- ...cutorExecutionDeploymentReconciliationTest.java | 11 +- .../TaskExecutorOperatorEventHandlingTest.java | 10 +- .../TaskExecutorPartitionLifecycleTest.java | 9 +- .../taskexecutor/TaskExecutorSlotLifetimeTest.java | 11 +- .../taskexecutor/TaskExecutorSubmissionTest.java | 29 ++-- .../runtime/taskexecutor/TaskExecutorTest.java | 78 ++++++--- .../taskexecutor/TaskManagerServicesBuilder.java | 12 +- .../TaskSubmissionTestEnvironment.java | 23 ++- .../taskexecutor/slot/TaskSlotTableImplTest.java | 13 +- .../runtime/taskexecutor/slot/TaskSlotUtils.java | 29 ++-- .../TaskCancelAsyncProducerConsumerITCase.java | 11 +- .../apache/flink/runtime/taskmanager/TaskTest.java | 102 +++++++----- .../flink/runtime/taskmanager/TestTaskBuilder.java | 9 +- .../AbstractUdfStreamOperatorLifecycleTest.java | 19 ++- .../partitioner/RescalePartitionerTest.java | 9 +- .../runtime/tasks/StreamTaskCancellationTest.java | 19 ++- .../runtime/tasks/StreamTaskTerminationTest.java | 9 +- .../streaming/runtime/tasks/StreamTaskTest.java | 32 +++- .../test/accumulators/AccumulatorLiveITCase.java | 9 +- .../flink/test/checkpointing/RescalingITCase.java | 9 +- .../flink/test/checkpointing/SavepointITCase.java | 10 +- .../JobManagerHAProcessFailureRecoveryITCase.java | 11 +- .../recovery/ProcessFailureCancelingITCase.java | 8 +- .../restore/AbstractOperatorRestoreTestBase.java | 17 +- .../apache/flink/yarn/YarnConfigurationITCase.java | 4 +- tools/maven/suppressions-runtime.xml | 2 +- 145 files changed, 1679 insertions(+), 835 deletions(-)