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 c5c3f1c [FLINK-24848][rest] Return 404 for unknown operation
new 49a05f4 [FLINK-25080][tests] Move TestingUtils to flink-core
new e37e636 [FLINK-25080][tests] Remove dependency on Acknowledge class
new 45f4ba5 [FLINK-25080][tests] Move ManuallyTriggeredScheduledExecutor
to flink-core
new 6f05e6f [FLINK-25080][tests] Move tests to flink-core
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/flink}/testutils/TestingUtils.java | 17 +++++++++--------
.../flink/util}/concurrent/ConjunctFutureTest.java | 3 +--
.../concurrent/ExponentialBackoffRetryStrategyTest.java | 4 +---
.../flink/util}/concurrent/FixedRetryStrategyTest.java | 4 +---
.../apache/flink/util}/concurrent/FutureUtilsTest.java | 16 ++++++----------
.../concurrent/ManuallyTriggeredScheduledExecutor.java | 4 +---
.../runtime/jobmanager/JMXJobManagerMetricTest.java | 2 +-
.../itcases/AbstractQueryableStateTestBase.java | 2 +-
.../webmonitor/handlers/JarHandlerParameterTest.java | 2 +-
.../flink/runtime/webmonitor/handlers/JarHandlers.java | 2 +-
.../webmonitor/handlers/JarRunHandlerParameterTest.java | 2 +-
.../checkpoint/CheckpointCoordinatorFailureTest.java | 2 +-
.../CheckpointCoordinatorMasterHooksTest.java | 2 +-
.../checkpoint/CheckpointCoordinatorRestoringTest.java | 2 +-
.../runtime/checkpoint/CheckpointCoordinatorTest.java | 2 +-
.../checkpoint/CheckpointCoordinatorTestingUtils.java | 2 +-
.../checkpoint/CheckpointCoordinatorTriggeringTest.java | 2 +-
.../runtime/checkpoint/CheckpointStateRestoreTest.java | 2 +-
.../FailoverStrategyCheckpointCoordinatorTest.java | 2 +-
.../ZooKeeperCompletedCheckpointStoreITCase.java | 2 +-
.../dispatcher/FileExecutionGraphInfoStoreTest.java | 4 ++--
.../runner/DefaultDispatcherRunnerITCase.java | 2 +-
.../runner/ZooKeeperDefaultDispatcherRunnerTest.java | 2 +-
.../executiongraph/ExecutionGraphRestartTest.java | 2 +-
.../executiongraph/ExecutionGraphSuspendTest.java | 2 +-
.../runtime/executiongraph/ExecutionGraphTestUtils.java | 2 +-
.../TestingDefaultExecutionGraphBuilder.java | 2 +-
.../flink/runtime/heartbeat/HeartbeatManagerTest.java | 4 ++--
.../nonha/embedded/EmbeddedLeaderServiceTest.java | 2 +-
.../io/network/netty/CancelPartitionRequestTest.java | 2 +-
.../network/netty/ClientTransportErrorHandlingTest.java | 2 +-
.../network/netty/ServerTransportErrorHandlingTest.java | 2 +-
.../partition/PartialConsumePipelinedResultTest.java | 2 +-
.../jobmanager/SlotCountExceedingParallelismTest.java | 2 +-
.../TestingJobManagerSharedServicesBuilder.java | 2 +-
.../slotpool/DeclarativeSlotPoolBridgeBuilder.java | 2 +-
.../jobmaster/slotpool/SlotPoolInteractionsTest.java | 2 +-
.../LeaderChangeClusterComponentsTest.java | 2 +-
.../runtime/leaderelection/LeaderElectionTest.java | 2 +-
.../leaderretrieval/ZooKeeperLeaderRetrievalTest.java | 2 +-
.../runtime/registration/RetryingRegistrationTest.java | 2 +-
.../resourcemanager/DefaultJobLeaderIdServiceTest.java | 2 +-
.../ResourceManagerPartitionLifecycleTest.java | 2 +-
.../ResourceManagerTaskExecutorTest.java | 2 +-
.../runtime/resourcemanager/ResourceManagerTest.java | 2 +-
.../slotmanager/DeclarativeSlotManagerBuilder.java | 2 +-
.../slotmanager/DeclarativeSlotManagerTest.java | 4 ++--
.../slotmanager/DefaultSlotStatusSyncerTest.java | 2 +-
.../slotmanager/FineGrainedSlotManagerTestBase.java | 2 +-
.../slotmanager/SlotManagerConfigurationBuilder.java | 2 +-
.../slotmanager/TaskExecutorManagerBuilder.java | 2 +-
.../slotmanager/TaskExecutorManagerTest.java | 2 +-
.../flink/runtime/rest/RestClientMultipartTest.java | 2 +-
.../org/apache/flink/runtime/rest/RestClientTest.java | 2 +-
.../flink/runtime/rest/RestExternalHandlersITCase.java | 2 +-
.../flink/runtime/rest/RestServerEndpointITCase.java | 2 +-
.../handler/cluster/JobManagerCustomLogHandlerTest.java | 2 +-
.../handler/cluster/JobManagerLogListHandlerTest.java | 2 +-
.../runtime/rest/handler/job/JobConfigHandlerTest.java | 2 +-
.../rest/handler/job/JobExceptionsHandlerTest.java | 2 +-
.../runtime/rest/handler/job/JobSubmitHandlerTest.java | 2 +-
.../job/SubtaskCurrentAttemptDetailsHandlerTest.java | 2 +-
.../SubtaskExecutionAttemptAccumulatorsHandlerTest.java | 2 +-
.../job/SubtaskExecutionAttemptDetailsHandlerTest.java | 2 +-
.../job/metrics/AggregatingMetricsHandlerTestBase.java | 2 +-
.../taskmanager/AbstractTaskManagerFileHandlerTest.java | 2 +-
.../taskmanager/TaskManagerDetailsHandlerTest.java | 2 +-
.../taskmanager/TaskManagerLogListHandlerTest.java | 2 +-
.../scheduler/DefaultExecutionGraphFactoryTest.java | 2 +-
.../flink/runtime/scheduler/DefaultSchedulerTest.java | 2 +-
.../flink/runtime/scheduler/SchedulerTestingUtils.java | 2 +-
.../scheduler/adaptive/AdaptiveSchedulerBuilder.java | 2 +-
.../scheduler/benchmark/SchedulerBenchmarkBase.java | 2 +-
.../taskexecutor/TaskManagerServicesBuilder.java | 2 +-
.../taskexecutor/TaskSubmissionTestEnvironment.java | 2 +-
.../flink/runtime/taskexecutor/slot/TaskSlotUtils.java | 2 +-
.../TaskCancelAsyncProducerConsumerITCase.java | 2 +-
.../flink/runtime/taskmanager/TestTaskBuilder.java | 2 +-
.../threadinfo/JobVertexThreadInfoTrackerTest.java | 2 +-
.../runtime/tasks/StreamTaskTerminationTest.java | 2 +-
flink-test-utils-parent/flink-test-utils/pom.xml | 8 ++++++++
.../flink/test/accumulators/AccumulatorLiveITCase.java | 2 +-
.../apache/flink/test/cancelling/CancelingTestBase.java | 2 +-
.../flink/test/checkpointing/RescalingITCase.java | 2 +-
.../flink/test/checkpointing/SavepointITCase.java | 2 +-
.../JobManagerHAProcessFailureRecoveryITCase.java | 2 +-
.../test/recovery/ProcessFailureCancelingITCase.java | 2 +-
.../restore/AbstractOperatorRestoreTestBase.java | 2 +-
.../org/apache/flink/yarn/YarnConfigurationITCase.java | 2 +-
89 files changed, 112 insertions(+), 114 deletions(-)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink}/testutils/TestingUtils.java (75%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/util}/concurrent/ConjunctFutureTest.java
(99%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/util}/concurrent/ExponentialBackoffRetryStrategyTest.java
(94%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/util}/concurrent/FixedRetryStrategyTest.java
(92%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/util}/concurrent/FutureUtilsTest.java
(98%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/util}/concurrent/ManuallyTriggeredScheduledExecutor.java
(97%)
