Questions tagged [cassandra]

Cassandra is a highly scalable, eventually consistent, distributed, structured row/column store.

Filter by
Sorted by
Tagged with
0
votes
0answers
14 views

READ messages were dropped in last 5000 ms: 2 internal and 0 cross node. Mean internal dropped latency: 2556 ms

INFO [ScheduledTasks:1] 2020-01-20 13:45:32,095 MessagingService.java:1236 - READ messages were dropped in last 5000 ms: 2 internal and 4 cross node. Mean internal dropped latency: 3449 ms and Mean ...
0
votes
0answers
19 views

How does pySpark read data from Cassandra

My Cassandra runs on a docker container on my machine. And I have a python file who runs the most basic word count application on spark which works. Now I'm trying to read data from my Cassandra. ...
-1
votes
1answer
17 views

Cassandra: no viable alternative at input

I am newbie to Cassandra database and I am trying to save my Spark dataframe to the Cassandra DB. While creating the table I am getting the exception. "SyntaxException: no viable alternative at input"....
-1
votes
1answer
9 views

Cassandra Data Distribution & Replication [closed]

Let's say, I have 8 nodes cluster. I have one keyspace in this cluster. If I have a replication factor of 3 for this keyspace, does this mean, data will be replicated to 3 nodes? If so, will all the ...
0
votes
1answer
23 views

Cassandra - Cannot achieve consistency level QUORUM ISSUE

I am using Cassandra DB for a few purposes in the project. I am trying to update the count of votes_up column in the comments table. But I am getting this error. enter image description here My ...
1
vote
0answers
17 views

Problem with Synchronous query execution in cassandra-driver (Node.js)

I'm trying to create at runtime keyspaces and tables inside them using cassandra-driver node implementation maintained by datastax. On the documentation (here) it's pointed out that there is a sync-...
1
vote
1answer
21 views

Disable thrift in Cassandra 3.x

Is it possible to disable thrift in Cassandra 3.x? Looked into nodetool disablethrift and also start_rpc setting of Cassandra.yaml, however is it possible to stop shipping libthrift jar from ...
0
votes
1answer
25 views

How to create keyspace and insert data using Phantom dsl

I'm using this library for the first time, and I ran into a problem. I did everything according to the documentation, but nothing is working, and i don't know why. Here is my table model: trait ...
2
votes
1answer
55 views

AttributeError: 'Student' object has no attribute '_values'

I am trying to write a flask application with cassandra and using Flask-CQLAlchemy library. And when I am trying to create an object of my model class(Student) it's giving me an error called 'Student' ...
0
votes
0answers
20 views

Create Tables In Spring Boot Reactive Cassandra On Start Up

I am not able to create tables in cassandra on application start-up. I am using spring boot 2.1.6-RELEASE along side spring-boot-starter-webflux and spring-boot-starter-data-cassandra-reactive. ...
0
votes
0answers
34 views

How to delete data from Cassandra table with TWCS and counter column?

I have a table that uses TWCS including a counter column: create table sensors_by_time ( group text, // sensor group date date, // bucketing id text, ...
1
vote
1answer
29 views

How to create a table to maintain a hierarchy structure in Cassandra?

We need a table to maintain a hierarchy to perform all the CRUD operations. Sample: - Karnataka - Bangalore - Kormangala - Hubli - Madhya Pradesh - Gwalior - Delhi I thought of the ...
0
votes
0answers
6 views

JanusGraphException: Could not commit transaction due to exception during persistence Caused by: PermanentLockingException: Local lock contention

I have a high level code like this. MethodXyz() { updateVertex(A, props1) commit // some other code updateVertex(A, props2) commit // do something else - long running } This method is called from ...
3
votes
0answers
29 views

How to remove tombstones with a timestamp in the future

How can tombstones that were inserted with a timestamp set in the very distance future be removed? Context: There was a bug in some code that inserted entries with a timestamp in the distant future. ...
0
votes
1answer
30 views

Cassandra Java date issue

I have a date as string and now I want to persist the same datetime in a timestamp column in Cassandra db. On cqlsh query the timestamp is shown as different from the actual one. I am parsing it ...
0
votes
0answers
18 views

How to Enable Logs for Hector Cassandra Client

I am using Hector jar to communicate with Cassandra 1.x.x in production code. Off-late I am getting few problems where the call-stack is pointing to the Jar code. I am pretty sure that the problem is ...
0
votes
1answer
27 views

How to connect Cassandra from gcloud cluster using python

We try to connect cluster using bash script using Jupyter notebook : !gcloud compute --project "project_name" ssh --zone "us-central1-a" "cassandra-abc-m" After that we try to connect using : ...
0
votes
0answers
74 views

Spark simple select job very slow

I have a simple job that selects all entries from a table. This job takes ~ 40sec. to complete. Same query ( select * from users ) on the cassandra database returns all results immediately. In the ...
-1
votes
0answers
20 views

Quarkus Cassandra Integration

Quarkus suppot many database, SQL and NoSQL. Cassandra have best performance on benchemark, much better when using "ScyllaDB", database based on Cassandra. When will we have integration with Cassandra?...
1
vote
2answers
32 views

Cassandra read consistency LOCAL_QUORUM

I have a doubt about how does Cassandra return the value in case of LOCAL_QUORUM. If due to some case there is no quorum consensus between the values returned by individual nodes, will Cassandra not ...
1
vote
2answers
37 views

Best way to transfer data from one cassandra cluster to an other

I need to transfer data from one cluster to an other. The table structure is the same on both clusters, what I need to do is select data from Table A, Clustering Key A1 on Cluster 1 and copy it to ...
-5
votes
0answers
23 views

Merits of Partitioning in Cassandra Databases

What are the merits of partitioning in Cassandra wherein we divide (uniformaly/non-uniformaly) rows around different nodes based on the used partition algorithm?
1
vote
1answer
33 views

Cassandra - Nested Json Insert

DSE 6.7 CentOS 6.7 We have data in JSON with the below format - { "Event_Type": "Booked", "Car": { "RegId": "0961dbac-297d-424c-96ce-9f37f1707cd9" } } { "Event_Type": "Complete", "Car": { "RegId": "...
0
votes
1answer
35 views

Millions of device information fetching from cassandra using GOLANG Driver

I am using Cassandra database to fetch millions of devices data based on device_id as partition key with parallel from API using GO-LANG DRIVER. some one please guide me which driver parameters need ...
0
votes
1answer
50 views

Cassandra: Python equivalent method to `sstabledump`?

I'm writing an application to read cassandra sstable files (e.g. mc-1-big-Data.db).we don't want to do it with "sstabledump" command which will require us to install cassandra in our cluster. So do we ...
0
votes
1answer
23 views

ccm start Address already in use; a cluster may already be running or you may need to add the loopback alias

I'm struggling starting Cassandra cluster with 'ccm start' command. I created a cluster named Gdelt, with 3 nodes, as follow: ccm status gives: Cluster: 'Gdelt' ------------------- node1: DOWN (...
0
votes
1answer
28 views

Datastax Kafka Connector Unable To Parse Json Topic

I have a producer class sends to a topic using custom JsonSerializer from Github public class JsonSerializer<T> implements Serializer<T> { ... @Override public byte[] ...
1
vote
1answer
23 views

Test Cassandras R + W > N

I want to explicitly show the R + W > N rule at a presentation. So my initial idea how to do this is as following: // setup 1: Create a Docker network with 3 Cassandra Nodes. 2: Create a simple ...
0
votes
1answer
35 views

How do I fetch sorted logs in Cassandra?

In my application we store logs in Cassandra. User can see the logs after giving a start and an end date for the logs. We fetch the data on the basis of these dates and have implemented pagination as ...
2
votes
4answers
67 views

What is the difference between scylla read path and cassandra read path?

What is the difference between Scylla read path and Cassandra read path? When I stress Cassandra and Scylla then Scylla read performance poor by 5 times than Cassandra using 16 core and normal HDD. I ...
0
votes
1answer
22 views

How to periodically write new rows in a Cassandra table to another table

I am trying to copy rows from a Cassandra table to another table (in Cassandra or may be to Oracle) continuously for running different dashboard queries. The source Cassandra table will be having ...
1
vote
0answers
68 views

Cassandra - Token pagination over bucket approach

I am currently working on a chat and I would like to paginate the messages of a given thread. I am a Cassandra table which looks like this: CREATE TABLE messages ( ID uuid, ... CreatedAt ...
0
votes
1answer
46 views

Databricks Spark Cassandra connectivity throwing exception: com.datastax.driver.core.exceptions.NoHostAvailableException

I have installed the Cassandra DB in Azure Virtual Machine and want to perform read/write operation through the Azure Databricks. I am going through the Databricks offcial documentation which does not ...
0
votes
1answer
24 views

Cassandra (DSE) - Need suggestion on using PER PARTITION LIMIT on huge data

I have a table with around 4M of partitions and each partition contains 4 rows. So, the total data in table would be having 16M rows (wide columns). Since our table is a time series database, we only ...
0
votes
2answers
37 views

Not marking nodes down due to local pause of 8478595263 > 5000000000

i have 3 node cassandra cluster in kubernetes. Deployed cassandra using bitnami/cassandra helm chart. getting error based on more number of request after sometime later WARN [GossipTasks:1] 2020-...
0
votes
1answer
21 views

Cassandra 3.11.1 GeoSpatial support

I'm trying to use GeoSpatial example from Cassandra documentation: https://docs.datastax.com/en/dse/6.7/cql/cql/cql_using/search_index/queriesGeoSpatial.html CREATE TABLE test ( id text PRIMARY KEY, ...
1
vote
1answer
29 views

How to track changes in Cassandra table using Java

I am just looking for a way to track changes in a table of Cassandra. I don't want to use a trigger. If any changes made I will immediately update my data source. Do you have any idea how to ...
0
votes
1answer
56 views

How do I bulk delete rows in Cassandra using the Java driver using partial primary key?

I have a table where the primary key is comprised of an account and an id. I need to use both as the "id" isn't unique across all accounts. In certain edge cases (not a hot path), we often need to ...
1
vote
1answer
46 views

Jaeger-query and Jaeger-collector pods in CrashLoopBackOff

I am trying to deploy the Jaeger Helm chart with Azure Cosmos DB acting as the Cassandra Storage Backend. I have set up the CosmosDB and created a values file as below: storage: type: cassandra ...
1
vote
1answer
20 views

DSE (Cassandra) - Range search on int data type

I am a beginner using Cassandra. I created a table with below details and when I try to perform range search using token, I am not getting any results. Am I doing something wrong or is it my ...
0
votes
1answer
44 views

Cassandra Insert/Update without duplication when you can't rely on the primary key or uuid

Here's the problem. Our 'customers' are ingested regularly as part of bulk file upload (CSV) from clients. The data we have from them is Name, Address, PostCode, Client Reference Number. We're ...
0
votes
1answer
35 views

How to refresh meta data dataframe in streaming app in every 5 min?

I am using spark-sql 2.4.x version , datastax-spark-cassandra-connector for Cassandra-3.x version. Along with kafka. I have a scenario for some finance data coming from kafka topic, say financeDf I ...
0
votes
1answer
44 views

Optimise Cassandra Query for faster result

I have a table called geo_location which keeps public ip range in the city( in integer form). I have to query an ip in the table and check if it lies between start_range and end_range and then return ...
2
votes
1answer
47 views

Getting error for value exceeding max_value_size_in_mb in cassandra.yaml

Now I observed some errors on my Cassandra system.log/debug.log and node was sudden DOWN after below errors. CorruptSSTableException as value length exceeds the maximum of 287435456, which is set via ...
0
votes
1answer
31 views

Cassandra Read Consistency when write path fail

I am new to cassandra and trying to figure out how cassandra provides consistency in case of failed writes. Consider following scenario where CL is QUORUM, in which case 2 out of 3 replicas must ...
0
votes
2answers
30 views

Cassandra PER PARTITION LIMIT not working throwing error in dev center

I am trying to run below CQL query in dev center (1.6) and seeing this error thus not allowing me to execute query. I verified DataStax documentation and I see syntax is correct. Any help please? ...
0
votes
1answer
21 views

spark-cassandra-connect python deleteFromCassandra method

i'm using Spark, Cassandra, Spark-Cassandra-Connector on Databricks Notebook, according to their website, we can use 'deleteFromCassandra' to delete rows: https://github.com/datastax/spark-cassandra-...
0
votes
0answers
27 views

Differences for max time uuid in cqlsh and Python cassandra driver

I'm having a bug where my python code can't find a record in Cassandra and it seems to boil down to differences in the minTimeuuid/maxTimeuuid functions in cqlsh versus the python driver. When I run ...
0
votes
0answers
18 views

Determine if Cassandra UPDATE changed value of column using a TRIGGER

I'm using a trigger on a Cassandra-DB Table. When the trigger fires, I'm trying to find out whether an UPDATE operation is going to cause actual data manipulation on a specific table column of the ...
-1
votes
0answers
9 views

How to Connect eclairjs in nodjs to cassandra database

Is there a way to connect Eclairjs to cassandra DB? if yes, please help me. All the examples i saw for eclairjs were only for reading from text file. If its not possible, can you give a good solution ...