[flink] branch master updated (083933a -> 31e9b3d)

[xt...@apache.org]

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 083933a  [FLINK-18917][docs][python] Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" -> "Table API" section
     add 4b0295f  [FLINK-18720][runtime] Initialize ResourceManagerDriver with ScheduledExecutor rather than Executor.
     add 7951838  [FLINK-18720][runtime] Introduce AbstractResourceManagerDriver as common base class of resource manager drivers.
     add 8e2e1d4  [FLINK-18720][k8s] Introduce KubernetesResourceManagerDriver.
     add d9e2f33  [FLINK-18720][k8s] Enable pod creation interval for KubernetesResourceManagerDriver.
     add 31e9b3d  [FLINK-18720][k8s] Switch kubernetes deployment to the new active resource manager implementation.

No new revisions were added by this update.

Summary of changes:
 .../kubernetes/KubernetesResourceManager.java      | 375 -----------
 .../KubernetesResourceManagerDriver.java           | 326 ++++++++++
 .../flink/kubernetes/KubernetesWorkerNode.java     |   2 +-
 ...ernetesResourceManagerDriverConfiguration.java} |   6 +-
 .../KubernetesResourceManagerFactory.java          |  66 +-
 .../KubernetesResourceManagerDriverTest.java       | 302 +++++++++
 .../kubernetes/KubernetesResourceManagerTest.java  | 719 ---------------------
 .../kubeclient/TestingFlinkKubeClient.java         | 180 ++++++
 .../kubeclient/resources/TestingKubernetesPod.java |  28 +-
 .../active/AbstractResourceManagerDriver.java      |  76 +++
 .../active/ActiveResourceManager.java              |  37 +-
 ...tory.java => ActiveResourceManagerFactory.java} |  72 ++-
 .../active/ResourceManagerDriver.java              |   4 +-
 .../active/ResourceManagerDriverTestBase.java      | 201 ++++++
 .../active/TestingResourceEventHandler.java        |  98 +++
 .../active/TestingResourceManagerDriver.java       |  12 +-
 16 files changed, 1314 insertions(+), 1190 deletions(-)
 delete mode 100644 flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java
 create mode 100644 flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
 rename flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/{KubernetesResourceManagerConfiguration.java => KubernetesResourceManagerDriverConfiguration.java} (86%)
 create mode 100644 flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriverTest.java
 delete mode 100644 flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResourceManagerTest.java
 create mode 100644 flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/TestingFlinkKubeClient.java
 copy flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/schema/Column.java => flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/resources/TestingKubernetesPod.java (66%)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/AbstractResourceManagerDriver.java
 copy flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/{LegacyActiveResourceManagerFactory.java => ActiveResourceManagerFactory.java} (54%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/active/ResourceManagerDriverTestBase.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/active/TestingResourceEventHandler.java