You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openjpa.apache.org by il...@apache.org on 2021/10/25 10:25:07 UTC
[openjpa] branch master updated: Considering only active pods for
TCPRemoteCommitProvider (#85)
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ò <il...@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>