This is an automated email from the ASF dual-hosted git repository. ilgrosso pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/openjpa.git
The following commit(s) were added to refs/heads/master by this push: new 6be0f5b Considering only active pods for TCPRemoteCommitProvider (#85) 6be0f5b is described below commit 6be0f5b061887bdfee948044d28bae4673204b1e Author: Francesco Chicchiriccò <ilgro...@users.noreply.github.com> AuthorDate: Mon Oct 25 12:25:04 2021 +0200 Considering only active pods for TCPRemoteCommitProvider (#85) --- .../openjpa/event/kubernetes/KubernetesTCPRemoteCommitProvider.java | 2 ++ pom.xml | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/openjpa-kubernetes/src/main/java/org/apache/openjpa/event/kubernetes/KubernetesTCPRemoteCommitProvider.java b/openjpa-kubernetes/src/main/java/org/apache/openjpa/event/kubernetes/KubernetesTCPRemoteCommitProvider.java index 7b7d945..e0e1247 100644 --- a/openjpa-kubernetes/src/main/java/org/apache/openjpa/event/kubernetes/KubernetesTCPRemoteCommitProvider.java +++ b/openjpa-kubernetes/src/main/java/org/apache/openjpa/event/kubernetes/KubernetesTCPRemoteCommitProvider.java @@ -21,6 +21,7 @@ package org.apache.openjpa.event.kubernetes; import io.fabric8.kubernetes.client.DefaultKubernetesClient; import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.KubernetesClientException; +import io.fabric8.kubernetes.client.internal.readiness.Readiness; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.List; @@ -67,6 +68,7 @@ public class KubernetesTCPRemoteCommitProvider extends DynamicTCPRemoteCommitPro try (KubernetesClient client = kubernetesClient()) { podIPs.addAll(client.pods().inNamespace(_namespace).withLabel(_label).list(). getItems().stream(). + filter(Readiness::isPodReady). map(pod -> pod.getStatus().getPodIP()). collect(Collectors.toList())); diff --git a/pom.xml b/pom.xml index 6a15f98..9fe6986 100644 --- a/pom.xml +++ b/pom.xml @@ -85,7 +85,7 @@ <mssql.connector.version>9.2.1.jre8</mssql.connector.version> <!-- other common versions --> - <kubernetes-client.version>5.4.1</kubernetes-client.version> + <kubernetes-client.version>5.9.0</kubernetes-client.version> <slf4j.version>1.7.23</slf4j.version> <!-- Compile Java source/target class level --> <compile.class.source>${java.class.version}</compile.class.source>