From f2825b701127262011962080bb27a160e7fcdc98 Mon Sep 17 00:00:00 2001 From: phact Date: Mon, 9 Mar 2020 13:08:40 -0400 Subject: [PATCH] support hosts and host interchangeably --- .../activitytype/cql/statements/core/CQLSessionCache.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/activitytype-cql/src/main/java/io/nosqlbench/activitytype/cql/statements/core/CQLSessionCache.java b/activitytype-cql/src/main/java/io/nosqlbench/activitytype/cql/statements/core/CQLSessionCache.java index b0cbfbb86..ea09d2cb3 100644 --- a/activitytype-cql/src/main/java/io/nosqlbench/activitytype/cql/statements/core/CQLSessionCache.java +++ b/activitytype-cql/src/main/java/io/nosqlbench/activitytype/cql/statements/core/CQLSessionCache.java @@ -79,6 +79,11 @@ public class CQLSessionCache implements Shutdownable { String[] contactPoints = activityDef.getParams().getOptionalString("host") .map(h -> h.split(",")).orElse(null); + if (contactPoints == null) { + contactPoints = activityDef.getParams().getOptionalString("hosts") + .map(h -> h.split(",")).orElse(null); + } + if (contactPoints != null) { builder.addContactPoints(contactPoints); }else if (scb.isEmpty()){