Tag: cassandra

无法连接到Cassandra Docker容器

我有官方Cassandradocker容器运行,但我无法从示例控制台应用程序访问。 我使用的是使用Hyper-V的Docker for Windows 我使用以下命令创build容器: docker run –name dev-cassandra -d cassandra:latest 当我运行该应用程序时,会出现以下错误 An unhandled exception of type 'Cassandra.NoHostAvailableException' occurred in Cassandra.dll 示例代码 class Program { static void Main(string[] args) { var cluster = Cassandra.Cluster.Builder().AddContactPoint("172.17.0.2").Build(); var session = cluster.Connect("Excelsior"); var rs = session.Execute("SELECT * FROM sample_table"); //Iterate through the RowSet foreach (var row in rs) { […]

将本地CQL命令文件传递给Cassandra Docker容器

是否有可能将CQL命令的本地文件传递给Cassandra Docker容器? 使用docker exec失败,因为它找不到本地文件: me@meanwhileinhell:~$ ls -al -rw-r–r– 1 me me 1672 Sep 28 11:02 createTables.cql me@meanwhileinhell:~$ docker exec -i cassandra_1 cqlsh -f createTables.cql Can't open 'createTables.cql': [Errno 2] No such file or directory: 'createTables.cql' 我真的不想打开一个bash会话,并以这种方式运行脚本。

使用docker在AWS EC2上设置和缩放titan / cassandra

我刚刚开始使用这些技术,所以如果我的问题似乎是愚蠢的。 我想build立一个Cassandra集群,并通过AWS EC2上的Cassandra部署Titan。 为了做到这一点,我find了这个指南 ,但是设置它却有点痛苦,而且我对生产的扩展也不是很有信心。 我的问题是,是否可以使用docker在AWS Elastic Beanstalk上设置cassandra / titan / … ,并让Elastic Beanstalk负责缩放它? 如果不是,那么最简单的方法是什么? 谢谢

无法在Docker容器中安装Cassandra代理

我已经成功地在两个独立的机器上使用Docker容器build立了两个节点的Cassandra集群。 当我尝试使用OpCenterpipe理集群时,由于DataStax Agent未安装而失败。 通过OpCenter自动安装代理失败。 我在Cassandra Docker容器中打开了一个bash shell,并尝试手动安装代理,但也失败了。 看来,代理安装程序正在期待sudo的支持,这是不存在的容器。 所以,我想知道将代理安装到Docker容器中的“正确方法”是什么。 任何人这样做? 有什么想法吗?

在Java中通过spark连接到Cassandra时出现问题

我有服务器与docker,并创build3 Cassandra节点,2个工人火花节点和一个主火花节点。 现在我想通过Java应用程序连接到我的笔记本电脑的火花。 我的java代码是: public SparkTestPanel(String id, User user) { super(id); form = new Form("form"); form.setOutputMarkupId(true); this.add(form); SparkConf conf = new SparkConf(true); conf.setAppName("Spark Test"); conf.setMaster("spark://172.11.100.156:9050"); conf.set("spark.cassandra.connection.host", "cassandra-0"); conf.set("spark.cassandra.connection.port", "9042"); conf.set("spark.cassandra.auth.username", "cassandra"); conf.set("spark.cassandra.auth.password", "cassandra"); JavaSparkContext sc = null; try { sc = new JavaSparkContext(conf); CassandraTableScanJavaRDD<com.datastax.spark.connector.japi.CassandraRow> cassandraTable = javaFunctions(sc).cassandraTable("test", "test_table"); List<com.datastax.spark.connector.japi.CassandraRow> collect = cassandraTable.collect(); for(com.datastax.spark.connector.japi.CassandraRow cassandraRow : […]

Cassandra docker – 无法通过JMX连接

我很难通过JMX连接到docker集装箱内的Cassandra。 我在AWS中运行(这意味着我得到一个NAT的IP)。 以下是我尝试过的东西: 创build了jmxremote.password文件 添加了jmxremote.password文件来启用jmx连接。 我从中创build我的图像的Dockerfile: 从cassandra:最新 COPY ./jmxremote.password /etc/cassandra/jmxremote.password 运行chmod 400 /etc/cassandra/jmxremote.password COPY ./jmxremote.password /etc/java-8-openjdk/management/jmxremote.password 我使用上面的docker文件构build了图像 运行容器: docker运行-P -d -e“JVM_OPTS = -Djava.rmi.server.hostname = 10.0.1.12”-e“LOCAL_JMX = no”-e 这会引发以下exception: java.rmi.ConnectException: Connection refused to host: 10.0.1.12; nested exception is: java.net.ConnectException: Connection refused at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:619) at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:216) at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:202) at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:130) at javax.management.remote.rmi.RMIServerImpl_Stub.newClient(Unknown Source) at javax.management.remote.rmi.RMIConnector.getConnection(RMIConnector.java:2432) at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:308) […]

打开cassandra节点间encryption原因“无法与任何种子闲谈”exception

我正在尝试将cassandra(2.1)节点间encryption。 出于testing目的,我试图启动一个2节点集群。 我正在两个独立的ec2实例上运行Docker容器内的每个节点。 没有节点间encryption,一切都按预期工作。 我使用以下脚本(取自https://docs.jboss.org/author/display/RHQ/Cassandra+Node+To+Node+Encryption?_sscc=t )生成ssl密钥: for ((a=0; a < NUMBER_OF_NODES ; a++)) do node_id=node${a} echo -e "Start building certificates for ${node_id}" echo -e "==========================================" rm -vf ./${node_id}.keystore rm -vf ./${node_id}.cer #1 Generate key and store ${java_folder}/keytool -genkey -v -keyalg RSA -keysize 1024 -alias ${node_id} -keystore ${node_id}.keystore -storepass "${node_id}store" -dname 'CN=RHQ' -keypass "${node_id}store" -validity 3650 […]

Docker容器中的Hadoop更快/值得吗?

我有一个基于Hadoop的环境。 我在这个系统中使用了Flume , Hue和Cassandra 。 现在Docker有一个很大的炒作,所以想研究一下Docker在这种情况下的优缺点。 我认为它应该更便携,但可以使用Cloudera Manager进行设置,只需点击几下鼠标即可。 这可能是更快或为什么值得吗? 有什么好处? 也许应该只有多节点Cassandra集群dockerized?

Cassandra和lucene:Docker中的用户pipe理

我正在使用Docker镜像来运行带有lucene插件的cassandra: https : //hub.docker.com/r/cpelka/cassandra-lucene/ 我在Google容器引擎上运行此图片。 一切工作正常,用户pipe理除外。 当我用cassandra / cassandra用户login时,似乎没有权限。 我无法列出用户,也无法更改密码。 我可以很好地访问和编辑表格,但它似乎并不是一个超级用户。 我读的是我必须启用密码validation。 我添加了设置到我的cassandra.yaml,但我无法重新启动我的cassandra服务。 地狱,如果我运行服务卡桑德拉停,需要一段时间,停下来,然后我仍然可以远程连接到我的数据库。 我认为Docker镜像运行数据库的方式,我不明白我有一天cassandra的经验。 任何帮助表示赞赏。 感谢和美好的一天, 德赖斯

Cassandra,JNA,Docker和CAP_IPC_LOCK

我试图优化我的Cassandra(3.7+)Docker容器的性能。 我发现从2015年的一个演示文稿 (在幻灯片21),我应该授予CAP_IPC_LOCK并设置ulimit memlock。 经过一番挖掘,似乎有两个select基本上是为了防止系统交换JVM,现代版本的Cassandra似乎通过使用JNA来完成。 在我的Docker容器上设置–ulimit memlock=-1:-1产生这样的效果 INFO 12:42:33 JNA mlockall successful 在启动时打印,所以我假设我已经完成了设置和完成。 我仍然需要–cap-add=CAP_IPC_LOCK ,如果是的话,如何检测我是否正确设置?