You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by xt...@apache.org on 2020/10/12 10:46:52 UTC
[flink] branch master updated (162c072 -> 5076e4a)
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 162c072 [FLINK-19492][core] Consolidate Source Events between Source API and Split Reader API
add 7fe187b [hotfix][mesos] Remove unused argument 'executor' from MesosServices.createMesosWorkerStore.
add 0de3df3 [hotfix][mesos] Replace deprecated UntypedActor with UntypedAbstractActor for MesosResourceManager.AkkaAdapter.
add f7545b0 [hotfix][mesos] Remove unused methods and extract interface for MesosArtifactServer.
add cc85ce3 [hotfix][mesos] Separate creating of mesos scheduler driver from MesosConfiguration.
add deb4c6b [hotfix][mesos] Separate actor creation from MesosResourceManager.
add 818e48d [FLINK-18722][runtime] Expose granting and revoking of RM leadership to ResourceManagerDriver.
add e598b60 [FLINK-18722][runtime] Expose resource manager's IO executor to resource manager drivers.
add 41c63e3 [FLINK-18722][mesos] Introduce MesosResourceManagerDriver.
add 5076e4a [FLINK-18722][mesos] Switch to the new active resource manager for Mesos deployment.
No new revisions were added by this update.
Summary of changes:
.../KubernetesResourceManagerFactory.java | 5 +-
.../MesosResourceManagerActorFactory.java | 79 ++
.../MesosResourceManagerActorFactoryImpl.java | 111 +++
...anager.java => MesosResourceManagerDriver.java} | 681 ++++++-----------
.../MesosResourceManagerFactory.java | 61 +-
.../RegisteredMesosWorkerNode.java | 4 +-
.../services/AbstractMesosServices.java | 30 +-
.../clusterframework/services/MesosServices.java | 28 +-
.../services/MesosServicesUtils.java | 3 +-
.../services/StandaloneMesosServices.java | 4 +-
.../services/ZooKeeperMesosServices.java | 4 +-
.../clusterframework/store/MesosWorkerStore.java | 30 +-
.../flink/mesos/util/MesosArtifactServer.java | 338 +-------
...actServer.java => MesosArtifactServerImpl.java} | 71 +-
.../flink/mesos/util/MesosConfiguration.java | 24 -
.../MesosResourceManagerDriverTest.java | 385 ++++++++++
.../clusterframework/MesosResourceManagerTest.java | 850 ---------------------
.../services/TestingMesosServices.java | 137 ++++
.../store/MesosWorkerStoreTest.java | 4 +-
.../store/TestingMesosWorkerStore.java | 168 ++++
.../mesos/scheduler/TestingSchedulerDriver.java | 206 +++++
.../mesos/util/TestingMesosArtifactServer.java | 98 +++
.../active/AbstractResourceManagerDriver.java | 13 +-
.../active/ActiveResourceManager.java | 13 +-
.../active/ActiveResourceManagerFactory.java | 5 +-
.../active/ResourceManagerDriver.java | 30 +-
.../active/ResourceManagerDriverTestBase.java | 6 +-
.../active/TestingResourceManagerDriver.java | 25 +-
28 files changed, 1588 insertions(+), 1825 deletions(-)
create mode 100644 flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactory.java
create mode 100644 flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactoryImpl.java
rename flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/{MesosResourceManager.java => MesosResourceManagerDriver.java} (50%)
mode change 100755 => 100644
copy flink-mesos/src/main/java/org/apache/flink/mesos/util/{MesosArtifactServer.java => MesosArtifactServerImpl.java} (84%)
create mode 100644 flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerDriverTest.java
delete mode 100644 flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java
create mode 100644 flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/services/TestingMesosServices.java
create mode 100644 flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/store/TestingMesosWorkerStore.java
create mode 100644 flink-mesos/src/test/java/org/apache/flink/mesos/scheduler/TestingSchedulerDriver.java
create mode 100644 flink-mesos/src/test/java/org/apache/flink/mesos/util/TestingMesosArtifactServer.java