Hi I am using Data stax ORM for Java, and I had a question is that possible to have a single query that uses the partition key and also filter the results, if use in the customWhereClause the partition key and another condition will it first...
Hi I am using Data stax ORM for Java, and I had a question is that possible to have a single query that uses the partition key and also filter the results, if use in the customWhereClause the partition key and another condition will it first take all the partition and then proceed the filtering or will it do the filtering on the partitions and also on the columns?
I understand that when inserting data, tombstones might be created because of existing null values in the columns of the dataframe. To mitigate this issue and minimize tombstones, insertion queries should exclude columns with null values.
...I understand that when inserting data, tombstones might be created because of existing null values in the columns of the dataframe. To mitigate this issue and minimize tombstones, insertion queries should exclude columns with null values.
Currently, I'm working with the spark-cassandra-connector in pyspark-jupyter notebook environment and I've come across the "com.datastax.spark.connector.types.CassandraOption" trait for scala, How can I leverage this trait or any other method to address the tombstone problem?
opened Pull Request #3083 on apache/cassandra
#3083 CASSANDRA-19018 An SAI-specific mechanism to ensure consistency isn't violated for multi-column AND queries at CL > ONE
commented Pull Request #3068 on apache/cassandra
TY for the review! Pushed an update fixing the once a day ticking. It was also making the tests fail so that's a big help.
If the value is a numeric, whole number you could use TINYINT, which is meant for storing 8-bit (signed) integers.
Information on this and other data types supported by Apache Cassandra® can be found in this doc:
If the value is a numeric, whole number you could use TINYINT, which is meant for storing 8-bit (signed) integers.
Information on this and other data types supported by Apache Cassandra® can be found in this doc: https://cassandra.apache.org/doc/stable/cassandra/cql/types.html
Select statement using TTL: EX: SELECT value, ttl(value), last_modified FROM test.tblTTLINORDERBY WHERE useruid = ‘userid1' AND direction IN ('out', 'in');
Before the JOOQ upgrade, if we do not use the...
Select statement using TTL: EX: SELECT value, ttl(value), last_modified FROM test.tblTTLINORDERBY WHERE useruid = ‘userid1' AND direction IN ('out', 'in');
Before the JOOQ upgrade, if we do not use the TTL value when inserting data and then check the TTL value using a select query, it will display the values as '0'.
After the JOOQ upgrade(3.9.1 -> 3.17.x), if we do not use the TTL value when inserting data and then check the TTL value using a select query, it will display the values as 'null'.
Are you considering 0 and null as equivalent in this scenario?
I'm going to store a 7 bits value in Cassandra and looking for the most efficient data structure for that. Could you please suggest what can be the best and efficient data type to store 7 bits value in C*?
The old cassandra container was shut down abruptly and i have issues starting it up. I've copied the data over to another container and I getting the following issue,
- I have tried using snapshots and restore. but the data wasn't...
The old cassandra container was shut down abruptly and i have issues starting it up. I've copied the data over to another container and I getting the following issue,
- I have tried using snapshots and restore. but the data wasn't correct.
- Sadly the replicated node was facing some issues as well.
- Currently, the new node is working but I am noticing this error.
How can I fix this error?
DataTracker.java:161 - SSTableIndex.open(column: search, minTerm: , maxTerm: te mohamed tahir , minKey: a6497a9d-5b1f-4707-bbe3-be3a6ebaadcd, maxKey: a6497a9d-5b1f-4707-bbe3-be3a6ebaadcd, sstable: BigTableReader(path='/var/lib/cassandra/data/pab/client-2a3c4e90bfe711eebc156d2c86545d91/md-13-big-Data.db'))
INFO [CompactionExecutor:3] 2024-02-02 01:55:03,499 DataTracker.java:161 - SSTableIndex.open(column: search, minTerm: , maxTerm: zza salim , minKey: 00057570f58f4a1eaf4b29af3802dbdd, maxKey: testclient11449, sstable: BigTableReader(path='/var/lib/cassandra/data/pab/client-2a3c4e90bfe711eebc156d2c86545d91/md-12-big-Data.db'))
ERROR [CompactionExecutor:3] 2024-02-02 01:55:03,499 CassandraDaemon.java:228 - Exception in thread Thread[CompactionExecutor:3,1,main]
java.lang.IllegalArgumentException: Self-suppression not permitted at java.lang.Throwable.addSuppressed(Throwable.java:1072) ~[na:1.8.0_232]
commented Pull Request #3082 on apache/cassandra
Would it make sense for the project to have a test in place that runs the quickstart commands so that any inconsistencies are caught automatically?
opened Pull Request #3082 on apache/cassandra
#3082 CASSANDRA-19360 | Quickstart commands are slightly wrong
Hi Everyone. If you missed it, you can now watch Maxim Muzafarov's presentation of his work on CEP-38: CQL Management, on the Planet Cassandra YouTube channel. https://youtu.be/CjfPoV0RwGQ?si=5X2UmFg5k1V8OtHj
opened Pull Request #3081 on apache/cassandra
#3081 CASSANDRA-16999 trunk native_port_ssl
opened Pull Request #3080 on apache/cassandra
#3080 CASSANDRA-16999 5.0 native_port_ssl in system.peers_v2
opened Pull Request #3079 on apache/cassandra
#3079 CASSANDRA-16999 4.1 add native_port_ssl to system.peers_v2
This is code in the file example.yaml, It is used to perform cassandra-stress testing on the table staff_activites. Actually I want to run 100000 insert operations while stressing, I am able to do it by using the command
...This is code in the file example.yaml, It is used to perform cassandra-stress testing on the table staff_activites. Actually I want to run 100000 insert operations while stressing, I am able to do it by using the command
./cassandra-stress user profile="../example.yaml" "ops(insert=1)" n=100000
But I want build a workload comprising of multiple tables with diff no. of insert operations , I tried to specify it inside the yaml file, It is showing the error. Command used to run is
./cassandra-stress user profile="../example.yaml" "ops(insert=1)"
The code inside the example.yaml file is below
specname: example
keyspace: example
keyspace_definition: |
CREATE KEYSPACE example WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 3};
table: staff_activities
table_definition: |
CREATE TABLE staff_activities (
name text,
when timeuuid,
what text,
PRIMARY KEY(name, when)
)
columnspec:
- name: name
size: uniform(5..10) # The names of the staff members are between 5-10 characters
population: uniform(1..10) # 10 possible staff members to pick from
- name: when
cluster: uniform(20..500) # Staff members do between 20 and 500 events
- name: what
size: normal(10..100,50)
insert:
partitions: fixed(1)
select: fixed(1)/500
batchtype: UNLOGGED
n: 1000 # n=1000 specifies 1000 operations
queries:
events:
cql: select * from staff_activities where name = ?
fields: samerow
latest_event:
cql: select * from staff_activities where name = ? LIMIT 1
fields: samerow
Error faced is
Connected to cluster: Test Cluster, max pending requests per connection 128, max connections per host 8
Datacenter: dc1; Host: localhost/127.0.0.1; Rack: rack1
Created schema. Sleeping 1s for propagation.
java.lang.IllegalArgumentException: Unrecognised insert option(s): {n=10}
at org.apache.cassandra.stress.StressProfile.getInsert(StressProfile.java:652)
at org.apache.cassandra.stress.StressProfile.printSettings(StressProfile.java:158)
at org.apache.cassandra.stress.settings.StressSettings.lambda$printSettings$1(StressSettings.java:311)
at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)
at org.apache.cassandra.stress.settings.StressSettings.printSettings(StressSettings.java:311)
at org.apache.cassandra.stress.Stress.run(Stress.java:100)
at org.apache.cassandra.stress.Stress.main(Stress.java:67)
commented Pull Request #95 on apache/cassandra-sidecar
Updated example output:
INFO [Test worker] 2024-01-31 11:31:31,445 MainModule.java:394 - Configuring streamRequestRateLimiter. rateLimitStreamRequestsPerSecond=5000
INFO [Test worker] 2024-01-31 11:31:31,450 MainModule.java:406...Updated example output:
INFO [Test worker] 2024-01-31 11:31:31,445 MainModule.java:394 - Configuring streamRequestRateLimiter. rateLimitStreamRequestsPerSecond=5000
INFO [Test worker] 2024-01-31 11:31:31,450 MainModule.java:406 - Configuring ingressFileRateLimiter. inboundGlobalFileBandwidth=750 B/s rawInboundGlobalFileBandwidth=750 B/s
INFO [Test worker] 2024-01-31 11:31:31,555 HttpServerOptionsProvider.java:155 - Configured traffic shaping options. InboundGlobalBandwidth=500 B/s rawInboundGlobalBandwidth=500 B/s OutboundGlobalBandwidth=1.46 KiB/s rawOutboundGlobalBandwidth=1500 B/s PeakOutboundGlobalBandwidth=1.95 KiB/s rawPeakOutboundGlobalBandwidth=2000 B/s IntervalForStats=3000ms MaxDelayToWait=2500ms
opened Pull Request #3077 on apache/cassandra
#3077 CASSANDRA-19305: Ephemeral reads