FAQ Database Discussion Community


New Datastax driver for Tableau is not working

cassandra,odbc,tableau,datastax
trying to run Tableau on top of DSE 4.7. It fails. I can't do something in worksheet or preview the data. Get this error: "Missing EOF at 'tablename_i_try_to_query' " What is the right way to fix it?...

DataStax Enterprise Amazon AMI

amazon-ec2,datastax-enterprise,datastax,ami
I'm trying to launch a new instance of DataStax AMI on a EC2 Amazon instance. I tried this in 2 different regions (us-east and eu-west), using these AMIs: ami-ada2b6c4, ami-814ec2e8 (us-east) and ami-7f33cd08, ami-b2212dc6 (eu-west) I followed this documentation: http://www.datastax.com/documentation/datastax_enterprise/4.6/datastax_enterprise/install/installAMI.html So this is what I've done so far: I've created...

Location of datastax opscenter dashboards

cassandra,datastax,opscenter
Just a simple question: where does datastax opscenter store it`s dashboards? Is it stored in the opscenter keyspace or as file on the filesystem? Could not find anything...

Dataxtax Agent error

cassandra,datastax,opscenter
While adding existing cluster in OpsCenter I receive an error: ERROR: Agent for XXX.XXX.XXX.XXX was unable to complete operation (http://XXX.XXX.XXX.XXX:61621/snapshots/pit/properties?): java.lang.IllegalArgumentException: No implementation of method: :make-reader of protocol: #'clojure.java.io/IOFactory found for class: nil On agent there is an error: java.lang.IllegalArgumentException: No implementation of method: :make-reader of protocol: #'clojure.java.io/IOFactory found for...

Can't able to start Cassandra Services

cassandra,datastax
I just downloaded tar ball and extracted it. Steps i have done is in this question path/dse/bin/cassandra-cli It says Connection refused at port 9160 netstat -plten returns no process on 9160. So cassandra service is not started. How to start it? DO i need to set any env variables or...

Can't install Previous version of Datastax DSE

datastax,datastax-enterprise
trying to: apt-get install 'dse-full=4.6.5-1' and getting: failed: [dsenode01] => {"failed": true} stderr: E: Unable to correct problems, you have held broken packages. stdout: Reading package lists... Building dependency tree... Reading state information... Some packages could not be installed. This may mean that you have requested an impossible situation or...

Cassandra deploy cluster failure

java,amazon-web-services,cassandra,datastax,nodetool
I am trying to deploy Cassandra cluster on AWS. I followed instructions on http://datastax.com/documentation/cassandra/2.1/cassandra/install/installAMI.html It looks everything is okay, but one node still getting 0 response. After initial script I ran cassandra-stress write command on rest two nodes and everything was okay. When I tried to run nodetool status command...

is the mapper class from com.datastax.driver.mapping threadsafe?

cassandra,datastax,datastax-java-driver
it would seem so since it receives a Session object(which is thread-safe), but i could find no "official" statement on the subject can anyone please confirm?...

What's wrong with this cassandra prepared statement call?

python,cassandra,datastax
I'm using the datastax cassandra driver for python. The portion of the code at issue is: cql = "SELECT * FROM iptools.geo2ip WHERE geo_key = ? AND (( geohash >= ? AND geohash < ? ) OR ( geohash >= ? AND geohash < ? ));" print cql prepared =...

Slicing over partition rows using tuple operation in CQL

cassandra,cql,datastax
I am trying to understand the behavior of tuple operator with clustering keys. Here is what I was trying to do: create table sampletable (a int,b int,c int, d int, e int, primary key((a,b,c),d,e)); insert into sampletable(a,b,c,d,e) values(1,1,1,1,1); insert into sampletable(a,b,c,d,e) values(1,1,1,1,1); insert into sampletable(a,b,c,d,e) values(1,1,1,1,2); insert into sampletable(a,b,c,d,e) values(1,1,2,1,1);...

Error during node startup: Unable to start DSE server / Plugin activation failed / Cannot find core

solr,cassandra,datastax-enterprise,datastax
I've been having these issues for quite a while already but I ignored them initially because I can still start my nodes. However, one of these issues became more serious recently that it now takes me a lot of tries in order to successfully start a node. Issue #1: Unable...

Upgrade of datastax-agent fails from opscenter

datastax-enterprise,datastax,opscenter
Running Datastax Enterprise 4.5.1 with OpsCenter 5.0.0 and attempting to upgrade OpsCenter and datastax-agents to OpsCenter version 5.1.0 This is a test cluster of 2 nodes in AWS. I downloaded OpsCenter 5.1.0 from the Datastax website and successfully upgraded the OpsCenter server in my test cluster. As expected, after connecting...

Cassandra single node installation

cassandra,datastax
I just try to install cassandra on my ubuntu:12.04. Steps i have followed Installed java version 1.7.XX and verified with java -version apt-get install libjna-java //Installs jna python 2.7 is installed already Extracted to /usr/local/installables/ Successfully extracted. Then I set cassandra home export CASSANDRA_HOME=/usr/local/installables/dse-2.2.2/resources/cassandra export PATH=$PATH:$CASSANDRA_HOME/bin pscenter.tar.gz dse.tar.gz I created...

Is it possible to have nodes from multiple datacenters join the same Spark cluster?

datastax,datastax-enterprise
I am running a Datastax Enterprise cluster (with GossipingPropertyFileSnitch). I have two datacenters, Analytics and Cassandra. Analytics nodes forms a Spark cluster. I am considering merging the two clusters to better utilize resources. When I enable Spark (in /etc/dse/default) on my Cassandra nodes I get a new master and it...

Load connecting tables from Cassandra in QlikView with DataSatx ODBC

cassandra,datastax,qlikview
I am new to both Cassandra (2.0) and QlikView (11). I have two keyspaces (tables) with large amount of data in Cassandra and I want to load them to QlikView. Since I can not load the entire set, filtering is necessary. // In QlikView's edit script ODBC CONNECT TO [DataStax...

What implications does consistency have on async writes?

cassandra,cassandra-2.0,datastax,datastax-java-driver
Both Datastax Python and Java Cassandra drivers supports async writes. Both of them also allows setting consistency level. Does the consistency level have any implication whatsoever for async writes?

Error while shutdown cassandra cluster from c# datastax driver

c#,cassandra,datastax-enterprise,datastax
I am using Datastax C# driver to connect to Cassandra node from my C# application. My code works fine and I am able to retrieve all data and process them. However, when I try to shutdown the cluster after fetching records, its giving me the above error. Below is...

to alter or create a new table in cassandra to add new columns

database-design,cassandra,datastax,datastax-enterprise
I am using DSE cassandra. I wanted to add new attributes to the existing table. I wanted to know what is the best practice to achieve this? Should i be adding new columns to existing table or creating new table? What are the pros and cons for either approach?...

How to get pass “requires authentication” while connecting to remote Cassandra cluster using SparkConf?

java,cassandra,apache-spark,datastax
I am trying to use apache spark and cassandra for the data analysis. So i wrote a java code to access the cassandra which is running on a remote machine. I used the following java code. public class JavaDemo implements Serializable { private transient SparkConf conf; private JavaDemo(SparkConf conf) {...

Solr Aggregation / Facet on DynamicField

solr,datastax-enterprise,datastax
Table schema: CREATE TABLE attributes_v1 ( profile_id bigint, attributes map<text, int>, solr_query text, PRIMARY KEY ((profile_id)) ) Data inside the table looks like this: profile_id | attributes ------------+--------------------------------------------- 2 | {'a101': 1, 'a11': 1, 'a12322': 1, 'a51': 3} 3 | {'a1': 1, 'a10': 1, 'a11': 3, 'a51': 1} 1 |...

how to query on cassandra table using custom index in select clause

solr,cassandra,cql,datastax
I have a custom index created by solr on cassandra table CREATE CUSTOM INDEX custom_index ON table_name (column) USING 'com.datastax.bdp.search.solr.Cql3SolrSecondaryIndex'; As far as i know, in the select clause of cassandra we can only have primary key in the where clause for select query. Can I use this custom index...

How do I run a repair only within a certain datacenter?

cassandra,cassandra-2.0,datastax,datastax-enterprise
I want to run a repair for specific Cassandra datacenter within a larger cluster. How can I do that nodetool repair -local -pr does not seem to work: $ nodetool repair -local -pr Exception in thread "main" java.lang.RuntimeException: Primary range repair should be performed on all nodes in the cluster....

Does Spark from DSE laod all data into RDD before running SQL Query?

cassandra,apache-spark,datastax
Running DSE 4.7 So say I have a 4 node DSE Cassandra/Spark cluster... I have a Cassandra table with say 4,000,000 records in it. On Spark running the following Spark SQL "select * from table where email = ? or mobile = ?" Will Spark load all the data into...

Importing long rows to Cassandra from Spark

cassandra,apache-spark,datastax
I've been trying to use the datastax spark-cassandra connector (https://github.com/datastax/spark-cassandra-connector) to import some data from csv files. I understand that most of the time case classes can be used on the import, but I'm dealing with rows with about 500 fields and so I can't use them without nesting (due...

Unable to create Solr Core, key type mismatch

solr,cassandra-2.0,datastax
Running DataStax Enterprise Server 4.6.0 with 6 node cluster, fresh, only 1 record inside this table: CREATE TABLE tweets.tweets (uid bigint, tweet_id bigint, tweet text,created timestamp,PRIMARY KEY (uid , created) ) WITH CLUSTERING ORDER BY (created DESC); schema.xml looks like this: <?xml version="1.0" encoding="UTF-8" ?> <schema name="tweets" version="1.1"> <types> <fieldType...

Cassandra - multiple counters based on timeframe

cassandra,datastax
I am building an application and using Cassandra as my datastore. In the app, I need to track event counts per user, per event source, and need to query the counts for different windows of time. For example, some possible queries could be: Get all events for user A for...

Out of memory error in Cassandra when querying big rows containing a collection (set)

java,cassandra,out-of-memory,datastax,cql3
I am using Cassandra 2.0.8 and I have got a cql3 table defined like this: CREATE TABLE search_scf_tdr ( fieldname text, fieldvalue text, scalability int, timestamptdr bigint, tdrkeys set<blob>, PRIMARY KEY ((fieldname, fieldvalue, scalability), timestamptdr) ) I use a replication factor of 2 per DC for this keyspace. I am...

Limiting columns per record in CQL

cassandra,cql,datastax
I've a problem which has been bothering me from quite while now. I'm scaling it down for simplification. I've a column family in Cassandra defined as: CREATE TABLE "Test" ( key text, column1 text, value text, PRIMARY KEY (key, column1) ) If I run a query in CQL as: select...

Cassandra compaction tasks stuck

cassandra,datastax-enterprise,datastax,opscenter
I'm running Datastax Enterprise in a cluster consisting of 3 nodes. They are all running under the same hardware: 2 Core Intel Xeon 2.2 Ghz, 7 GB RAM, 4 TB Raid-0 This should be enough for running a cluster with a light load, storing less than 1 GB of data....

Cassandra - can't remove the nodes

java,cassandra,datastax
I've accidently added new nodes to the test cluster. I removed the nodes afterwards but they still appear when connecting to the cluster. The nodetool gossipinfo doesn't show them. The nodetool ring doesn't either but when connecting via the datastax Java client they do appear: LOG4J 2015-05-06 15:44:54.796 INFO :...

Restoring cassandra from snapshot

cassandra,cassandra-2.0,datastax,datastax-enterprise
So I did something of a test run/disaster recovery practice deleting a table and restoring in Cassandra via snapshot on a test cluster I have built. This test cluster has four nodes, and I used the node restart method so after truncating the table in question, all nodes were shutdown,...

Cassandra: Selecting a Range of TimeUUIDs using the DataStax Java Driver

java,cassandra,datastax,datastax-java-driver
The use case that we are working to solve with Cassandra is this: We need to retrieve a list of entity UUIDs that have been updated within a certain time range within the last 90 days. Imagine that we're building a document tracking system, so our relevant entity is a...

Partition key column in Cassandra

cassandra,cql,datastax,datastax-enterprise,cql3
I want to understand exactly what will improve my performance if I decide to go with following strategy for partition Lets say I have a table for songs and I want to define artists as the partition key. This table is going to grow gradually. Today I have 25 artists...

Unbalanced Cassandra replicas storage

java,cassandra,datastax
In our setup we have 2 DCs, 21 Cassandra nodes in each DC, and a total of 4 replicas per record (in one of the keyspaces) - two replicas per site. Every Cassandra node is setup with 16 VNodes. We did not manually set the initial_token for each node in...

How to restart Cassandra EC2 instance?

amazon-web-services,amazon-ec2,cassandra,datastax,nodetool
I have Cassandra cluster on AWS. I have it only for testing purposes. Because of that I need to stop my instances and start them some other time. I deployed cluster with Datastax AMI and everything seems alright. I stoped instances in EC2 Management console and waited for 'stoped' state....

How do you add elements to a set with DataStax QueryBuilder?

scala,cql,datastax,cql3,datastax-java-driver
I have a table whose column types are text, bigint, set<text> I'm trying to update a single row and add an element to the set using QueryBuilder. The code that overwrites the existing set looks like this (note this is scala): val query = QueryBuilder.update("twitter", "tweets") .`with`(QueryBuilder.set("sinceid", update.sinceID)) .and(QueryBuilder.set("tweets", setAsJavaSet(update.tweets)))...

update cassandra field using string concatenation

cassandra,datastax,cqlsh
I am trying to update an existing string column in cassandra table. For example i want to append domain id in front of username. Following is my table id, username 1, agaikwad 2, xyz I want to write cql to update above table to reflect following id, username 1, homeoffice\\agaikwad...

How can I change which address Datastax agent will try to connect to?

datastax,datastax-enterprise
My Cassandra instances are not listening on 127.0.0.1. When I start datastax-agent I find this in logs: # tail -n 100 /var/log/datastax-agent/agent.log ... ERROR [Initialization] 2015-05-19 22:35:04,064 Can't connect to Cassandra, retrying soon. com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:9042 (com.datastax.driver.core.TransportException: [/127.0.0.1:9042] Cannot connect)) at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:220) at...

Datastax java-driver QueryBuilder.update issue in scala

scala,query-builder,datastax,datastax-java-driver
Here is the scala code I am attempting to use to update a row in a cassandra database: val query = QueryBuilder.update("twitter","tweets") .`with`(QueryBuilder.set("sinceid", update.sinceID) .and(QueryBuilder.set("tweets", update.tweets))) .where(QueryBuilder.eq("handle", update.handle)); which is based off of the suggestion here Everything seems to work correctly except for the ".and". The error I get back...

DSE 4.6 to DSE 4.7 Failed to find Spark assembly

apache-spark,datastax,datastax-enterprise,spark-jobserver
I have a problem with job-server-0.5.0 after upgraded DSE 4.6 to 4.7. If I run server_start.sh I'll get error "Failed to find Spark assembly in /usr/share/dse/spark/assembly/target/scala-2.10 You need to build Spark before running this program." I found in /usr/share/dse/spark/bin/compute-classpath.sh this code raises error for f in ${assembly_folder}/spark-assembly*hadoop*.jar; do if [[...

dse cassandra solr doesnt return _uniqueKey in response

solr,cassandra,datastax,datastax-enterprise
Im using Datastax 4.6. My solr client queries data by using _uniqueKey. From version 4.6 the limitation about using simple primary key is removed. How can i configure solr or create table in cassandra, so that I receive in solr response information about synthetic key _uniqueKey. There is no problem...

Weird dse hive integration in DSE 4.7

hadoop,hive,datastax,datastax-enterprise
I'm trying to run Hive query over existing C* table. Here is my C* table definition: drop table IF EXISTS mydata.site_users; CREATE TABLE IF NOT EXISTS appdata.site_users ( user_id text, user_test_uuid uuid, --for testing purposes, if we can use it in queries, there could be some serde problems? user_name text,...

What is the port number for cassandra and solr?

solr,cassandra,datastax
I read the documentation which says 7199 is JMX port number and 8983 is solr port number and 9160 is cassandra client port number. But if i start dse cassandra -s starts solr. If i start cassandra-client in the same machine dse cassandra -f It says Error: Exception thrown by...

How to Connect to Cassandra Remotely Using DevCenter

.net,azure,cassandra,datastax
I setup the DataStax Cassandra Sandbox on Azure using their image. I was able to run OpsCenter locally on the server without any issues. The install is Ubuntu which I am very new to. Per this post Apache Cassandra remote access, I should be able to set my rpc_address to...