0

casscon <- dbConnect(cassdrv, "jdbc:cassandra://localhost:9042/quantum_cassandra") 12:31:02.140 [main] 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] 调试 com.datastax.driver.core.Connection - Connection[localhost/127.0.0.1:9042-1, inFlight=0, closed=false] 传输已初始化并准备就绪 12:31:02.232 [main] 调试cddriver.core.ControlConnection - [控制连接] 刷新节点列表和令牌映射 12:31:02.315 [main] 调试 cddriver.core.ControlConnection - [控制连接] 刷新模式 12:31:02.322 [main] 调试 com.datastax。驱动程序核心。Connection - Connection[localhost/127.0.0.1:9042-1, inFlight=0, closed=true] 关闭连接 12:31:02.323 [New I/O worker #4] DEBUG com.datastax.driver.core.Connection - Not终止连接 [localhost/127.0.0.1:9042-1, inFlight=0, closed=true]:仍有待处理的请求 12:31:02.325 [新 I/O 工作人员 #4] 调试 com.datastax.driver.core。连接 - 未终止连接 [localhost/127.0.0.1:9042-1, inFlight=0, closed=true]:仍有待处理的请求 12:31:02.329 [main] DEBUG com.datastax.driver.core.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:com.datastax.driver.core.Responses$Error.asException(Responses.java:103) ~[cassandra-driver-core-2.1.6-SNAPSHOT.jar:na] 中未配置的表 schema_keyspaces 在 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] 在 com.datastax.driver.core.Connection$Dispatcher.messageReceived(Connection.java:734) ~[cassandra-driver-core-2.1.6-SNAPSHOT .jar:na] at org.jboss.netty.channel.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] 在 org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) ~[netty-3.9.0.Final.jar:na] 在 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] 在 org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) ~[netty-3.9.0.Final.jar:na] 在 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.channel.Channels.fireMessageReceived(Channels.java:296) jboss.netty.handler.codec.frame.FrameDecoder。展开AndFireMessageReceived(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] 在 org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559) ~[netty-3.9.0.Final.jar:na] 在 org.jboss。 netty.channel.Channels.fireMessageReceived(Channels.java:268) ~[netty-3.9.0.Final.jar:na] 在 org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255) ~[netty-3.9.0.Final.jar:na] 在 org.jboss.netty.channel.socket.nio.NioWorker。在 org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)~[netty-3.9 中读取(NioWorker.java:88)~[netty-3.9.0.Final.jar:na] .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] 调试 com.datastax.driver.core.Cluster - 关闭 12:31:02.352 [main] 调试 oaccql.jdbc.CassandraDriver - 最终连接属性:{user=, password=, portNumber=9042, databaseName=quantum_cassandra, serverName=localhost} 12:31:02.381 [main] 调试 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: 读取负帧大小(-2147483648)!

任何人都可以帮助解决这个问题。

4

1 回答 1

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")

希望这会奏效

于 2017-04-21T05:58:49.810 回答