From 9e913b799b5b13910d9b95a6dfb5fc156dacc8b8 Mon Sep 17 00:00:00 2001
From: "sainthxd@gmail.com" <sainthxd@gmail.com>
Date: Thu, 16 Jul 2015 21:45:34 +0800
Subject: [PATCH] change the port of Cassandra (previous version 1.2) as a
parameter instead of a constant 9160
---
.../src/main/java/com/yahoo/ycsb/db/CassandraClient10.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/cassandra/src/main/java/com/yahoo/ycsb/db/CassandraClient10.java b/cassandra/src/main/java/com/yahoo/ycsb/db/CassandraClient10.java
index c5d1a20c..669cf029 100644
--- a/cassandra/src/main/java/com/yahoo/ycsb/db/CassandraClient10.java
+++ b/cassandra/src/main/java/com/yahoo/ycsb/db/CassandraClient10.java
@@ -136,7 +136,7 @@ public class CassandraClient10 extends DB
for (int retry = 0; retry < ConnectionRetries; retry++)
{
- tr = new TFramedTransport(new TSocket(myhost, 9160));
+ tr = new TFramedTransport(new TSocket(myhost, Integer.parseInt(getProperties().getProperty("port","9160"))));
TProtocol proto = new TBinaryProtocol(tr);
client = new Cassandra.Client(proto);
try
--
GitLab