This is an automated email from the ASF dual-hosted git repository.
tison pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cf4e0f1 [FLINK-14503][coordination] Add partition report to heartbeat
new c927e17 [FLINK-14762][client] Handle clients close gracefully
new 1266c88 [FLINK-14762][client] ClusterClient#submitJob returns
CompletableFuture of JobID
new 7741eed [FLINK-14762][tests] Introduce TestingJobClient
new 318e406 [FLINK-14762][client] Implement JobClient#cancel
new 0328fb6 [FLINK-14762][client] Implement JobClient#stopWithSavepoint
new cf4de13 [FLINK-14762][client] Implement JobClient#triggerSavepoint
new d8aa9b9 [FLINK-14762][client] Implement JobClient#getAccumulators
new f3df25d [FLINK-14762][api] Move JobStatus to flink-core
new 3898a4b [FLINK-14762][client] Implement JobClient#getJobStatus
The 9 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/client/ClientUtils.java | 2 -
.../org/apache/flink/client/cli/CliFrontend.java | 2 +-
.../deployment/AbstractJobClusterExecutor.java | 22 ++++++-
.../deployment/AbstractSessionClusterExecutor.java | 9 ++-
.../deployment/ClusterClientJobClientAdapter.java | 63 +++++++++++++------
.../apache/flink/client/program/ClusterClient.java | 20 +++---
.../flink/client/program/MiniClusterClient.java | 24 +++-----
.../client/program/rest/RestClusterClient.java | 67 +++++++++-----------
.../flink/client/cli/CliFrontendListTest.java | 2 +-
.../apache/flink/client/program/ClientTest.java | 2 +-
.../flink/client/program/TestingClusterClient.java | 8 +--
.../client/program/rest/RestClusterClientTest.java | 21 +++----
.../connectors/kafka/KafkaConsumerTestBase.java | 2 +-
.../org/apache/flink/api/common}/JobStatus.java | 5 +-
.../api/common/accumulators/AccumulatorHelper.java | 28 ++++++++-
.../org/apache/flink/core/execution/JobClient.java | 47 ++++++++++++++
.../java/ExecutorDiscoveryAndJobClientTest.java | 18 +-----
.../apache/flink/api/java/TestingJobClient.java | 72 ++++++++++++++++++++++
.../jobmanager/JMXJobManagerMetricTest.java | 2 +-
.../itcases/AbstractQueryableStateTestBase.java | 2 +-
.../history/HistoryServerArchiveFetcher.java | 2 +-
.../webmonitor/history/HistoryServerTest.java | 2 +-
.../runtime/checkpoint/CheckpointCoordinator.java | 2 +-
.../CheckpointCoordinatorDeActivator.java | 2 +-
.../runtime/checkpoint/CheckpointIDCounter.java | 2 +-
.../runtime/checkpoint/CheckpointProperties.java | 2 +-
.../runtime/checkpoint/CompletedCheckpoint.java | 2 +-
.../checkpoint/CompletedCheckpointStore.java | 2 +-
.../checkpoint/StandaloneCheckpointIDCounter.java | 2 +-
.../StandaloneCompletedCheckpointStore.java | 2 +-
.../checkpoint/ZooKeeperCheckpointIDCounter.java | 5 +-
.../ZooKeeperCompletedCheckpointStore.java | 2 +-
.../flink/runtime/client/JobStatusMessage.java | 2 +-
.../clusterframework/ApplicationStatus.java | 2 +-
.../flink/runtime/dispatcher/Dispatcher.java | 2 +-
.../FileArchivedExecutionGraphStore.java | 2 +-
.../MemoryArchivedExecutionGraphStore.java | 2 +-
.../executiongraph/AccessExecutionGraph.java | 2 +-
.../executiongraph/ArchivedExecutionGraph.java | 2 +-
.../runtime/executiongraph/ExecutionGraph.java | 2 +-
.../runtime/executiongraph/JobStatusListener.java | 2 +-
.../runtime/executiongraph/SchedulingUtils.java | 2 +-
.../AdaptedRestartPipelinedRegionStrategyNG.java | 2 +-
.../executiongraph/metrics/DownTimeGauge.java | 4 +-
.../executiongraph/metrics/RestartTimeGauge.java | 4 +-
.../executiongraph/metrics/UpTimeGauge.java | 4 +-
.../apache/flink/runtime/jobmaster/JobMaster.java | 2 +-
.../flink/runtime/jobmaster/JobMasterGateway.java | 2 +-
.../apache/flink/runtime/jobmaster/JobResult.java | 2 +-
.../runtime/messages/webmonitor/JobDetails.java | 2 +-
.../webmonitor/JobIdsWithStatusOverview.java | 2 +-
.../runtime/messages/webmonitor/JobsOverview.java | 2 +-
.../flink/runtime/minicluster/MiniCluster.java | 2 +-
.../rest/handler/job/JobDetailsHandler.java | 2 +-
.../handler/job/JobExecutionResultHandler.java | 2 +-
.../backpressure/BackPressureStatsTrackerImpl.java | 2 +-
.../runtime/rest/messages/job/JobDetailsInfo.java | 2 +-
.../flink/runtime/scheduler/SchedulerBase.java | 2 +-
.../flink/runtime/scheduler/SchedulerNG.java | 2 +-
.../flink/runtime/webmonitor/RestfulGateway.java | 2 +-
.../flink/runtime/webmonitor/WebMonitorUtils.java | 2 +-
.../CheckpointCoordinatorFailureTest.java | 2 +-
.../CheckpointCoordinatorMasterHooksTest.java | 2 +-
.../CheckpointCoordinatorRestoringTest.java | 2 +-
.../checkpoint/CheckpointCoordinatorTest.java | 2 +-
.../CheckpointCoordinatorTriggeringTest.java | 2 +-
.../checkpoint/CheckpointIDCounterTest.java | 5 +-
.../checkpoint/CompletedCheckpointStoreTest.java | 2 +-
.../checkpoint/CompletedCheckpointTest.java | 2 +-
.../ExecutionGraphCheckpointCoordinatorTest.java | 2 +-
.../StandaloneCompletedCheckpointStoreTest.java | 2 +-
.../ZooKeeperCompletedCheckpointStoreITCase.java | 2 +-
.../ZooKeeperCompletedCheckpointStoreTest.java | 2 +-
.../dispatcher/DispatcherResourceCleanupTest.java | 2 +-
.../flink/runtime/dispatcher/DispatcherTest.java | 2 +-
.../FileArchivedExecutionGraphStoreTest.java | 2 +-
.../runtime/dispatcher/MiniDispatcherTest.java | 2 +-
...inedRegionStrategyNGConcurrentFailoverTest.java | 2 +-
...startPipelinedRegionStrategyNGFailoverTest.java | 2 +-
.../executiongraph/ArchivedExecutionGraphTest.java | 2 +-
.../ExecutionGraphCoLocationRestartTest.java | 4 +-
.../ExecutionGraphDeploymentTest.java | 2 +-
.../executiongraph/ExecutionGraphMetricsTest.java | 2 +-
.../ExecutionGraphNotEnoughResourceTest.java | 2 +-
.../executiongraph/ExecutionGraphRestartTest.java | 2 +-
.../ExecutionGraphSchedulingTest.java | 2 +-
.../executiongraph/ExecutionGraphSuspendTest.java | 2 +-
.../executiongraph/ExecutionGraphTestUtils.java | 2 +-
.../ExecutionGraphVariousFailuesTest.java | 2 +-
.../executiongraph/ExecutionVertexCancelTest.java | 2 +-
.../ExecutionVertexInputConstraintTest.java | 2 +-
.../executiongraph/FinalizeOnMasterTest.java | 4 +-
.../executiongraph/GlobalModVersionTest.java | 2 +-
.../jobmaster/JobManagerRunnerImplTest.java | 2 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 2 +-
.../flink/runtime/jobmaster/JobResultTest.java | 2 +-
.../jobmaster/utils/TestingJobMasterGateway.java | 2 +-
.../runtime/messages/GenericMessageTester.java | 6 +-
.../runtime/messages/WebMonitorMessagesTest.java | 2 +-
.../messages/webmonitor/JobDetailsTest.java | 2 +-
.../webmonitor/JobIdsWithStatusOverviewTest.java | 2 +-
.../webmonitor/MultipleJobsDetailsTest.java | 2 +-
.../handler/job/JobExecutionResultHandlerTest.java | 2 +-
.../handler/legacy/ExecutionGraphCacheTest.java | 2 +-
.../utils/ArchivedExecutionGraphBuilder.java | 2 +-
.../rest/messages/job/JobDetailsInfoTest.java | 2 +-
.../runtime/scheduler/DefaultSchedulerTest.java | 2 +-
.../LegacySchedulerBatchSchedulingTest.java | 2 +-
.../TaskCancelAsyncProducerConsumerITCase.java | 2 +-
.../RecoverableCompletedCheckpointStore.java | 2 +-
.../webmonitor/TestingDispatcherGateway.java | 2 +-
.../runtime/webmonitor/TestingRestfulGateway.java | 2 +-
.../api/environment/CheckpointConfig.java | 2 +-
.../RemoteStreamExecutionEnvironmentTest.java | 5 +-
.../ExecutorDiscoveryAndJobClientTest.java | 18 +-----
.../streaming/environment/TestingJobClient.java | 72 ++++++++++++++++++++++
.../client/gateway/local/LocalExecutorITCase.java | 2 +-
.../jobmaster/JobMasterStopWithSavepointIT.java | 2 +-
.../jobmaster/JobMasterTriggerSavepointITCase.java | 2 +-
.../test/accumulators/AccumulatorLiveITCase.java | 2 +-
.../flink/test/cancelling/CancelingTestBase.java | 2 +-
.../flink/test/checkpointing/RescalingITCase.java | 9 +--
.../ResumeCheckpointManuallyITCase.java | 2 +-
.../flink/test/checkpointing/SavepointITCase.java | 2 +-
.../ZooKeeperHighAvailabilityITCase.java | 2 +-
.../utils/SavepointMigrationTestBase.java | 21 +++----
.../flink/test/classloading/ClassLoaderITCase.java | 2 +-
.../flink/test/runtime/FileBufferReaderITCase.java | 7 +--
.../flink/test/runtime/SchedulingITCase.java | 7 +--
.../ZooKeeperLeaderElectionITCase.java | 2 +-
.../restore/AbstractOperatorRestoreTestBase.java | 2 +-
.../flink/yarn/YARNHighAvailabilityITCase.java | 7 +--
132 files changed, 492 insertions(+), 300 deletions(-)
rename {flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph =>
flink-core/src/main/java/org/apache/flink/api/common}/JobStatus.java (97%)
create mode 100644
flink-java/src/test/java/org/apache/flink/api/java/TestingJobClient.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/environment/TestingJobClient.java
