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 <[email protected]> Authored: Thu Sep 22 10:27:36 2016 -0700 Committer: Hitesh Khamesra <[email protected]> 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]]
