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