You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/11/04 12:27:03 UTC
[flink] branch master updated (845fb95 -> 85d7374)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 845fb95 [FLINK-14080][table-planner-blink] Introduce SqlTimestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE
add 76225ed [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true
add 7e3a92b [hotfix] Fix checkstyle violations in SchedulerIsolatedTasksTest
add ee32514 [hotfix] Fix checkstyle violation in SchedulerTestBase
add aa10ec8 [hotfix] Enable SchedulerTestBase to use different ComponentMainThreadExecutors
add 85d7374 [FLINK-14462] Enable ScheduleIsolatedTasksTest#testScheduleWithDyingInstances
No new revisions were added by this update.
Summary of changes:
docs/ops/deployment/mesos.md | 4 +-
docs/ops/deployment/mesos.zh.md | 4 +-
.../org/apache/flink/client/LocalExecutor.java | 2 -
.../client/program/rest/RestClusterClient.java | 3 -
.../entrypoint/ClassPathJobGraphRetriever.java | 1 -
.../optimizer/plantranslate/JobGraphGenerator.java | 2 -
.../runtime/webmonitor/handlers/JarRunHandler.java | 6 +-
.../flink/runtime/executiongraph/Execution.java | 9 +-
.../runtime/executiongraph/ExecutionGraph.java | 19 +--
.../executiongraph/ExecutionGraphBuilder.java | 3 +-
.../executiongraph/SlotProviderStrategy.java | 28 ++--
.../apache/flink/runtime/jobgraph/JobGraph.java | 11 --
.../runtime/jobmaster/slotpool/SchedulerImpl.java | 102 +++++--------
.../runtime/jobmaster/slotpool/SlotProvider.java | 9 +-
.../flink/runtime/minicluster/MiniCluster.java | 8 -
.../runtime/scheduler/DefaultSchedulerFactory.java | 3 +-
.../ExecutionGraphCheckpointCoordinatorTest.java | 1 -
.../dispatcher/DispatcherResourceCleanupTest.java | 1 -
.../flink/runtime/dispatcher/DispatcherTest.java | 2 -
.../runner/DefaultDispatcherRunnerITCase.java | 5 +-
.../ZooKeeperDefaultDispatcherRunnerTest.java | 2 -
.../ExecutionGraphCoLocationRestartTest.java | 7 +-
.../ExecutionGraphDeploymentTest.java | 49 +++---
.../ExecutionGraphNotEnoughResourceTest.java | 169 +++++++++++++++++++++
.../executiongraph/ExecutionGraphRestartTest.java | 50 ------
.../ExecutionGraphSchedulingTest.java | 7 -
.../executiongraph/ExecutionGraphTestUtils.java | 10 --
.../ExecutionPartitionLifecycleTest.java | 2 +-
.../executiongraph/ExecutionVertexCancelTest.java | 4 +-
.../ExecutionVertexSchedulingTest.java | 6 +-
.../executiongraph/ProgrammedSlotProvider.java | 1 -
.../executiongraph/TestingSlotProvider.java | 2 +-
.../TestingSlotProviderStrategy.java | 8 +-
.../executiongraph/utils/SimpleSlotProvider.java | 4 -
.../SlotCountExceedingParallelismTest.java | 9 +-
.../scheduler/ScheduleWithCoLocationHintTest.java | 127 ++++++++--------
.../scheduler/SchedulerIsolatedTasksTest.java | 125 +++++----------
.../jobmanager/scheduler/SchedulerTestBase.java | 67 ++++----
.../flink/runtime/jobmaster/JobMasterTest.java | 18 +--
.../jobmaster/slotpool/SlotPoolCoLocationTest.java | 10 --
.../jobmaster/slotpool/SlotPoolImplTest.java | 11 --
.../slotpool/SlotPoolInteractionsTest.java | 5 -
.../slotpool/SlotPoolSlotSharingTest.java | 16 --
.../DefaultExecutionSlotAllocatorTest.java | 4 +-
.../LegacySchedulerBatchSchedulingTest.java | 5 +-
.../apache/flink/yarn/YarnClusterDescriptor.java | 4 -
46 files changed, 418 insertions(+), 527 deletions(-)
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphNotEnoughResourceTest.java