flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [flink] branch master updated (845fb95 -> 85d7374)
Date Mon, 04 Nov 2019 12:27:03 GMT
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


Mime
View raw message