TIBCOSoftware / snappydata

Project SnappyData - memory optimized analytics database, based on Apache Spark™ and Apache Geode™. Stream, Transact, Analyze, Predict in one cluster
http://www.snappydata.io
Other
1.04k stars 200 forks source link

Locator connected with the problem #656

Open cherishDWJ opened 7 years ago

cherishDWJ commented 7 years ago

My cluster has three hosts, a server, a locator, a lead, locator configuration port is 9998, running my code, sometimes connected, sometimes stuck fixed, no error message: My code:

object SmartConnectorExample {

  def main(args: Array[String]): Unit = {

    val spark: SparkSession = SparkSession
        .builder
        .appName("SmartConnectorExample")
        // It can be any master URL
        .master("local[4]")
        // snappydata.connection property enables the application to interact with SnappyData store
        .config("spark.snappydata.store.locators", "    cloudera2:9998")
        .getOrCreate

    val snSession = new SnappySession(spark.sparkContext)

//    println("\n\n ####  Reading from the SnappyStore table SNAPPY_COL_TABLE  ####  \n")
//    val colTable = snSession.table("SNAPPY_COL_TABLE")
//    colTable.show(10)

//    println(" ####  Creating a table TestColumn  #### \n")

    snSession.dropTable("ColumnTbale", ifExists = true)

    // Creating a table from a DataFrame
    val dataFrame = snSession.range(1000).selectExpr("id", "floor(rand() * 10000) as k")

    snSession.sql("create table ColumnTbale (id bigint not null, k bigint not null)")

    dataFrame.write.insertInto("ColumnTbale")

    println(" ####  Write to table completed. ### \n\n" +
        "Now you can query table ColumnTbale using $SNAPPY_HOME/bin/snappy-shell")

     val colTable = snSession.table("ColumnTbale")
    colTable.show(10)

  }

}

Console information:

Using Spark's default log4j profile: org/apache/spark/log4j-defaults.properties
17/06/14 09:35:23 INFO SparkContext: Running Spark version 2.0.2.3
17/06/14 09:35:24 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
17/06/14 09:35:24 INFO SecurityManager: Changing view acls to: admin
17/06/14 09:35:24 INFO SecurityManager: Changing modify acls to: admin
17/06/14 09:35:24 INFO SecurityManager: Changing view acls groups to: 
17/06/14 09:35:24 INFO SecurityManager: Changing modify acls groups to: 
17/06/14 09:35:24 INFO SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users  with view permissions: Set(admin); groups with view permissions: Set(); users  with modify permissions: Set(admin); groups with modify permissions: Set()
17/06/14 09:35:24 INFO Utils: Successfully started service 'sparkDriver' on port 62433.
17/06/14 09:35:24 INFO SparkEnv: Registering MapOutputTracker
17/06/14 09:35:24 INFO SparkEnv: Registering BlockManagerMaster
17/06/14 09:35:24 INFO DiskBlockManager: Created local directory at C:\Users\admin\AppData\Local\Temp\blockmgr-d4eb2918-845f-4acd-90db-46d9b6cf4552
17/06/14 09:35:24 INFO MemoryStore: MemoryStore started with capacity 899.7 MB
17/06/14 09:35:24 INFO SparkEnv: Registering OutputCommitCoordinator
17/06/14 09:35:25 INFO log: Logging initialized @2235ms
17/06/14 09:35:25 INFO Server: jetty-9.2.16.v20160414
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@740d2e78{/jobs,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@1c481ff2{/jobs/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@72437d8d{/jobs/job,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@1b955cac{/jobs/job/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@676cf48{/stages,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@5a1de7fb{/stages/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@335b5620{/stages/stage,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@29a0cdb{/stages/stage/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@32a68f4f{/stages/pool,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@73194df{/stages/pool/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@6eb2384f{/Spark Cache,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@3c9c0d96{/Spark Cache/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@3a4621bd{/Spark Cache/rdd,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@31dadd46{/Spark Cache/rdd/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@4ed5eb72{/environment,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@12f9af83{/environment/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@19b93fa8{/executors,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@7e6ef134{/executors/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@1f010bf0{/executors/threadDump,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@40db2a24{/executors/threadDump/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@10cf09e8{/static,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@1921ad94{/,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@ee86bcb{/api,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@177bea38{/stages/stage/kill,null,AVAILABLE}
17/06/14 09:35:25 INFO ServerConnector: Started ServerConnector@3a0baae5{HTTP/1.1}{0.0.0.0:4040}
17/06/14 09:35:25 INFO Server: Started @2360ms
17/06/14 09:35:25 INFO Utils: Successfully started service 'SparkUI' on port 4040.
17/06/14 09:35:25 INFO SparkUI: Bound SparkUI to 0.0.0.0, and started at http://192.168.16.47:4040
17/06/14 09:35:25 INFO Executor: Starting executor ID driver on host localhost
17/06/14 09:35:25 INFO Utils: Successfully started service 'org.apache.spark.network.netty.NettyBlockTransferService' on port 62455.
17/06/14 09:35:25 INFO NettyBlockTransferService: Server created on 192.168.16.47:62455
17/06/14 09:35:25 INFO BlockManagerMaster: Registering BlockManager BlockManagerId(driver, 192.168.16.47, 62455)
17/06/14 09:35:25 INFO BlockManagerMasterEndpoint: Registering block manager 192.168.16.47:62455 with 899.7 MB RAM, BlockManagerId(driver, 192.168.16.47, 62455)
17/06/14 09:35:25 INFO BlockManagerMaster: Registered BlockManager BlockManagerId(driver, 192.168.16.47, 62455)
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@4721d212{/metrics/json,null,AVAILABLE}
17/06/14 09:35:25 WARN SparkContext: Use an existing SparkContext, some configuration may not take effect.
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@878452d{/SQL,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@4c51bb7{/SQL/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@6b54655f{/SQL/execution,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@7d3430a7{/SQL/execution/json,null,AVAILABLE}
17/06/14 09:35:25 INFO ContextHandler: Started o.e.j.s.ServletContextHandler@165b2f7f{/static/sql,null,AVAILABLE}
17/06/14 09:35:25 INFO SharedState: Warehouse path is 'file:/D:/workSpace/SparkSql/spark-warehouse'.
17/06/14 09:35:25 INFO SnappySharedState: Warehouse path is 'file:/D:/workSpace/SparkSql/spark-warehouse'.

The gemfirexd-interface.log informateion:

17/06/14 09:35:27.028 CST main<tid=0x1> INFO snappystore: 
---------------------------------------------------------------------------

  Copyright (c) 2016 SnappyData, Inc. All rights reserved.

  Licensed under the Apache License, Version 2.0 (the "License"); you
  may not use this file except in compliance with the License. You
  may obtain a copy of the License at

  http://www.apache.org/licenses/LICENSE-2.0

  Unless required by applicable law or agreed to in writing, software
  distributed under the License is distributed on an "AS IS" BASIS,
  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
  implied. See the License for the specific language governing
  permissions and limitations under the License. See accompanying
  LICENSE file.

---------------------------------------------------------------------------
Java version:   1.5.4 amogh 031017 2017-03-10 17:51:17 +0530 javac 1.8.0_66
Native version: gemfirexd native code unavailable
Source revision: 392bbf24c28530a624b81e1f95232b6da6688e53
Source repository: branch-1.5.4
Running on: LAPTOP-MO9756P2/192.168.16.47, 4 cpu(s), amd64 Windows 10 10.0
Process ID: 79676
User: admin
Current dir: D:\workSpace\SparkSql
Home dir: C:\Users\admin
Command Line Parameters:
  -Dfile.encoding=UTF-8
  -Xbootclasspath/p:D:\eclipse\plugins\org.scala-lang.scala-library_2.11.8.v20160304-115712-1706a37eb8.jar;D:\eclipse\plugins\org.scala-lang.scala-reflect_2.11.8.v20160304-115712-1706a37eb8.jar
Class Path:
  D:\workSpace\SparkSql\target\classes
  D:\workSpace\SparkSql\target\test-classes
  D:\apache-maven-3.5.0\repository\io\snappydata\snappydata-cluster_2.11\0.8\snappydata-cluster_2.11-0.8.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-yarn_2.11\2.0.2.3\snappy-spark-yarn_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-http\9.2.16.v20160414\jetty-http-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-yarn-server-web-proxy\2.7.3\hadoop-yarn-server-web-proxy-2.7.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-yarn-server-common\2.7.3\hadoop-yarn-server-common-2.7.3.jar
  D:\apache-maven-3.5.0\repository\org\mortbay\jetty\jetty\6.1.26\jetty-6.1.26.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-plus\9.2.16.v20160414\jetty-plus-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-webapp\9.2.16.v20160414\jetty-webapp-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-xml\9.2.16.v20160414\jetty-xml-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-jndi\9.2.16.v20160414\jetty-jndi-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-server\9.2.16.v20160414\jetty-server-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-io\9.2.16.v20160414\jetty-io-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-servlet\9.2.16.v20160414\jetty-servlet-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\apache\thrift\libfb303\0.9.3\libfb303-0.9.3.jar
  D:\apache-maven-3.5.0\repository\org\spark-project\hive\hive-metastore\1.2.1.spark2\hive-metastore-1.2.1.spark2.jar
  D:\apache-maven-3.5.0\repository\com\jolbox\bonecp\0.8.0.RELEASE\bonecp-0.8.0.RELEASE.jar
  D:\apache-maven-3.5.0\repository\commons-cli\commons-cli\1.2\commons-cli-1.2.jar
  D:\apache-maven-3.5.0\repository\commons-lang\commons-lang\2.6\commons-lang-2.6.jar
  D:\apache-maven-3.5.0\repository\commons-logging\commons-logging\1.1.3\commons-logging-1.1.3.jar
  D:\apache-maven-3.5.0\repository\org\datanucleus\datanucleus-api-jdo\3.2.6\datanucleus-api-jdo-3.2.6.jar
  D:\apache-maven-3.5.0\repository\org\datanucleus\datanucleus-rdbms\3.2.9\datanucleus-rdbms-3.2.9.jar
  D:\apache-maven-3.5.0\repository\javax\jdo\jdo-api\3.0.1\jdo-api-3.0.1.jar
  D:\apache-maven-3.5.0\repository\javax\transaction\jta\1.1\jta-1.1.jar
  D:\apache-maven-3.5.0\repository\org\antlr\antlr-runtime\3.4\antlr-runtime-3.4.jar
  D:\apache-maven-3.5.0\repository\org\antlr\stringtemplate\3.2.1\stringtemplate-3.2.1.jar
  D:\apache-maven-3.5.0\repository\antlr\antlr\2.7.7\antlr-2.7.7.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-yarn-common\2.7.3\hadoop-yarn-common-2.7.3.jar
  D:\apache-maven-3.5.0\repository\javax\xml\bind\jaxb-api\2.2.2\jaxb-api-2.2.2.jar
  D:\apache-maven-3.5.0\repository\javax\xml\stream\stax-api\1.0-2\stax-api-1.0-2.jar
  D:\apache-maven-3.5.0\repository\org\apache\commons\commons-compress\1.4.1\commons-compress-1.4.1.jar
  D:\apache-maven-3.5.0\repository\org\tukaani\xz\1.0\xz-1.0.jar
  D:\apache-maven-3.5.0\repository\org\mortbay\jetty\jetty-util\6.1.26\jetty-util-6.1.26.jar
  D:\apache-maven-3.5.0\repository\com\sun\jersey\jersey-core\1.9\jersey-core-1.9.jar
  D:\apache-maven-3.5.0\repository\com\sun\jersey\jersey-client\1.9\jersey-client-1.9.jar
  D:\apache-maven-3.5.0\repository\org\codehaus\jackson\jackson-core-asl\1.9.13\jackson-core-asl-1.9.13.jar
  D:\apache-maven-3.5.0\repository\org\codehaus\jackson\jackson-jaxrs\1.9.13\jackson-jaxrs-1.9.13.jar
  D:\apache-maven-3.5.0\repository\org\codehaus\jackson\jackson-xc\1.9.13\jackson-xc-1.9.13.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-annotations\2.7.3\hadoop-annotations-2.7.3.jar
  D:\Java\jdk1.8.0_111\lib\tools.jar
  D:\apache-maven-3.5.0\repository\com\google\inject\extensions\guice-servlet\3.0\guice-servlet-3.0.jar
  D:\apache-maven-3.5.0\repository\commons-io\commons-io\2.4\commons-io-2.4.jar
  D:\apache-maven-3.5.0\repository\com\google\inject\guice\3.0\guice-3.0.jar
  D:\apache-maven-3.5.0\repository\javax\inject\javax.inject\1\javax.inject-1.jar
  D:\apache-maven-3.5.0\repository\aopalliance\aopalliance\1.0\aopalliance-1.0.jar
  D:\apache-maven-3.5.0\repository\com\sun\jersey\jersey-server\1.9\jersey-server-1.9.jar
  D:\apache-maven-3.5.0\repository\com\sun\jersey\jersey-json\1.9\jersey-json-1.9.jar
  D:\apache-maven-3.5.0\repository\org\codehaus\jettison\jettison\1.1\jettison-1.1.jar
  D:\apache-maven-3.5.0\repository\com\sun\xml\bind\jaxb-impl\2.2.3-1\jaxb-impl-2.2.3-1.jar
  D:\apache-maven-3.5.0\repository\com\sun\jersey\contribs\jersey-guice\1.9\jersey-guice-1.9.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-yarn-api\2.7.3\hadoop-yarn-api-2.7.3.jar
  D:\apache-maven-3.5.0\repository\com\google\guava\guava\14.0.1\guava-14.0.1.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-tags_2.11\2.0.2.3\snappy-spark-tags_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-yarn-client\2.7.3\hadoop-yarn-client-2.7.3.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-servlets\9.2.16.v20160414\jetty-servlets-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\apache\thrift\libthrift\0.9.3\libthrift-0.9.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\httpcomponents\httpcore\4.4.1\httpcore-4.4.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\derby\derby\10.12.1.1\derby-10.12.1.1.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-util\9.2.16.v20160414\jetty-util-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\spark-project\hive\hive-exec\1.2.1.spark2\hive-exec-1.2.1.spark2.jar
  D:\apache-maven-3.5.0\repository\javolution\javolution\5.5.1\javolution-5.5.1.jar
  D:\apache-maven-3.5.0\repository\log4j\apache-log4j-extras\1.2.17\apache-log4j-extras-1.2.17.jar
  D:\apache-maven-3.5.0\repository\org\antlr\ST4\4.0.4\ST4-4.0.4.jar
  D:\apache-maven-3.5.0\repository\com\googlecode\javaewah\JavaEWAH\0.3.2\JavaEWAH-0.3.2.jar
  D:\apache-maven-3.5.0\repository\org\iq80\snappy\snappy\0.2\snappy-0.2.jar
  D:\apache-maven-3.5.0\repository\org\json\json\20090211\json-20090211.jar
  D:\apache-maven-3.5.0\repository\stax\stax-api\1.0.1\stax-api-1.0.1.jar
  D:\apache-maven-3.5.0\repository\net\sf\opencsv\opencsv\2.3\opencsv-2.3.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappydata-core_2.11\0.8\snappydata-core_2.11-0.8.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappydata-store-core\1.5.4\snappydata-store-core-1.5.4.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\gemfire-core\1.5.4\gemfire-core-1.5.4.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\gemfire-joptsimple\1.5.4\gemfire-joptsimple-1.5.4.jar
  D:\apache-maven-3.5.0\repository\javax\resource\javax.resource-api\1.7\javax.resource-api-1.7.jar
  D:\apache-maven-3.5.0\repository\mx4j\mx4j-tools\3.0.1\mx4j-tools-3.0.1.jar
  D:\apache-maven-3.5.0\repository\javax\transaction\javax.transaction-api\1.2\javax.transaction-api-1.2.jar
  D:\apache-maven-3.5.0\repository\org\apache\hbase\hbase-server\0.98.17-hadoop2\hbase-server-0.98.17-hadoop2.jar
  D:\apache-maven-3.5.0\repository\org\apache\hbase\hbase-prefix-tree\0.98.17-hadoop2\hbase-prefix-tree-0.98.17-hadoop2.jar
  D:\apache-maven-3.5.0\repository\org\apache\hbase\hbase-common\0.98.17-hadoop2\hbase-common-0.98.17-hadoop2-tests.jar
  D:\apache-maven-3.5.0\repository\org\apache\hbase\hbase-hadoop-compat\0.98.17-hadoop2\hbase-hadoop-compat-0.98.17-hadoop2.jar
  D:\apache-maven-3.5.0\repository\org\apache\hbase\hbase-hadoop2-compat\0.98.17-hadoop2\hbase-hadoop2-compat-0.98.17-hadoop2.jar
  D:\apache-maven-3.5.0\repository\com\github\stephenc\high-scale-lib\high-scale-lib\1.1.1\high-scale-lib-1.1.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\commons\commons-math\2.1\commons-math-2.1.jar
  D:\apache-maven-3.5.0\repository\org\mortbay\jetty\jetty-sslengine\6.1.26\jetty-sslengine-6.1.26.jar
  D:\apache-maven-3.5.0\repository\org\mortbay\jetty\jsp-2.1\6.1.14\jsp-2.1-6.1.14.jar
  D:\apache-maven-3.5.0\repository\org\mortbay\jetty\jsp-api-2.1\6.1.14\jsp-api-2.1-6.1.14.jar
  D:\apache-maven-3.5.0\repository\org\mortbay\jetty\servlet-api-2.5\6.1.14\servlet-api-2.5-6.1.14.jar
  D:\apache-maven-3.5.0\repository\tomcat\jasper-compiler\5.5.23\jasper-compiler-5.5.23.jar
  D:\apache-maven-3.5.0\repository\tomcat\jasper-runtime\5.5.23\jasper-runtime-5.5.23.jar
  D:\apache-maven-3.5.0\repository\commons-el\commons-el\1.0\commons-el-1.0.jar
  D:\apache-maven-3.5.0\repository\org\jamon\jamon-runtime\2.4.1\jamon-runtime-2.4.1.jar
  D:\apache-maven-3.5.0\repository\com\github\stephenc\findbugs\findbugs-annotations\1.3.9-1\findbugs-annotations-1.3.9-1.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\gemfire-shared\1.5.4\gemfire-shared-1.5.4.jar
  D:\apache-maven-3.5.0\repository\net\java\dev\jna\jna\4.2.2\jna-4.2.2.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\gemfire-trove\1.5.4\gemfire-trove-1.5.4.jar
  D:\apache-maven-3.5.0\repository\com\io7m\xom\xom\1.2.10\xom-1.2.10.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\gemfire-jgroups\1.5.4\gemfire-jgroups-1.5.4.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\gemfire-json\1.5.4\gemfire-json-1.5.4.jar
  D:\apache-maven-3.5.0\repository\commons-modeler\commons-modeler\2.0.1\commons-modeler-2.0.1.jar
  D:\apache-maven-3.5.0\repository\commons-digester\commons-digester\1.4.1\commons-digester-1.4.1.jar
  D:\apache-maven-3.5.0\repository\commons-logging\commons-logging-api\1.0.4\commons-logging-api-1.0.4.jar
  D:\apache-maven-3.5.0\repository\javax\ws\rs\jsr311-api\1.1.1\jsr311-api-1.1.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\hbase\hbase-common\0.98.17-hadoop2\hbase-common-0.98.17-hadoop2.jar
  D:\apache-maven-3.5.0\repository\org\apache\hbase\hbase-client\0.98.17-hadoop2\hbase-client-0.98.17-hadoop2.jar
  D:\apache-maven-3.5.0\repository\org\jruby\jcodings\jcodings\1.0.8\jcodings-1.0.8.jar
  D:\apache-maven-3.5.0\repository\org\jruby\joni\joni\2.1.2\joni-2.1.2.jar
  D:\apache-maven-3.5.0\repository\org\cloudera\htrace\htrace-core\2.05\htrace-core-2.05.jar
  D:\apache-maven-3.5.0\repository\org\apache\htrace\htrace-core\3.2.0-incubating\htrace-core-3.2.0-incubating.jar
  D:\apache-maven-3.5.0\repository\mx4j\mx4j-remote\3.0.2\mx4j-remote-3.0.2.jar
  D:\apache-maven-3.5.0\repository\xml-apis\xml-apis\1.0.b2\xml-apis-1.0.b2.jar
  D:\apache-maven-3.5.0\repository\org\apache\hbase\hbase-protocol\0.98.17-hadoop2\hbase-protocol-0.98.17-hadoop2.jar
  D:\apache-maven-3.5.0\repository\org\apache\hbase\hbase-annotations\0.98.17-hadoop2\hbase-annotations-0.98.17-hadoop2.jar
  D:\apache-maven-3.5.0\repository\javax\mail\javax.mail-api\1.5.5\javax.mail-api-1.5.5.jar
  D:\apache-maven-3.5.0\repository\org\osgi\org.osgi.core\6.0.0\org.osgi.core-6.0.0.jar
  D:\apache-maven-3.5.0\repository\org\apache\ant\ant\1.9.7\ant-1.9.7.jar
  D:\apache-maven-3.5.0\repository\org\apache\ant\ant-launcher\1.9.7\ant-launcher-1.9.7.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappydata-store-shared\1.5.4\snappydata-store-shared-1.5.4.jar
  D:\apache-maven-3.5.0\repository\com\esotericsoftware\kryo-shaded\4.0.0\kryo-shaded-4.0.0.jar
  D:\apache-maven-3.5.0\repository\com\esotericsoftware\minlog\1.3.0\minlog-1.3.0.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappydata-store-client\1.5.4\snappydata-store-client-1.5.4.jar
  D:\apache-maven-3.5.0\repository\org\parboiled\parboiled_2.11\2.1.3\parboiled_2.11-2.1.3.jar
  D:\apache-maven-3.5.0\repository\com\chuusai\shapeless_2.11\2.3.0\shapeless_2.11-2.3.0.jar
  D:\apache-maven-3.5.0\repository\org\typelevel\macro-compat_2.11\1.1.1\macro-compat_2.11-1.1.1.jar
  D:\apache-maven-3.5.0\repository\org\objenesis\objenesis\2.4\objenesis-2.4.jar
  D:\apache-maven-3.5.0\repository\com\zaxxer\HikariCP\2.6.0\HikariCP-2.6.0.jar
  D:\apache-maven-3.5.0\repository\org\codehaus\janino\janino\3.0.6\janino-3.0.6.jar
  D:\apache-maven-3.5.0\repository\org\codehaus\janino\commons-compiler\3.0.6\commons-compiler-3.0.6.jar
  D:\apache-maven-3.5.0\repository\org\twitter4j\twitter4j-stream\4.0.4\twitter4j-stream-4.0.4.jar
  D:\apache-maven-3.5.0\repository\org\twitter4j\twitter4j-core\4.0.4\twitter4j-core-4.0.4.jar
  D:\apache-maven-3.5.0\repository\org\apache\tomcat\tomcat-jdbc\8.5.9\tomcat-jdbc-8.5.9.jar
  D:\apache-maven-3.5.0\repository\org\apache\tomcat\tomcat-juli\8.5.9\tomcat-juli-8.5.9.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-streaming-kafka-0.8_2.11\2.0.2.3\snappy-spark-streaming-kafka-0.8_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\kafka\kafka_2.11\0.8.2.1\kafka_2.11-0.8.2.1.jar
  D:\apache-maven-3.5.0\repository\com\101tec\zkclient\0.3\zkclient-0.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\kafka\kafka-clients\0.8.2.1\kafka-clients-0.8.2.1.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-graphx_2.11\2.0.2.3\snappy-spark-graphx_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\com\github\fommil\netlib\core\1.1.2\core-1.1.2.jar
  D:\apache-maven-3.5.0\repository\net\sourceforge\f2j\arpack_combined_all\0.1\arpack_combined_all-0.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\xbean\xbean-asm5-shaded\4.4\xbean-asm5-shaded-4.4.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-hive-thriftserver_2.11\2.0.2.3\snappy-spark-hive-thriftserver_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\spark-project\hive\hive-beeline\1.2.1.spark2\hive-beeline-1.2.1.spark2.jar
  D:\apache-maven-3.5.0\repository\net\sf\supercsv\super-csv\2.2.0\super-csv-2.2.0.jar
  D:\apache-maven-3.5.0\repository\net\sf\jpam\jpam\1.1\jpam-1.1.jar
  D:\apache-maven-3.5.0\repository\org\spark-project\hive\hive-cli\1.2.1.spark2\hive-cli-1.2.1.spark2.jar
  D:\apache-maven-3.5.0\repository\org\spark-project\hive\hive-jdbc\1.2.1.spark2\hive-jdbc-1.2.1.spark2.jar
  D:\apache-maven-3.5.0\repository\org\scala-lang\scala-compiler\2.11.8\scala-compiler-2.11.8.jar
  D:\apache-maven-3.5.0\repository\org\scala-lang\modules\scala-parser-combinators_2.11\1.0.4\scala-parser-combinators_2.11-1.0.4.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-hive_2.11\2.0.2.3\snappy-spark-hive_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\calcite\calcite-avatica\1.2.0-incubating\calcite-avatica-1.2.0-incubating.jar
  D:\apache-maven-3.5.0\repository\org\jodd\jodd-core\3.5.2\jodd-core-3.5.2.jar
  D:\apache-maven-3.5.0\repository\org\apache\avro\avro-mapred\1.7.7\avro-mapred-1.7.7-hadoop2.jar
  D:\apache-maven-3.5.0\repository\org\codehaus\jackson\jackson-mapper-asl\1.9.13\jackson-mapper-asl-1.9.13.jar
  D:\apache-maven-3.5.0\repository\org\apache\avro\avro\1.7.7\avro-1.7.7.jar
  D:\apache-maven-3.5.0\repository\com\thoughtworks\paranamer\paranamer\2.3\paranamer-2.3.jar
  D:\apache-maven-3.5.0\repository\com\twitter\parquet-hadoop-bundle\1.6.0\parquet-hadoop-bundle-1.6.0.jar
  D:\apache-maven-3.5.0\repository\org\apache\avro\avro-ipc\1.7.7\avro-ipc-1.7.7.jar
  D:\apache-maven-3.5.0\repository\commons-httpclient\commons-httpclient\3.1\commons-httpclient-3.1.jar
  D:\apache-maven-3.5.0\repository\commons-codec\commons-codec\1.10\commons-codec-1.10.jar
  D:\apache-maven-3.5.0\repository\org\datanucleus\datanucleus-core\3.2.10\datanucleus-core-3.2.10.jar
  D:\apache-maven-3.5.0\repository\org\apache\httpcomponents\httpclient\4.5.2\httpclient-4.5.2.jar
  D:\apache-maven-3.5.0\repository\joda-time\joda-time\2.9.4\joda-time-2.9.4.jar
  D:\apache-maven-3.5.0\repository\com\google\code\findbugs\jsr305\3.0.1\jsr305-3.0.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\calcite\calcite-core\1.2.0-incubating\calcite-core-1.2.0-incubating.jar
  D:\apache-maven-3.5.0\repository\org\apache\calcite\calcite-linq4j\1.2.0-incubating\calcite-linq4j-1.2.0-incubating.jar
  D:\apache-maven-3.5.0\repository\net\hydromatic\eigenbase-properties\1.1.5\eigenbase-properties-1.1.5.jar
  D:\apache-maven-3.5.0\repository\org\slf4j\jul-to-slf4j\1.7.21\jul-to-slf4j-1.7.21.jar
  D:\apache-maven-3.5.0\repository\log4j\log4j\1.2.17\log4j-1.2.17.jar
  D:\apache-maven-3.5.0\repository\org\slf4j\jcl-over-slf4j\1.7.21\jcl-over-slf4j-1.7.21.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-sql_2.11\2.0.2.3\snappy-spark-sql_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\parquet\parquet-hadoop\1.7.0\parquet-hadoop-1.7.0.jar
  D:\apache-maven-3.5.0\repository\org\apache\parquet\parquet-format\2.3.0-incubating\parquet-format-2.3.0-incubating.jar
  D:\apache-maven-3.5.0\repository\org\apache\parquet\parquet-jackson\1.7.0\parquet-jackson-1.7.0.jar
  D:\apache-maven-3.5.0\repository\com\univocity\univocity-parsers\2.1.1\univocity-parsers-2.1.1.jar
  D:\apache-maven-3.5.0\repository\com\fasterxml\jackson\core\jackson-databind\2.6.5\jackson-databind-2.6.5.jar
  D:\apache-maven-3.5.0\repository\com\fasterxml\jackson\core\jackson-annotations\2.6.0\jackson-annotations-2.6.0.jar
  D:\apache-maven-3.5.0\repository\com\fasterxml\jackson\core\jackson-core\2.6.5\jackson-core-2.6.5.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-sketch_2.11\2.0.2.3\snappy-spark-sketch_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\parquet\parquet-column\1.7.0\parquet-column-1.7.0.jar
  D:\apache-maven-3.5.0\repository\org\apache\parquet\parquet-common\1.7.0\parquet-common-1.7.0.jar
  D:\apache-maven-3.5.0\repository\org\apache\parquet\parquet-encoding\1.7.0\parquet-encoding-1.7.0.jar
  D:\apache-maven-3.5.0\repository\org\apache\parquet\parquet-generator\1.7.0\parquet-generator-1.7.0.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-mllib_2.11\2.0.2.3\snappy-spark-mllib_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\commons\commons-math3\3.4.1\commons-math3-3.4.1.jar
  D:\apache-maven-3.5.0\repository\org\scalanlp\breeze_2.11\0.11.2\breeze_2.11-0.11.2.jar
  D:\apache-maven-3.5.0\repository\org\scalanlp\breeze-macros_2.11\0.11.2\breeze-macros_2.11-0.11.2.jar
  D:\apache-maven-3.5.0\repository\com\github\rwl\jtransforms\2.4.0\jtransforms-2.4.0.jar
  D:\apache-maven-3.5.0\repository\org\spire-math\spire_2.11\0.7.4\spire_2.11-0.7.4.jar
  D:\apache-maven-3.5.0\repository\org\spire-math\spire-macros_2.11\0.7.4\spire-macros_2.11-0.7.4.jar
  D:\apache-maven-3.5.0\repository\org\jpmml\pmml-model\1.2.15\pmml-model-1.2.15.jar
  D:\apache-maven-3.5.0\repository\org\jpmml\pmml-schema\1.2.15\pmml-schema-1.2.15.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-repl_2.11\2.0.2.3\snappy-spark-repl_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\jline\jline\2.14.2\jline-2.14.2.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\spark-jobserver_2.11\0.6.2.3\spark-jobserver_2.11-0.6.2.3.jar
  D:\apache-maven-3.5.0\repository\io\spray\spray-can_2.11\1.3.3\spray-can_2.11-1.3.3.jar
  D:\apache-maven-3.5.0\repository\io\spray\spray-io_2.11\1.3.3\spray-io_2.11-1.3.3.jar
  D:\apache-maven-3.5.0\repository\io\spray\spray-http_2.11\1.3.3\spray-http_2.11-1.3.3.jar
  D:\apache-maven-3.5.0\repository\org\parboiled\parboiled-scala_2.11\1.1.7\parboiled-scala_2.11-1.1.7.jar
  D:\apache-maven-3.5.0\repository\org\parboiled\parboiled-core\1.1.7\parboiled-core-1.1.7.jar
  D:\apache-maven-3.5.0\repository\io\spray\spray-util_2.11\1.3.3\spray-util_2.11-1.3.3.jar
  D:\apache-maven-3.5.0\repository\com\yammer\metrics\metrics-core\2.2.0\metrics-core-2.2.0.jar
  D:\apache-maven-3.5.0\repository\io\spray\spray-json_2.11\1.3.2\spray-json_2.11-1.3.2.jar
  D:\apache-maven-3.5.0\repository\com\typesafe\config\1.3.0\config-1.3.0.jar
  D:\apache-maven-3.5.0\repository\io\spray\spray-caching_2.11\1.3.3\spray-caching_2.11-1.3.3.jar
  D:\apache-maven-3.5.0\repository\com\googlecode\concurrentlinkedhashmap\concurrentlinkedhashmap-lru\1.4.2\concurrentlinkedhashmap-lru-1.4.2.jar
  D:\apache-maven-3.5.0\repository\commons-pool\commons-pool\1.6\commons-pool-1.6.jar
  D:\apache-maven-3.5.0\repository\io\spray\spray-client_2.11\1.3.3\spray-client_2.11-1.3.3.jar
  D:\apache-maven-3.5.0\repository\io\spray\spray-httpx_2.11\1.3.3\spray-httpx_2.11-1.3.3.jar
  D:\apache-maven-3.5.0\repository\org\jvnet\mimepull\mimepull\1.9.5\mimepull-1.9.5.jar
  D:\apache-maven-3.5.0\repository\com\h2database\h2\1.3.176\h2-1.3.176.jar
  D:\apache-maven-3.5.0\repository\org\joda\joda-convert\1.8.1\joda-convert-1.8.1.jar
  D:\apache-maven-3.5.0\repository\org\flywaydb\flyway-core\3.2.1\flyway-core-3.2.1.jar
  D:\apache-maven-3.5.0\repository\com\typesafe\akka\akka-cluster_2.11\2.3.15\akka-cluster_2.11-2.3.15.jar
  D:\apache-maven-3.5.0\repository\com\typesafe\akka\akka-remote_2.11\2.3.15\akka-remote_2.11-2.3.15.jar
  D:\apache-maven-3.5.0\repository\org\uncommons\maths\uncommons-maths\1.2.2a\uncommons-maths-1.2.2a.jar
  D:\apache-maven-3.5.0\repository\com\typesafe\slick\slick_2.11\2.1.0\slick_2.11-2.1.0.jar
  D:\apache-maven-3.5.0\repository\commons-dbcp\commons-dbcp\1.4\commons-dbcp-1.4.jar
  D:\apache-maven-3.5.0\repository\com\typesafe\akka\akka-slf4j_2.11\2.3.15\akka-slf4j_2.11-2.3.15.jar
  D:\apache-maven-3.5.0\repository\com\typesafe\akka\akka-actor_2.11\2.3.15\akka-actor_2.11-2.3.15.jar
  D:\apache-maven-3.5.0\repository\io\spray\spray-routing-shapeless2_2.11\1.3.3\spray-routing-shapeless2_2.11-1.3.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\shiro\shiro-core\1.2.6\shiro-core-1.2.6.jar
  D:\apache-maven-3.5.0\repository\commons-beanutils\commons-beanutils\1.8.3\commons-beanutils-1.8.3.jar
  D:\apache-maven-3.5.0\repository\org\slf4j\slf4j-api\1.7.21\slf4j-api-1.7.21.jar
  D:\apache-maven-3.5.0\repository\org\scala-lang\scala-reflect\2.11.8\scala-reflect-2.11.8.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-streaming_2.11\2.0.2.3\snappy-spark-streaming_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\slf4j\slf4j-log4j12\1.7.21\slf4j-log4j12-1.7.21.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-core_2.11\2.0.2.3\snappy-spark-core_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\io\dropwizard\metrics\metrics-core\3.1.2\metrics-core-3.1.2.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\jersey\containers\jersey-container-servlet-core\2.22.2\jersey-container-servlet-core-2.22.2.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\hk2\external\javax.inject\2.4.0-b34\javax.inject-2.4.0-b34.jar
  D:\apache-maven-3.5.0\repository\javax\ws\rs\javax.ws.rs-api\2.0.1\javax.ws.rs-api-2.0.1.jar
  D:\apache-maven-3.5.0\repository\com\twitter\chill_2.11\0.8.1\chill_2.11-0.8.1.jar
  D:\apache-maven-3.5.0\repository\commons-net\commons-net\2.2\commons-net-2.2.jar
  D:\apache-maven-3.5.0\repository\net\java\dev\jets3t\jets3t\0.9.3\jets3t-0.9.3.jar
  D:\apache-maven-3.5.0\repository\javax\activation\activation\1.1.1\activation-1.1.1.jar
  D:\apache-maven-3.5.0\repository\mx4j\mx4j\3.0.2\mx4j-3.0.2.jar
  D:\apache-maven-3.5.0\repository\javax\mail\mail\1.4.7\mail-1.4.7.jar
  D:\apache-maven-3.5.0\repository\org\bouncycastle\bcprov-jdk15on\1.51\bcprov-jdk15on-1.51.jar
  D:\apache-maven-3.5.0\repository\com\jamesmurty\utils\java-xmlbuilder\1.0\java-xmlbuilder-1.0.jar
  D:\apache-maven-3.5.0\repository\net\iharder\base64\2.3.8\base64-2.3.8.jar
  D:\apache-maven-3.5.0\repository\com\clearspring\analytics\stream\2.7.0\stream-2.7.0.jar
  D:\apache-maven-3.5.0\repository\org\apache\zookeeper\zookeeper\3.4.8\zookeeper-3.4.8.jar
  D:\apache-maven-3.5.0\repository\com\twitter\chill-java\0.8.1\chill-java-0.8.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\curator\curator-recipes\2.7.1\curator-recipes-2.7.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\curator\curator-framework\2.7.1\curator-framework-2.7.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\curator\curator-client\2.7.1\curator-client-2.7.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\mesos\mesos\0.21.1\mesos-0.21.1-shaded-protobuf.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\jersey\core\jersey-client\2.22.2\jersey-client-2.22.2.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\hk2\hk2-api\2.4.0-b34\hk2-api-2.4.0-b34.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\hk2\hk2-utils\2.4.0-b34\hk2-utils-2.4.0-b34.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\hk2\external\aopalliance-repackaged\2.4.0-b34\aopalliance-repackaged-2.4.0-b34.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\hk2\hk2-locator\2.4.0-b34\hk2-locator-2.4.0-b34.jar
  D:\apache-maven-3.5.0\repository\org\javassist\javassist\3.18.1-GA\javassist-3.18.1-GA.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-launcher_2.11\2.0.2.3\snappy-spark-launcher_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\jersey\containers\jersey-container-servlet\2.22.2\jersey-container-servlet-2.22.2.jar
  D:\apache-maven-3.5.0\repository\io\netty\netty-all\4.0.29.Final\netty-all-4.0.29.Final.jar
  D:\apache-maven-3.5.0\repository\org\scala-lang\scalap\2.11.8\scalap-2.11.8.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\jersey\core\jersey-server\2.22.2\jersey-server-2.22.2.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\jersey\media\jersey-media-jaxb\2.22.2\jersey-media-jaxb-2.22.2.jar
  D:\apache-maven-3.5.0\repository\javax\annotation\javax.annotation-api\1.2\javax.annotation-api-1.2.jar
  D:\apache-maven-3.5.0\repository\javax\validation\validation-api\1.1.0.Final\validation-api-1.1.0.Final.jar
  D:\apache-maven-3.5.0\repository\com\ning\compress-lzf\1.0.3\compress-lzf-1.0.3.jar
  D:\apache-maven-3.5.0\repository\net\jpountz\lz4\lz4\1.3.0\lz4-1.3.0.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\jersey\core\jersey-common\2.22.2\jersey-common-2.22.2.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\jersey\bundles\repackaged\jersey-guava\2.22.2\jersey-guava-2.22.2.jar
  D:\apache-maven-3.5.0\repository\org\glassfish\hk2\osgi-resource-locator\1.0.1\osgi-resource-locator-1.0.1.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-network-shuffle_2.11\2.0.2.3\snappy-spark-network-shuffle_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\fusesource\leveldbjni\leveldbjni-all\1.8\leveldbjni-all-1.8.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-continuation\9.2.16.v20160414\jetty-continuation-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\org\apache\commons\commons-lang3\3.3.2\commons-lang3-3.3.2.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-network-common_2.11\2.0.2.3\snappy-spark-network-common_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\xerial\snappy\snappy-java\1.1.2.6\snappy-java-1.1.2.6.jar
  D:\apache-maven-3.5.0\repository\io\netty\netty\3.8.0.Final\netty-3.8.0.Final.jar
  D:\apache-maven-3.5.0\repository\org\apache\ivy\ivy\2.4.0\ivy-2.4.0.jar
  D:\apache-maven-3.5.0\repository\oro\oro\2.0.8\oro-2.0.8.jar
  D:\apache-maven-3.5.0\repository\com\fasterxml\jackson\module\jackson-module-scala_2.11\2.6.5\jackson-module-scala_2.11-2.6.5.jar
  D:\apache-maven-3.5.0\repository\com\fasterxml\jackson\module\jackson-module-paranamer\2.6.5\jackson-module-paranamer-2.6.5.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-client\2.7.3\hadoop-client-2.7.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-common\2.7.3\hadoop-common-2.7.3.jar
  D:\apache-maven-3.5.0\repository\xmlenc\xmlenc\0.52\xmlenc-0.52.jar
  D:\apache-maven-3.5.0\repository\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar
  D:\apache-maven-3.5.0\repository\javax\servlet\jsp\jsp-api\2.1\jsp-api-2.1.jar
  D:\apache-maven-3.5.0\repository\commons-configuration\commons-configuration\1.6\commons-configuration-1.6.jar
  D:\apache-maven-3.5.0\repository\commons-beanutils\commons-beanutils-core\1.8.0\commons-beanutils-core-1.8.0.jar
  D:\apache-maven-3.5.0\repository\com\google\code\gson\gson\2.2.4\gson-2.2.4.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-auth\2.7.3\hadoop-auth-2.7.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\directory\server\apacheds-kerberos-codec\2.0.0-M15\apacheds-kerberos-codec-2.0.0-M15.jar
  D:\apache-maven-3.5.0\repository\org\apache\directory\server\apacheds-i18n\2.0.0-M15\apacheds-i18n-2.0.0-M15.jar
  D:\apache-maven-3.5.0\repository\org\apache\directory\api\api-asn1-api\1.0.0-M20\api-asn1-api-1.0.0-M20.jar
  D:\apache-maven-3.5.0\repository\org\apache\directory\api\api-util\1.0.0-M20\api-util-1.0.0-M20.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-hdfs\2.7.3\hadoop-hdfs-2.7.3.jar
  D:\apache-maven-3.5.0\repository\xerces\xercesImpl\2.9.1\xercesImpl-2.9.1.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-mapreduce-client-app\2.7.3\hadoop-mapreduce-client-app-2.7.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-mapreduce-client-common\2.7.3\hadoop-mapreduce-client-common-2.7.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-mapreduce-client-shuffle\2.7.3\hadoop-mapreduce-client-shuffle-2.7.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-mapreduce-client-core\2.7.3\hadoop-mapreduce-client-core-2.7.3.jar
  D:\apache-maven-3.5.0\repository\org\apache\hadoop\hadoop-mapreduce-client-jobclient\2.7.3\hadoop-mapreduce-client-jobclient-2.7.3.jar
  D:\apache-maven-3.5.0\repository\io\dropwizard\metrics\metrics-jvm\3.1.2\metrics-jvm-3.1.2.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-unsafe_2.11\2.0.2.3\snappy-spark-unsafe_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\net\razorvine\pyrolite\4.13\pyrolite-4.13.jar
  D:\apache-maven-3.5.0\repository\io\dropwizard\metrics\metrics-json\3.1.2\metrics-json-3.1.2.jar
  D:\apache-maven-3.5.0\repository\org\eclipse\jetty\jetty-security\9.2.16.v20160414\jetty-security-9.2.16.v20160414.jar
  D:\apache-maven-3.5.0\repository\io\dropwizard\metrics\metrics-graphite\3.1.2\metrics-graphite-3.1.2.jar
  D:\apache-maven-3.5.0\repository\org\roaringbitmap\RoaringBitmap\0.5.11\RoaringBitmap-0.5.11.jar
  D:\apache-maven-3.5.0\repository\javax\servlet\javax.servlet-api\3.1.0\javax.servlet-api-3.1.0.jar
  D:\apache-maven-3.5.0\repository\com\google\protobuf\protobuf-java\2.6.1\protobuf-java-2.6.1.jar
  D:\apache-maven-3.5.0\repository\org\json4s\json4s-jackson_2.11\3.2.11\json4s-jackson_2.11-3.2.11.jar
  D:\apache-maven-3.5.0\repository\org\json4s\json4s-core_2.11\3.2.11\json4s-core_2.11-3.2.11.jar
  D:\apache-maven-3.5.0\repository\org\json4s\json4s-ast_2.11\3.2.11\json4s-ast_2.11-3.2.11.jar
  D:\apache-maven-3.5.0\repository\net\sf\py4j\py4j\0.10.1\py4j-0.10.1.jar
  D:\apache-maven-3.5.0\repository\io\snappydata\snappy-spark-catalyst_2.11\2.0.2.3\snappy-spark-catalyst_2.11-2.0.2.3.jar
  D:\apache-maven-3.5.0\repository\org\antlr\antlr4-runtime\4.5.3\antlr4-runtime-4.5.3.jar
  D:\apache-maven-3.5.0\repository\junit\junit\4.11\junit-4.11.jar
  D:\apache-maven-3.5.0\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar
  D:\apache-maven-3.5.0\repository\org\specs2\specs2-core_2.11\2.4.16\specs2-core_2.11-2.4.16.jar
  D:\apache-maven-3.5.0\repository\org\specs2\specs2-matcher_2.11\2.4.16\specs2-matcher_2.11-2.4.16.jar
  D:\apache-maven-3.5.0\repository\org\specs2\specs2-common_2.11\2.4.16\specs2-common_2.11-2.4.16.jar
  D:\apache-maven-3.5.0\repository\org\scalaz\scalaz-core_2.11\7.1.0\scalaz-core_2.11-7.1.0.jar
  D:\apache-maven-3.5.0\repository\org\scalaz\scalaz-concurrent_2.11\7.1.0\scalaz-concurrent_2.11-7.1.0.jar
  D:\apache-maven-3.5.0\repository\org\scalaz\scalaz-effect_2.11\7.1.0\scalaz-effect_2.11-7.1.0.jar
  D:\apache-maven-3.5.0\repository\org\scalatest\scalatest_2.11\2.2.4\scalatest_2.11-2.2.4.jar
  D:\apache-maven-3.5.0\repository\org\scala-lang\modules\scala-xml_2.11\1.0.2\scala-xml_2.11-1.0.2.jar
Library Path:
  D:\Java\jdk1.8.0_111\bin
  C:\WINDOWS\Sun\Java\bin
  C:\WINDOWS\system32
  C:\WINDOWS
  D:/Java/jdk1.8.0_111/bin/../jre/bin/server
  D:/Java/jdk1.8.0_111/bin/../jre/bin
  D:/Java/jdk1.8.0_111/bin/../jre/lib/amd64
  C:\Windows\system32
  C:\Windows
  C:\Windows\System32\Wbem
  C:\Windows\System32\WindowsPowerShell\v1.0\
  C:\Program Files (x86)\NVIDIA Corporation\PhysX\Common
  D:\Java\jdk1.8.0_111\bin
  D:\TortoiseSVN\bin
  D:\apache-maven-3.5.0\bin
  D:\scala\scala-2.11.11\bin
  C:\WINDOWS\system32
  C:\WINDOWS
  C:\WINDOWS\System32\Wbem
  C:\WINDOWS\System32\WindowsPowerShell\v1.0\
  C:\Program Files\Intel\WiFi\bin\
  C:\Program Files\Common Files\Intel\WirelessCommon\
  C:\Program Files\Git\cmd
  %PYTHON_HOME%
  %SPARK_HOME%
  C:\Users\admin\AppData\Local\Microsoft\WindowsApps
  d:\Docker Toolbox
  D:\eclipse
  .
System Properties:
    awt.toolkit = sun.awt.windows.WToolkit
    file.encoding = UTF-8
    file.encoding.pkg = sun.io
    file.separator = \
    gemfire.log-file = gemfirexd-interface.log
    gemfirexd.log-file = gemfirexd-interface.log
    java.awt.graphicsenv = sun.awt.Win32GraphicsEnvironment
    java.awt.printerjob = sun.awt.windows.WPrinterJob
    java.class.version = 52.0
    java.endorsed.dirs = D:\Java\jdk1.8.0_111\jre\lib\endorsed
    java.ext.dirs = D:\Java\jdk1.8.0_111\jre\lib\ext;C:\WINDOWS\Sun\Java\lib\ext
    java.home = D:\Java\jdk1.8.0_111\jre
    java.io.tmpdir = C:\Users\admin\AppData\Local\Temp\
    java.runtime.name = Java(TM) SE Runtime Environment
    java.runtime.version = 1.8.0_111-b14
    java.specification.name = Java Platform API Specification
    java.specification.vendor = Oracle Corporation
    java.specification.version = 1.8
    java.vendor = Oracle Corporation
    java.vendor.url = http://java.oracle.com/
    java.vendor.url.bug = http://bugreport.sun.com/bugreport/
    java.version = 1.8.0_111
    java.vm.info = mixed mode
    java.vm.name = Java HotSpot(TM) 64-Bit Server VM
    java.vm.specification.name = Java Virtual Machine Specification
    java.vm.specification.vendor = Oracle Corporation
    java.vm.specification.version = 1.8
    java.vm.vendor = Oracle Corporation
    java.vm.version = 25.111-b14
    jna.loaded = true
    jnidispatch.path = C:\Users\admin\AppData\Local\Temp\jna-92668751\jna4367807911957740810.dll
    line.separator = 

    os.version = 10.0
    p2p.useSSL = false
    path.separator = ;
    sun.arch.data.model = 64
    sun.boot.class.path = D:\eclipse\plugins\org.scala-lang.scala-library_2.11.8.v20160304-115712-1706a37eb8.jar;D:\eclipse\plugins\org.scala-lang.scala-reflect_2.11.8.v20160304-115712-1706a37eb8.jar;D:\Java\jdk1.8.0_111\jre\lib\resources.jar;D:\Java\jdk1.8.0_111\jre\lib\rt.jar;D:\Java\jdk1.8.0_111\jre\lib\sunrsasign.jar;D:\Java\jdk1.8.0_111\jre\lib\jsse.jar;D:\Java\jdk1.8.0_111\jre\lib\jce.jar;D:\Java\jdk1.8.0_111\jre\lib\charsets.jar;D:\Java\jdk1.8.0_111\jre\lib\jfr.jar;D:\Java\jdk1.8.0_111\jre\classes
    sun.boot.library.path = D:\Java\jdk1.8.0_111\jre\bin
    sun.cpu.endian = little
    sun.cpu.isalist = amd64
    sun.desktop = windows
    sun.io.unicode.encoding = UnicodeLittle
    sun.java.command = Snappy.SparkSql.SmartConnectorExample
    sun.java.launcher = SUN_STANDARD
    sun.jnu.encoding = GBK
    sun.management.compiler = HotSpot 64-Bit Tiered Compilers
    sun.nio.ch.bugLevel = 
    sun.os.patch.level = 
    user.country = CN
    user.language = zh
    user.script = 
    user.timezone = Asia/Shanghai
    user.variant = 
---------------------------------------------------------------------------

17/06/14 09:35:27.032 CST main<tid=0x1> INFO snappystore: Startup Configuration:
 ### GemFire Properties defined with system property ###
log-file=gemfirexd-interface.log
### GemFire Properties defined with api ###
disable-auto-reconnect=true
locators=cloudera2[9998]
mcast-port=0
### GemFire Properties using default values ###
ack-severe-alert-threshold=0
ack-wait-threshold=15
archive-disk-space-limit=0
archive-file-size-limit=0
async-distribution-timeout=0
async-max-queue-size=8
async-queue-timeout=60000
bind-address=
cache-xml-file=cache.xml
conflate-events=server
conserve-sockets=true
delta-propagation=true
deploy-working-dir=.
disable-tcp=false
distributed-system-id=-1
durable-client-id=
durable-client-timeout=300
enable-network-partition-detection=false
enable-time-statistics=false
enforce-unique-host=false
groups=
jmx-manager=false
jmx-manager-access-file=
jmx-manager-bind-address=
jmx-manager-hostname-for-clients=
jmx-manager-http-port=7070
jmx-manager-password-file=
jmx-manager-port=1099
jmx-manager-ssl=false
jmx-manager-ssl-ciphers=any
jmx-manager-ssl-protocols=any
jmx-manager-ssl-require-authentication=true
jmx-manager-start=false
jmx-manager-update-rate=2000
lock-memory=false
log-disk-space-limit=0
log-file-size-limit=0
log-level=config
max-num-reconnect-tries=3
max-wait-time-reconnect=60000
mcast-address=239.192.81.1
mcast-flow-control=1048576, 0.25, 5000
mcast-recv-buffer-size=1048576
mcast-send-buffer-size=65535
mcast-ttl=32
member-timeout=5000
membership-port-range=1024-65535
memcached-port=0
memcached-protocol=ASCII
name=
off-heap-memory-size=
redundancy-zone=
remote-locators=
remove-unresponsive-client=false
roles=
security-=
security-client-accessor=
security-client-accessor-pp=
security-client-auth-init=
security-client-authenticator=
security-client-dhalgo=
security-log-file=
security-log-level=config
security-peer-auth-init=
security-peer-authenticator=
security-peer-verifymember-timeout=1000
server-bind-address=
socket-buffer-size=32768
socket-lease-time=60000
ssl-ciphers=any
ssl-enabled=false
ssl-protocols=any
ssl-require-authentication=true
start-locator=
statistic-archive-file=
statistic-sample-rate=1000
statistic-sampling-enabled=true
tcp-port=0
udp-fragment-size=60000
udp-recv-buffer-size=1048576
udp-send-buffer-size=65535
user-command-packages=

17/06/14 09:35:27.081 CST main<tid=0x1> INFO snappystore: GemFire P2P Listener started on  tcp:///192.168.16.47:31513
17/06/14 09:35:27.189 CST PingSender<tid=0x4e> INFO snappystore: locator cloudera2(null)<v0>:9998 member address is cloudera2(10539)<v0>:53956
17/06/14 09:35:27.190 CST main<tid=0x1> INFO snappystore: Attempting to join distributed system whose membership coordinator is cloudera2(10539)<v0>:53956 using membership ID LAPTOP-MO9756P2(79676):41212
17/06/14 09:35:27.360 CST UDP ucast receiver<tid=0x4a> WARN snappystore: The clock for this machine may be more than 5 minutes different than the negotiated cache time received from cloudera2(10539)<v0>:53956
17/06/14 09:35:27.362 CST UDP ucast receiver<tid=0x4a> INFO snappystore: The negotiated cache time from cloudera2(10539)<v0>:53956 is 2017/06/14 16:09:36.438 CST.  Delta from the system clock is 23,649,078 milliseconds.
17/06/14 09:35:27.378 CST main<tid=0x1> INFO snappystore: Membership: lead member is now cloudera2(10539)<v0>:53956
17/06/14 09:35:27.392 CST FD_SOCK Ping thread<tid=0x50> INFO snappystore: GemFire failure detection is now monitoring cloudera2(10539)<v0>:53956
17/06/14 09:35:27.393 CST UDP ucast receiver<tid=0x4a> WARN snappystore: New offset calculated is off more than 2,364,867 ms from earlier offset.
17/06/14 09:35:27.394 CST main<tid=0x1> INFO snappystore: Entered into membership with ID LAPTOP-MO9756P2(79676)<v3>:41212.
17/06/14 09:35:27.395 CST main<tid=0x1> INFO snappystore: Starting DistributionManager LAPTOP-MO9756P2(79676)<v3>:41212. 
17/06/14 09:35:27.395 CST main<tid=0x1> INFO snappystore: Initial (membershipManager) view =  [cloudera2(10539)<v0>:53956{lead}, cloudera1(130186)<v1>:64080, cloudera3(34244)<v2>:53194, LAPTOP-MO9756P2(79676)<v3>:41212]
17/06/14 09:35:27.395 CST main<tid=0x1> INFO snappystore: Admitting member <cloudera2(10539)<v0>:53956>. Now there are 1 non-admin member(s).
17/06/14 09:35:27.396 CST main<tid=0x1> INFO snappystore: Admitting member <cloudera1(130186)<v1>:64080>. Now there are 2 non-admin member(s).
17/06/14 09:35:27.396 CST main<tid=0x1> INFO snappystore: Admitting member <cloudera3(34244)<v2>:53194>. Now there are 3 non-admin member(s).
17/06/14 09:35:27.396 CST main<tid=0x1> INFO snappystore: Admitting member <LAPTOP-MO9756P2(79676)<v3>:41212>. Now there are 4 non-admin member(s).
17/06/14 09:35:27.747 CST UDP ucast receiver<tid=0x4a> INFO snappystore: Member cloudera3(34244)<v2>:53194 is not equivalent or in the same redundancy zone.
17/06/14 09:35:27.748 CST UDP ucast receiver<tid=0x4a> INFO snappystore: Member cloudera2(10539)<v0>:53956 is not equivalent or in the same redundancy zone.
17/06/14 09:35:27.748 CST main<tid=0x1> INFO snappystore: DistributionManager LAPTOP-MO9756P2(79676)<v3>:41212 started on cloudera2[9998]. There were 3 other DMs. others: [cloudera2(10539)<v0>:53956, cloudera1(130186)<v1>:64080, cloudera3(34244)<v2>:53194]  
17/06/14 09:35:27.749 CST UDP ucast receiver<tid=0x4a> INFO snappystore: Member cloudera1(130186)<v1>:64080 is not equivalent or in the same redundancy zone.
17/06/14 09:35:27.762 CST Thread-17 StatSampler<tid=0x53> INFO snappystore: Disabling statistic archival.
17/06/14 09:35:42.767 CST main<tid=0x1> WARN snappystore: 15 seconds have elapsed while waiting for replies: <UpdateAttributesProcessor$UpdateAttributesReplyProcessor@57435801 2 waiting for 3 replies from [cloudera2(10539)<v0>:53956, cloudera1(130186)<v1>:64080, cloudera3(34244)<v2>:53194]> on LAPTOP-MO9756P2(79676)<v3>:41212 whose current membership list is: [[cloudera1(130186)<v1>:64080, LAPTOP-MO9756P2(79676)<v3>:41212, cloudera3(34244)<v2>:53194, cloudera2(10539)<v0>:53956]]
dshirish commented 7 years ago

@diwenjing We have recently released 0.9 version of the product. You can download it from releases page: https://github.com/SnappyDataInc/snappydata/releases. (use 0.9 version for both cluster mode and connector program)

For Smart Connector mode, use new property "snappydata.connection" (or "spark.snappydata.connection" if using Apache Spark to connect to SnappyData) with value as "locatorHost:jdbcClientPort" (default client port is 1527). The old (spark.snappydata.store.locators) property will give error.

Since you are connecting from Windows you may have to set HADOOP_HOME and install winutils.exe (as mentioned on the link below) if you see errors- https://jaceklaskowski.gitbooks.io/mastering-apache-spark/content/spark-tips-and-tricks-running-spark-windows.html

sumwale commented 7 years ago

@diwenjing Did you get to try the suggestions by @dshirish above? Please try with latest 1.0 RC release (final 1.0 release will be out soon).