This is an automated email from the ASF dual-hosted git repository.
azagrebin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f4a062a [hotfix][javadocs] Fix typo
add 577abe7 [FLINK-15790][k8s] Make some interfaces in FlinkKubeClient
asynchronous which potentially blocks the execution of RpcEndpoint's main thread
No new revisions were added by this update.
Summary of changes:
.../kubernetes/KubernetesClusterDescriptor.java | 10 +-
.../kubernetes/KubernetesResourceManager.java | 55 +++++---
.../flink/kubernetes/cli/KubernetesSessionCli.java | 2 +-
.../KubernetesResourceManagerConfiguration.java | 26 ++--
.../KubernetesResourceManagerFactory.java | 14 +-
.../kubeclient/Fabric8FlinkKubeClient.java | 153 +++++++++++++--------
.../kubernetes/kubeclient/FlinkKubeClient.java | 27 ++--
.../kubernetes/kubeclient/KubeClientFactory.java | 9 +-
.../kubernetes/KubernetesResourceManagerTest.java | 78 +++++++++--
.../flink/kubernetes/KubernetesTestBase.java | 3 +-
.../kubeclient/Fabric8FlinkKubeClientTest.java | 41 +++---
11 files changed, 283 insertions(+), 135 deletions(-)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerBatchSchedulingTest.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesResourceManagerConfiguration.java
(59%)
