From 6be0f5b061887bdfee948044d28bae4673204b1e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Francesco=20Chicchiricc=C3=B2?=
 <ilgrosso@users.noreply.github.com>
Date: Mon, 25 Oct 2021 12:25:04 +0200
Subject: [PATCH] Considering only active pods for TCPRemoteCommitProvider
 (#85)

---
 .../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 7b7d94526..e0e1247e6 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 6a15f98dd..9fe698699 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>