Repository: incubator-geode
Updated Branches:
  refs/heads/develop d639eefd3 -> 85e97c30c


GEODE-37 In spark connector we call TcpClient static method to get
the server info. But TcpClient has no more that static method. Now
we create instance of Tcpclient.


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/85e97c30
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/85e97c30
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/85e97c30

Branch: refs/heads/develop
Commit: 85e97c30ce2130d47d152b4c8970a494f3adf646
Parents: d639eef
Author: Hitesh Khamesra <hkhame...@pivotal.io>
Authored: Thu Sep 22 10:27:36 2016 -0700
Committer: Hitesh Khamesra <hkhame...@pivotal.io>
Committed: Thu Sep 22 10:29:30 2016 -0700

----------------------------------------------------------------------
 .../org/apache/geode/spark/connector/internal/LocatorHelper.scala | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/85e97c30/geode-spark-connector/geode-spark-connector/src/main/scala/org/apache/geode/spark/connector/internal/LocatorHelper.scala
----------------------------------------------------------------------
diff --git 
a/geode-spark-connector/geode-spark-connector/src/main/scala/org/apache/geode/spark/connector/internal/LocatorHelper.scala
 
b/geode-spark-connector/geode-spark-connector/src/main/scala/org/apache/geode/spark/connector/internal/LocatorHelper.scala
index b8b2b14..8b27255 100644
--- 
a/geode-spark-connector/geode-spark-connector/src/main/scala/org/apache/geode/spark/connector/internal/LocatorHelper.scala
+++ 
b/geode-spark-connector/geode-spark-connector/src/main/scala/org/apache/geode/spark/connector/internal/LocatorHelper.scala
@@ -63,7 +63,8 @@ object LocatorHelper extends Logging {
       try {
         val addr = new InetSocketAddress(host, port)
         val req = new GetAllServersRequest(serverGroup)
-        val res = TcpClient.requestToServer(addr.getAddress, addr.getPort, 
req, 2000)
+        val tcpClient = new TcpClient();
+        val res = tcpClient.requestToServer(addr.getAddress, addr.getPort, 
req, 2000)
         if (res != null) {
           import scala.collection.JavaConverters._
           val servers = 
res.asInstanceOf[GetAllServersResponse].getServers.asInstanceOf[JArrayList[ServerLocation]]

Reply via email to