2016-12-03 57 views
0

casscon <建立R中卡桑德拉連接 - 數據庫連接(cassdrv, 「JDBC:卡桑德拉://本地主機:9042/quantum_cassandra」) 12:31:02.140 [主要] DEBUG c.datastax.driver .jdbc.SessionHolder - 連接的最終屬性:{user =,password =,portNumber = 9042,databaseName = quantum_cassandra,serverName = localhost} 12:31:02.140 [main] DEBUG com.datastax.driver.core.Cluster - 啓動具有聯繫點的新羣集[localhost/127.0.0.1:9042] 12:31:02.230 [main] DEBUG com.datastax.driver.core.Connection - 連接[localhost/127.0.0.1:9042-1,inFlight = 0, closed = false]傳輸初始化並準備就緒 12:31:02.232 [main] DEBUG cddriver.core.ControlConnection - [Control connection] Refres hing節點列表和令牌圖 12:31:02.315 [main] DEBUG cddriver.core.ControlConnection - [Control connection]刷新模式 12:31:02.322 [main] DEBUG com.datastax.driver.core.Connection - Connection [localhost/127.0.0.1:9042-1,inFlight = 0,closed = true]關閉連接 12:31:02.323 [新I/O工作者#4] DEBUG com.datastax.driver.core.Connection - 不終止連接[localhost/127.0.0.1:9042-1,inFlight = 0,closed = true]:仍有未決請求 12:31:02.325 [新I/O工作者#4] DEBUG com.datastax.driver.core.Connection - 未終止連接[localhost/127.0.0.1:9042-1,inFlight = 0,closed = true]:仍有未決請求 12:31:02.329 [main] DEBUG com.datastax.driver.core.Connection - Connection [localhost/127.0.0.1:9042-1,inFlight = 0,closed = true]已經終止 12:31:02.331 [main] DEBUG cddriver.core.ControlConnection - [控制連接] localhost/127.0.0.1上的錯誤:9042連接,無法嘗試更多主機 com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table schema_keyspaces at com.datastax.driver.core.Responses $ Error.asException(Responses.java:103)〜[cassandra-driver-core-2.1.6-SNAPSHOT.jar:na] at com.datastax.driver .core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:140)〜[cassandra-driver-core-2.1.6-SNAPSHOT.jar:na] at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:158 )〜[cassandra-driver-core-2.1.6-SNAPSHOT.jar:na] at com.datastax.driver.core.Connection $ Dispatcher.messageReceived(Connection.java:734)〜[cassandra-driver-core-2.1 .6-SNAPSHOT.jar:na] at org.jboss.netty.ch annel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.handler.timeout.IdleStateAwareChannelUpstreamHandler.handleUpstream(IdleStateAwareChannelUpstreamHandler.java:36)〜[ netty-3.9.0.Final.jar:na] at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)〜[netty-3.9.0.Final.jar:na] at org。 jboss.netty.channel.DefaultChannelPipeline $ DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.handler.timeout.IdleStateHandler.messageReceived(IdleStateHandler。 java:294)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)〜[netty-3.9.0.Final.jar: na] at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.channel.DefaultChannelPipeline $ DefaultChannelHandlerContext.sendUpstream( DefaultChannelPipeline.java:791)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)〜[netty-3.9.0.Final。 jar:na] at org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:70)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty。 channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.channel.DefaultChannelPipeline $ DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)〜[ netty-3.9.0.Final。jar:na] at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.handler.codec。 frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443) 〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303)〜[netty-3.9.0.Final.jar: na] at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream( DefaultChannelPipeline.java:564)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.channe l.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)〜[netty- 3.9.0.Final.jar:na] at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)〜[netty-3.9.0.Final.jar:na] at org.jboss。在org.jboss.netty.channel.socket.nio.AbstractNioWorker.process()中, AbstractNioWorker.java:108)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)〜[netty-3.9。 0.Final.jar:na] at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.util.ThreadRenamingRunnable.run( ThreadRenamingRunnable.java:108)〜[netty-3.9.0.Final.jar:na] at org.jboss.netty.util.internal.DeadLockProofWorker $ 1.run(DeadLockProofWorker.java:42)〜[netty-3.9.0 .Final.jar:na] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)〜[na:1.8.0_111] at java.util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor.java :617)〜[na:1.8.0_111] at java.lang.Thread.run(Thread.java:745)〜[na:1.8.0_111] 12:31:02.337 [main] DEBUG com.datastax.driver .core.Cluster - 關閉 12:31:02.352 [main] DEBUG oaccql.jdbc.CassandraDriver - 連接的最終屬性:{user =,password =, portNumber = 9042,databaseName = quantum_cassandra,serverName = localhost} 12:31:02.381 [main] DEBUG oaccql.jdbc.CassandraDriver - 連接的最終屬性:{portNumber = 9042,databaseName = quantum_cassandra,serverName = localhost} .jcall(drv @ jdrv,「Ljava/sql/Connection;」,「connect」,as.character(url)[1],: java.sql.SQLNonTransientConnectionException:org.apache.thrift.transport.TTransportException:Read a負幀大小(-2147483648)!無法使用RJDBC

請問任何人都可以幫忙解決這個問題。

回答

0
library(RJDBC) 
drv <- JDBC("org.apache.cassandra.cql.jdbc.CassandraDriver",list.files("C:/Program Files/DataStax Community/apache-cassandra/lib",pattern="jar$",full.names=T)) 
conn <- dbConnect(drv, "jdbc:cassandra://localhost:9042/dbname") 
result <- dbGetQuery(conn, "select tablename from columnname") 

希望這會工作