无法与火花shell命令

Question

SnappyData V0.5连接到snappydata店

我的目标是开始从我的SnappyData一个“火花壳”安装的/ bin目录，并发出斯卡拉反对我SnappyData现有表的命令商店。

我和我的SnappyData商店，定位器和领导在同一主机上（并且是的，他们都在运行）。

要做到这一点，我在运行此命令按照这里的文档：

Connecting to a Cluster with spark-shell

〜/ snappydata /斌$火花壳--master本地[*] --conf snappydata。 store.locators = 10.0.18.66：1527 --conf spark.ui.port = 4041

我得到这个错误试图创建一个火花外壳到我的商店：

[TRACE 2016/08/12 15:21:55.183 UTC GFXD:error:FabricServiceAPI tid=0x1] XJ040 error occurred while starting server : java.sql.SQLException(XJ040): Failed to start datab
ase 'snappydata', see the cause for details. java.sql.SQLException(XJ040): Failed to start database 'snappydata', see the cause for details. at com.pivotal.gemfirexd.internal.impl.jdbc.SQLExceptionFactory40.getSQLException(SQLExceptionFactory40.java:124) at com.pivotal.gemfirexd.internal.impl.jdbc.Util.newEmbedSQLException(Util.java:110) at com.pivotal.gemfirexd.internal.impl.jdbc.Util.newEmbedSQLException(Util.java:136) at com.pivotal.gemfirexd.internal.impl.jdbc.Util.generateCsSQLException(Util.java:245) at com.pivotal.gemfirexd.internal.impl.jdbc.EmbedConnection.bootDatabase(EmbedConnection.java:3380) at com.pivotal.gemfirexd.internal.impl.jdbc.EmbedConnection.(EmbedConnection.java:450) at com.pivotal.gemfirexd.internal.impl.jdbc.EmbedConnection30.(EmbedConnection30.java:94) at com.pivotal.gemfirexd.internal.impl.jdbc.EmbedConnection40.(EmbedConnection40.java:75) at com.pivotal.gemfirexd.internal.jdbc.Driver40.getNewEmbedConnection(Driver40.java:95) at com.pivotal.gemfirexd.internal.jdbc.InternalDriver.connect(InternalDriver.java:351) at com.pivotal.gemfirexd.internal.jdbc.InternalDriver.connect(InternalDriver.java:219) at com.pivotal.gemfirexd.internal.jdbc.InternalDriver.connect(InternalDriver.java:195) at com.pivotal.gemfirexd.internal.jdbc.AutoloadedDriver.connect(AutoloadedDriver.java:141) at com.pivotal.gemfirexd.internal.engine.fabricservice.FabricServiceImpl.startImpl(FabricServiceImpl.java:290) at com.pivotal.gemfirexd.internal.engine.fabricservice.FabricServerImpl.start(FabricServerImpl.java:60) at io.snappydata.impl.ServerImpl.start(ServerImpl.scala:32)

Caused by: com.gemstone.gemfire.GemFireConfigException: Unable to contact a Locator service (timeout=5000ms). Operation either timed out or Locator does not exist. Configured list of locators is "[dev-snappydata-1(null):1527]". at com.gemstone.gemfire.distributed.internal.membership.jgroup.GFJGBasicAdapter.getGemFireConfigException(GFJGBasicAdapter.java:533) at com.gemstone.org.jgroups.protocols.TCPGOSSIP.sendGetMembersRequest(TCPGOSSIP.java:212) at com.gemstone.org.jgroups.protocols.PingSender.run(PingSender.java:82) at java.lang.Thread.run(Thread.java:745)

Answer 1

嗯！我假设你正在从桌面尝试Spark-shell并连接到AWS中的集群？ 不确定这是否会起作用，因为由spark-shell启动的本地JVM将试图连接到Snappydata中不太可能工作的p2p群集。

另一方面，Snappy-shell仅使用JDBC客户端进行连接（因此将工作）。

而且，无论如何您都不能使用定位器客户端端口（1527）。请参阅here

您可以使用snappydata.store.locators=10.0.18.66:10334不是1527作为端口吗？不太可能，这将工作，但值得一试。

也许有办法打开所有端口并访问AWS上的这些节点。不过，不建议用于生产。

我很好奇ENGG团队的其他答复。 在此之前，您可能必须从网络内部（AWS节点）启动spark-shell。