From 8c38859456076d73db497010e96eb3ea3fc15f56 Mon Sep 17 00:00:00 2001 From: Mikel Nelson Date: Mon, 23 Mar 2015 13:50:38 -0700 Subject: [PATCH] Issue #5737 Cassandra Cluster Example Custom Seed Cores on First Node --- cassandra/README.md | 3 +++ cassandra/java/io/k8s/cassandra/KubernetesSeedProvider.java | 3 +++ 2 files changed, 6 insertions(+) diff --git a/cassandra/README.md b/cassandra/README.md index a463c9fa..18338a23 100644 --- a/cassandra/README.md +++ b/cassandra/README.md @@ -295,10 +295,13 @@ public class KubernetesSeedProvider implements SeedProvider { ObjectMapper mapper = new ObjectMapper(); Endpoints endpoints = mapper.readValue(url, Endpoints.class); if (endpoints != null) { + // Here is a problem point, endpoints.endpoints can be null in first node cases. + if (endpoints.endpoints != null){ for (String endpoint : endpoints.endpoints) { String[] parts = endpoint.split(":"); list.add(InetAddress.getByName(parts[0])); } + } } } catch (IOException ex) { logger.warn("Request to kubernetes apiserver failed"); diff --git a/cassandra/java/io/k8s/cassandra/KubernetesSeedProvider.java b/cassandra/java/io/k8s/cassandra/KubernetesSeedProvider.java index e1e2fbae..8b8ad40b 100644 --- a/cassandra/java/io/k8s/cassandra/KubernetesSeedProvider.java +++ b/cassandra/java/io/k8s/cassandra/KubernetesSeedProvider.java @@ -70,10 +70,13 @@ public class KubernetesSeedProvider implements SeedProvider { ObjectMapper mapper = new ObjectMapper(); Endpoints endpoints = mapper.readValue(url, Endpoints.class); if (endpoints != null) { + // Here is a problem point, endpoints.endpoints can be null in first node cases. + if (endpoints.endpoints != null){ for (String endpoint : endpoints.endpoints) { String[] parts = endpoint.split(":"); list.add(InetAddress.getByName(parts[0])); } + } } } catch (IOException ex) { logger.warn("Request to kubernetes apiserver failed");