Questions tagged [cassandra]

Apache Cassandra is a highly scalable, eventually consistent, distributed, structured row store. Questions about Cassandra server administration should be asked on https://dba.stackexchange.com/questions/tagged/cassandra .

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

Research in folder with Apache Cassandra using Docker [closed]

I installed Cassandra using docker, I know that we can write data in tabs and research some datas but how can I research datas in a folder like : ./database/database1.txt If you can help me, I would ...
arthoxe's user avatar
0 votes
0 answers
7 views

SimpleSeedProvider.java:62 - Seed provider couldn't lookup host cass1, using docker

I am trying to run two/three cassandra docker image instances on same device & want to make cluster from these. Using windows & docker desktop. Same result when I have tried on WSL2 Ubuntu. I ...
jdk's user avatar
  • 451
0 votes
0 answers
16 views

Write_Prometheus plugin with basic auth

I am testing the below Write_Prometheus plugin to send the cassandra metrics to prometheus server which is external machine but i see that all metrics are sending without any basic auth happening. so ...
rohit singhal's user avatar
0 votes
0 answers
27 views

How do I use a local Volume for bitnami/cassandra:4.1 without permission errors?

I have the following cassandra:
 container_name: cassandra
 image: bitnami/cassandra:4.1
 volumes:
 - ./cassandra_data:/bitnami
 environment:
 - CASSANDRA_SEEDS=...
Jackie's user avatar
  • 22.1k
0 votes
0 answers
25 views

Cassandra/Scylla cartesian product in a simple WHERE IN query? [duplicate]

I have a simple table like group(id varcahr(64) primary key, size bigint) and I need to find if a set of ids are in the table. I use a simple query: SELECT id FROM group WHERE id IN (<id1>..<...
Ste's user avatar
  • 179
-1 votes
1 answer
29 views

Huge delete on Cassandra ti reclaim disk space

I have a 3 node Cassandra v3.0.15 cluster with replication factor 3. My disk size is 2Tb and it's already 95% full. Almost 1.5T of data is considered stale and must deleted and retain only last 2 ...
Dexter's user avatar
  • 820
1 vote
2 answers
31 views

What database use to store arrays of fractional numbers that give AI to fast write and read?

I need to store a lot of arrays of fractional numbers that I need to quickly write, read, and search. I need a database where I can give an array of numbers that I get from AI and get fast results ...
JsPlusPlusDeveloper's user avatar
1 vote
1 answer
47 views

"Cannot have aggregate and non-aggregate selectors in query" in azure cosmos cassandra db

https://howtoprogram.xyz/2017/02/18/using-group-apache-cassandara/ I am trying to execute the same example which is in above link in azure cosmos cassandra db but getting the below error enter image ...
Amrutha's user avatar
  • 11
0 votes
0 answers
15 views

Cassandra / Scylla / NodeJS - Validation failed for type org.apache.cassandra.db.marshal.Int32Type: got 8 bytes

I have this function: async function insertGameSession(user_id, start_date, gameId) { const session_id = scyllaDB.types.TimeUuid.now(); // Generate a new time-based UUID const query = ` ...
Venelin's user avatar
  • 2,930
0 votes
0 answers
24 views

How to simulate a 'heavy' query in Cassandra?

I am writing an integration test for a part of my application and I want to test that my custom readTimeoutMillis property is set and works as expected. In order to do so, I want to simulate a heavy ...
dtekunov's user avatar
1 vote
1 answer
21 views

system.size_estimates seems to be off in estimates than real table

I have created a simple schema in scylla with just a table chunks(id text, size bigint) and filled it with a bulk upload of about 30M rows. Using dsbulk count I get the right row count: dsbulk-1.11.0/...
Ste's user avatar
  • 179
0 votes
0 answers
12 views

Chunks & indexes not getting deleted from cassandra storage even after setting retention period

Below is my schema config for loki schemaConfig: configs: - from: 2023-09-24 index: period: 24h prefix: loki_index_ chunks: prefix: chunk ...
Sunilsai's user avatar
0 votes
1 answer
12 views

Bitnami Helm Cassandra -- Unable to connectwith cqlsh [remotely]

I am not able to connect remote cassandra cluster which is built using bitnami helm chart and self signed cert. Below error. FYI.. i have enabled ssl cqlschrc as below [ssl] ; certfile = ~/keys/...
Narayana Swamy's user avatar
0 votes
0 answers
10 views

Loading a cassandra DB as a dataframe in PyCharm using python and pyspark

I'm using PyCharm to run my python code. I want to use pyspark to load a cassandra DB. My code: listsDataFrame = spark.read.format("org.apache.spark.sql.cassandra").options(**...
Aditya's user avatar
  • 33
0 votes
1 answer
23 views

Is there a solution to store user's data in a cassandra table with distinct non primary values only?

Trying to design a cassandra database table to store user's profile information - username, Name, Mobile Number and Email ID. username is used as the clustering key, whereas I want to limit Mobile ...
Norbu M Ashraf's user avatar
0 votes
1 answer
31 views

Save the current state of the docker container into a new docker image

I have a simple project that has a Cassandra database in a docker container. The database contains only one keyspace and a table. I want to save the container as an image after creating the keyspace ...
Panda153's user avatar
0 votes
0 answers
16 views

spark with cassandra cluster [closed]

I am trying to set up a cassandra cluster and use spark as its query engine. I am using spark 3 with standalone scheduler. My question is how to set up spark: should i set up spark workers/driver on ...
xsa xsa's user avatar
  • 21
0 votes
2 answers
14 views

Do keeping cassandra fetch limit low make any improvement in performance?

I have to know if setting a lower fetch limit for a Cassandra SELECT query makes any improvement in performance of db? PS : I recently changed a queries fetch limit from 100000 to 5000. I thought ...
Lucknesh_N's user avatar
2 votes
1 answer
27 views

Is there any way to use reactive cassandra repository with Pageable in Spring Boot?

I am trying to use ReactiveCassandraRepository interface for my repository. When I tried to add findAll method like this: public interface MatchRepository extends ReactiveCassandraRepository<Match, ...
karakale's user avatar
  • 146
0 votes
0 answers
14 views

Understanding the implications of using UnpooledByteBufAllocator.DEFAULT in Flink with Cassandra sinks

I am in the process of upgrading Flink applications from JDK 8 to JDK 11, and these applications use Cassandra sinks. During this process, I encountered an issue with the Flink cluster running out of ...
Shivanshu Gupta's user avatar
0 votes
0 answers
25 views

Does Astyanax write use "default_time_to_live"?

I am writing data into a Cassandra cluster using Astyanax like so: private void writeToBatch(Collection<Program> programBatch, MutationBatch batch) { ColumnFamily<UUID, String> ...
Lucifer893's user avatar
0 votes
0 answers
38 views

Apache Cassandra, how to estimate amount of work for repair

We have a cluster conststing of 14 nodes in two datacenters, version 4.0.5. The database is pretty big and repair process takes pretty long time. Is there any way to estimate the amount of changes for ...
Aleks M's user avatar
  • 11
2 votes
1 answer
26 views

How do I work with JSON-like data along with vector search in Astra DB

I've an Astra DB cluster and I'd like to work with JSON-like structures along with vector search on them via my Mongoose library in my javascript app. How do I achieve that?
Madhavan's user avatar
  • 843
0 votes
1 answer
26 views

How to make singleton connection in cassandra database in node js

I am using cassandra db so currently every request is creating new connection instance to db. I want if a connection is already establish than skip to create new one. and using a node dependency for ...
Sonu Suthar's user avatar
1 vote
1 answer
24 views

How to write current timestamp in cassandra column using entity mapper

We are using entity mapper to map cassandra table to java object. Ex class Activity { @PrimaryKey int id; @Column Date modifiedDate; @Column String activityDesc; } I want to add ...
Deepu--Java's user avatar
  • 3,752
0 votes
0 answers
39 views

Run python code on Databricks, using multiprocessing

I have the following code that is my final attemp to port some operation done in sequential order to parallel executions. This is code that I run on Databricks and I wanted to speed up the execution. ...
Gabriele Sciurti's user avatar
0 votes
1 answer
18 views

How do I generate tokens for the RandomPartitioner?

I want to calculate and assign tokens to newly created Cassandra cluster with multi DC WITH Random Partitioner. I am using OSS Apache Cassandra 1.0.12. What formula can I use or is there a tool to ...
Zen's user avatar
  • 31
0 votes
0 answers
13 views

Datastax Solr Search so It Will Results Only 1 Result for Every Range of Date

I am using Datastax Enterprice 6.8; I have a trajectory dataset with timestamp Date field. This dataset updated at least in every 5 seconds, so it will be 720 data in an hour, for every entity. Is it ...
panoet's user avatar
  • 3,618
1 vote
1 answer
33 views

When using Docker Compose to create three cassandra nodes on the same network, how to prevent them from splitting into separate rings?

I'm on XUbuntu, with all the latest updates applied. I've set up the Docker repo, and installed the latest docker suite of tools. I've used apt-get and installed docker-compose. I've created the ...
tcs's user avatar
  • 367
1 vote
2 answers
44 views

Is there any tool available to migrate Oracle tables to Cassandra DB?

How can the Oracle Database Schema, Tables, and Procedures be migrated to Cassandra? Any tool available to do this work?
Srinivasan Duraisamy's user avatar
0 votes
1 answer
71 views

DBeaver Community Edition - No Driver for Apache Cassandra on Mac

I am a Mac user attempting to set up DBeaver to connect to Cassandra DB. https://downloads.datastax.com/#odbc-jdbc-drivers has no Mac version for Apache Cassandra to download. Any solutions or ...
user22554263's user avatar
-1 votes
2 answers
16 views

SchemaAction to add a column to a Cassandra table

I want to add the column in table (Cassandra ) with deleting the data when i added the field name in entity class. Previously update is there now it is deprecated. So tell me what we have to use. ...
Shailendra Kumar Prasad's user avatar
1 vote
1 answer
31 views

How can I estimate the Cassandra repair progress?

Me and my team is trying to build a tool to perform maintenance tool (with web interface) within our organisation and we want to show a progress bar on the tool showing estimate percentage and/or ...
JayRathod's user avatar
0 votes
1 answer
54 views

Node specified with setNode() method forwards read request to other nodes

I am trying to read data present in a specific cassandra (4) node, using Datastax driver version 4.13. I have read this post, which supposedly works for driver versions 3.x I have modified my code as ...
ranban282's user avatar
  • 146
0 votes
0 answers
23 views

Tombstone values not written in Cassandra

I have a sink connector that is writing a JSON message to a Cassandra table. The Cassandra table has a row with some columns having timestamps values. A new message comes to the sink connector and now ...
Prashanth Sirikonda's user avatar
1 vote
2 answers
29 views

Schema operation failed: Unknown property 'read_repair' , 'additional_write_policy'

I am using the following cassandra servers and while trying to create a table name I am getting following error. 2023-09-11 13:57:55,961 [info] c.a.l.s.r.c.CassandraCluster - Connected to Cassandra ...
BKV's user avatar
  • 11
0 votes
2 answers
28 views

partition key for cassandra db single node

Partition key is used to distribute row to nodes. If I only use one single node, should I worry about the warning of comparing on partition key? Moreover, in my user case, I need to query on partition ...
MengMeng's user avatar
  • 1,016
1 vote
1 answer
26 views

Issue with pagination in Cassandra

I am trying to paginate through records in Cassandra. I am using paging state for this. CASE 1: When I set the LIMIT and fetch size in the query, it returns paging state up until the limit is not ...
Ritesh Kumar's user avatar
0 votes
0 answers
10 views

Is it viable using sstableloader to clone data from Cassandra 4.x back to Cassandra 3.x?

I learned that Cass 4.x is compatible to sstables from Cass3.x. Cassandra 4.1 (which has version -nb- ) is able to read SSTable formats as early as -ma- (from C 3.0. 0).* So I assume that I can use ...
Koniph Cole's user avatar
0 votes
1 answer
34 views

Unable to connect to Cassandra (AstraDB) for vector search example from LangChain docs

I'm trying to connect to AstraDB for my Python vector search project (for my GPT chatbot), but I'm getting a connection error. (I'm following the example in the LangChain Cassandra Vector store ...
devinbost's user avatar
  • 4,676
0 votes
1 answer
42 views

Unable to connect to cassandra 4.1.3 version from springoot 3.1.1 version

Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cassandraSessionFactory' defined in class path resource [com/test/config/CassandraConfig....
mpsimham's user avatar
2 votes
1 answer
29 views

How to get backpressure for Cassandra Writes in multi-apps scenario?

I have multiples applications that do writes to Cassandra. Each unit app has backpressure mecanism configured, like throughputMBPerSec=10 Problems arise when multiples applications are running at the ...
Klun's user avatar
  • 100
-1 votes
1 answer
39 views

Cassandra suddenly hangs, returns Windows FileSystemException: "The process is inaccessible because the file is in use by another process"

I am running a product. I'm using these versions: JDK 1.8 Cassandra 3.11.7 (EmbeddedCassandra-Github) SpringBoot 2.2.2 Release WindowServer 2019 Standard Memory 128GB The server specification is ...
junsung kang's user avatar
1 vote
2 answers
48 views

Can I just copy the snapshot from an existing node to a new machine to restore data?

I'm studying backup and restore of Cassandra. The DataStax doc (Cassandra restore) mentioned two ways of restoring data: Restoring from local nodes Restoring from centralized backups. My question is:...
Koniph Cole's user avatar
0 votes
0 answers
30 views

Error decoding/mapping Kafka record: CDC Pipeline from PostgreSQL to Cassandra DB?

I am encountering an issue while working with Change Data Capture using Kafka Connect. Problem: I am working on a Change Data Capture Pipeline, and I'm getting the following error message when trying ...
Jasir Arfat's user avatar
0 votes
1 answer
38 views

Apache Spark and Cassandra: UnauthorizedException on Super-user Permission with Consistency Level QUORUM

I'm using Apache Spark to write data to a Cassandra cluster. The deployment is kubernetes based and am using cassandra helm chart. Sporadically, I encounter a SparkException that leads to job abortion,...
Pro's user avatar
  • 315
0 votes
0 answers
14 views

Bitnami Cassandra external loadbalance ip for each pod

How do I add external IP's to all pods in bitnami cassandra helm chart. I don't want to use nodeport as i might have 10+ k8 nodes. Or single load balancer ip [loadBalancerIP:""]is only ...
Narayana Swamy's user avatar
0 votes
0 answers
18 views

K8ssandra on Existing on-prem k8 cluster

Is there a document where I can refer and deploy k8ssandra onto onprem k8 single cluster. This https://docs.k8ssandra.io/install/local/single-cluster-helm/ expects docker/mini kube to move forward. Is ...
Narayana Swamy's user avatar
0 votes
1 answer
25 views

Update edge properties from another existing edge in gremlinpython

I am trying to update edge in my dse graph by extracting properties of another existing edge as below: edgeProperties = g.E(edge.id).valueMap().next() g.V(newVertex.id).as_('newV').addE(edge.label).to(...
S_R R_G's user avatar
0 votes
1 answer
40 views

Getting error: You specified datacenter1 as the local DC, but some contact points are from a different DC

I am using TestContainres in my app registry.add("cass.contact-points", cassandra::getContainerIpAddress); registry.add("cass.datacenter", cassandra::...
rafradio's user avatar

1
2 3 4 5
413