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 6a7b464 [FLINK-18659][hive][orc] Fix streaming write for Hive 1.x Orc
table
add dfee6a6 [hotfix][runtime] Move active resource manager related
classes to separate package.
add f7a227d [hotfix][runtime] Move PendingWorkerCounter to a separate
file.
add dfd8823 [hotfix][runtime] Make ResourceManager#onStart final.
add 0fe2047 [hotfix][runtime] Refactor resource manager termination
handling.
add 25c803f [hotfix][runtime] Guard
ResourceManager#startServicesOnLeadership from being overridden.
add 974298b [hotfix][runtime] Refactor
ResourceManager#onTaskManagerRegistration argument type.
add 0c689aa [hotfix][runtime] Add equals() and hashCode() or
CommonProcessMemorySpec.
add 8edbdff [FLINK-18719][runtime] Rename ActiveResourceManager to
LegacyActiveResourceManager.
add 26ce629 [FLINK-18719][runtime] Introduce interfaces
ResourceManagerDriver and ResourceEventHandler.
add d17993f [FLINK-18719][runtime] Introduce new ActiveResourceManager.
No new revisions were added by this update.
Summary of changes:
.../kubernetes/KubernetesResourceManager.java | 19 +-
.../KubernetesResourceManagerFactory.java | 4 +-
.../clusterframework/MesosResourceManager.java | 4 +-
.../MesosResourceManagerFactory.java | 4 +-
.../runtime/jobmanager/JobManagerProcessSpec.java | 11 +
.../runtime/resourcemanager/ResourceManager.java | 29 +-
.../resourcemanager/StandaloneResourceManager.java | 8 +-
.../active/ActiveResourceManager.java | 287 ++++++++++++++
.../LegacyActiveResourceManager.java} | 69 +---
.../LegacyActiveResourceManagerFactory.java} | 6 +-
.../active/PendingWorkerCounter.java | 61 +++
.../active/ResourceEventHandler.java | 53 +++
.../active/ResourceManagerDriver.java | 90 +++++
.../config/memory/CommonProcessMemorySpec.java | 21 +
.../config/memory/JvmMetaspaceAndOverhead.java | 20 +
.../memory/jobmanager/JobManagerFlinkMemory.java | 25 +-
.../taskmanager/TaskExecutorFlinkMemory.java | 29 ++
.../resourcemanager/TestingResourceManager.java | 5 +
.../active/ActiveResourceManagerTest.java | 437 +++++++++++++++++++++
.../PendingWorkerCounterTest.java} | 11 +-
.../active/TestingResourceManagerDriver.java | 134 +++++++
.../config/memory/JobManagerProcessSpecTest.java | 68 ++++
.../config/memory/TaskExecutorProcessSpecTest.java | 89 +++++
.../org/apache/flink/yarn/YarnResourceManager.java | 19 +-
.../entrypoint/YarnResourceManagerFactory.java | 4 +-
25 files changed, 1403 insertions(+), 104 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/{ActiveResourceManager.java
=> active/LegacyActiveResourceManager.java} (76%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/{ActiveResourceManagerFactory.java
=> active/LegacyActiveResourceManagerFactory.java} (90%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/PendingWorkerCounter.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ResourceEventHandler.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ResourceManagerDriver.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManagerTest.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/{ActiveResourceManagerTest.java
=> active/PendingWorkerCounterTest.java} (86%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/active/TestingResourceManagerDriver.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/util/config/memory/JobManagerProcessSpecTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/util/config/memory/TaskExecutorProcessSpecTest.java
