Tag: cassandra
com.datastax.driver.core.exceptions.InvalidQueryException：unconfigured table schema_keyspaces
我正在尝试使用cassandra配置spring数据。 但是当我的应用程序在tomcat中部署时，我得到了吼叫错误。 当我检查连接时，它可用于给定端口。 （127.0.0.1:9042）。 我有下面的堆栈跟踪和弹簧配置。 有没有人对这个错误有所了解？ 完整堆栈跟踪： 2015-12-06 17:46:25 ERROR web.context.ContextLoader:331 – Context initialization failed org.springframework.beans.factory.BeanCreationException: Error creating bean with name ‘cassandraSession’: Invocation of init method failed; nested exception is com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:9042 (com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table schema_keyspaces)) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1572) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:539) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:476) at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:303) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:299) […]
如何解决“在类路径中发现Netty的本地epoll传输，但epoll不可用。 使用NIO代替“警告？
我正在使用Cassandra，并且在启动期间，Netty使用堆栈跟踪打印警告： 在类路径中找到Netty的本地epoll传输，但epoll不可用。 改用NIO。“ 该应用程序正常工作，但有没有办法解决警告？ 这是完整的堆栈跟踪： 16:29:46 WARN com.datastax.driver.core.NettyUtil – Found Netty’s native epoll transport in the classpath, but epoll is not available. Using NIO instead. java.lang.UnsatisfiedLinkError: no netty-transport-native-epoll in java.library.path at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1867) at java.lang.Runtime.loadLibrary0(Runtime.java:870) at java.lang.System.loadLibrary(System.java:1122) at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:168) at io.netty.channel.epoll.Native.(Native.java:49) at io.netty.channel.epoll.Epoll.(Epoll.java:30) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at com.datastax.driver.core.NettyUtil.(NettyUtil.java:68) at com.datastax.driver.core.NettyOptions.eventLoopGroup(NettyOptions.java:101) at com.datastax.driver.core.Connection$Factory.(Connection.java:709) at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1386) […]
TaskSchedulerImpl：初始作业未接受任何资源;
这是我想要做的。 我创建了两个DataStax企业集群节点，在此基础上我创建了一个java程序来获取一个表的计数（Cassandra数据库表）。 这个程序是在eclipse中构建的，它实际上来自一个Windows框。 在从Windows运行此程序时，它在运行时失败并出现以下错误： 初始工作没有接受任何资源; 检查群集UI以确保已注册工作并具有足够的内存 已经在这些集群上成功编译和运行相同的代码而没有任何问题。 可能是什么原因导致错误？ 码： import org.apache.spark.SparkConf; import org.apache.spark.SparkContext; import org.apache.spark.api.java.JavaSparkContext; import org.apache.spark.sql.SchemaRDD; import org.apache.spark.sql.cassandra.CassandraSQLContext; import com.datastax.bdp.spark.DseSparkConfHelper; public class SparkProject { public static void main(String[] args) { SparkConf conf = DseSparkConfHelper.enrichSparkConf(new SparkConf()).setMaster(“spark://10.63.24.14X:7077”).setAppName(“DatastaxTests”).set(“spark.cassandra.connection.host”,”10.63.24.14x”).set(“spark.executor.memory”, “2048m”).set(“spark.driver.memory”, “1024m”).set(“spark.local.ip”,”10.63.24.14X”); JavaSparkContext sc = new JavaSparkContext(conf); CassandraSQLContext cassandraContext = new CassandraSQLContext(sc.sc()); SchemaRDD employees = cassandraContext.sql(“SELECT * FROM portware_ants.orders”); […]
Cassandra的IN关系对查询有害吗？
给出CQL中以下select的示例： SELECT * FROM tickets WHERE ID IN (1,2,3,4) 给定ID是一个分区键，使用IN关系比做多个查询更好还是没有区别？
java.lang.NoClassDefFoundError：org / apache / spark / Logging
我总是收到以下错误。有人可以帮我吗？ Exception in thread “main” java.lang.NoClassDefFoundError: org/apache/spark/Logging at java.lang.ClassLoader.defineClass1(Native Method) at java.lang.ClassLoader.defineClass(ClassLoader.java:763) at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) at java.net.URLClassLoader.defineClass(URLClassLoader.java:467) at java.net.URLClassLoader.access$100(URLClassLoader.java:73) at java.net.URLClassLoader$1.run(URLClassLoader.java:368) at java.net.URLClassLoader$1.run(URLClassLoader.java:362) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:361) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) at com.datastax.spark.connector.japi.DStreamJavaFunctions.(DStreamJavaFunctions.java:24) at com.datastax.spark.connector.japi.CassandraStreamingJavaUtil.javaFunctions(CassandraStreamingJavaUtil.java:55) at SparkStream.main(SparkStream.java:51) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147) Caused by: java.lang.ClassNotFoundException: org.apache.spark.Logging at […]
