This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d480e25 [FLINK-14840] Use Executor interface in SQL cli
add 9000a9b [hotfix][yarn] Move getDynamicProperties from yarn utils to
BootstrapTools
add c63f407 [hotfix][yarn] Fix typos in YarnResourceManager
add 3aa143f [hotfix][yarn] Add ActiveResourceManager containing some
common codes
add fc37b6d [FLINK-9495][kubernetes] Implement ResourceManager for
Kubernetes
No new revisions were added by this update.
Summary of changes:
.../kubernetes/KubernetesResourceManager.java | 338 +++++++++++++++++++
.../flink/kubernetes/KubernetesWorkerNode.java | 40 +--
.../kubernetes/KubernetesResourceManagerTest.java | 359 +++++++++++++++++++++
.../flink/kubernetes/KubernetesWorkerNodeTest.java | 45 +--
.../runtime/clusterframework/BootstrapTools.java | 30 ++
.../resourcemanager/ActiveResourceManager.java | 120 +++++++
.../clusterframework/BootstrapToolsTest.java | 14 +
.../src/main/java/org/apache/flink/yarn/Utils.java | 31 --
.../org/apache/flink/yarn/YarnResourceManager.java | 66 ++--
.../test/java/org/apache/flink/yarn/UtilsTest.java | 16 -
10 files changed, 918 insertions(+), 141 deletions(-)
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/registration/TaskExecutorConnection.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesWorkerNode.java
(52%)
create mode 100644
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResourceManagerTest.java
copy
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/WindowCreationValidationTest.java
=>
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesWorkerNodeTest.java
(51%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ActiveResourceManager.java
