Instead of throwing exception when tokenRange finding fails, write to…

… first available node
hawkular · Feb 24, 2017 · 31c1332 · 31c1332
1 parent c589d3f
commit 31c1332
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../metrics-core-service/src/main/java/org/hawkular/metrics/core/service/DataAccessImpl.java b/.../metrics-core-service/src/main/java/org/hawkular/metrics/core/service/DataAccessImpl.java
@@ -669,7 +669,8 @@ private Observable.Transformer<BoundStatement, Integer> applyMicroBatching() {
                             return tokenRange;
                         }
                     }
-                    throw new RuntimeException("Unable to find any Cassandra node to insert token " + token.toString());
+                    log.warn("Unable to find any Cassandra node to insert token " + token.toString());
+                    return session.getCluster().getMetadata().getTokenRanges().iterator().next();
                 })
                 .flatMap(g -> g.compose(new BoundBatchStatementTransformer()))
                 .flatMap(batch -> rxSession