2016-12-03 34 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") 

希望这会工作