opened Pull Request #3155 on apache/cassandra
#3155 CASSANDRA-19007 experimental version of a fix for 19007, where normal filtering respects the strict flag
Sent a message in 👋 Welcome in #🆘discord-help
Hi I wondered how do you mange to use double quote for this kind of keyword in cassandra using datastax mapping? because I used that but I still get the error:
Invalid CQL form [view]: needs double quotes...
Hi I wondered how do you mange to use double quote for this kind of keyword in cassandra using datastax mapping? because I used that but I still get the error:
Invalid CQL form [view]: needs double quotes
https://cdn.discordapp.com/attachments/1086041101841989692/1213170982894829578/image.png?ex=65f48085&is=65e20b85&hm=d1e2366ca6f9ead260fd0efbfdabeca8c8f4aeadece472baebaa85481cc32fad&
If I have the below data set:
id year location
------------------
1 2000 Tokyo
1 2001 NewYork
2 2000 London
2 2002 NewYork
and a CQL table that has,
PRIMARY KEY is (id,year);...If I have the below data set:
id year location
------------------
1 2000 Tokyo
1 2001 NewYork
2 2000 London
2 2002 NewYork
and a CQL table that has,
PRIMARY KEY is (id,year);
I would like create a materialized view to have each id for those records with location as NewYork.
The resulting view will have to look like:
id year location
------------------
1 2001 NewYork
2 2002 NewYork
Basically, I need to sort by year first then with location next. Is it possible? Thanks.
Pull Request #3154 on apache/cassandra merged by bschoening
#3154 CASSANDRA-19242: bumped CQLSH version 6.2 > 6.3
Facing the above issue after upgrading application to java 17 with spring 6.0.8 and datastax-driver 4.17.0 beta release and cassandra-5.0-beta1 server.
Caused by: java.lang.ClassCastException: class...
Facing the above issue after upgrading application to java 17 with spring 6.0.8 and datastax-driver 4.17.0 beta release and cassandra-5.0-beta1 server.
Caused by: java.lang.ClassCastException: class com.datastax.oss.driver.internal.core.cql.DefaultSimpleStatement cannot be cast to class com.datastax.oss.driver.api.core.cql.PreparedStatement (com.datastax.oss.driver.internal.core.cql.DefaultSimpleStatement and com.datastax.oss.driver.api.core.cql.PreparedStatement are in unnamed module of loader org.eclipse.jetty.webapp.WebAppClassLoader @563e4951) at com.infinote.persistence.EntityMetaDataBasedQueryBinder.bindFindByIdQuery(EntityMetaDataBasedQueryBinder.java:161) at com.infinote.persistence.dao.CassandraDaoSupport.lambda$get$6(CassandraDaoSupport.java:567) at com.infinote.persistence.dao.CassandraDaoSupport.doWithRetry(CassandraDaoSupport.java:648) at com.infinote.persistence.dao.CassandraDaoSupport.get(CassandraDaoSupport.java:565) at com.infinote.smtp.dao.EmailConfigDao.get(EmailConfigDao.java:20) at com.infinote.smtp.EmailServiceImpl.get(EmailServiceImpl.java:156) at com.infinote.smtp.EmailServiceImpl.afterPropertiesSet(EmailServiceImpl.java:201)
The Below issues comes when in deploy the code in the server and table creation is failing Below is the code for refence.
CassandraDaoSupport class invoking bindFindByIdQuery Method present in EntityMetaDataBasedQueryBinder
protected <T> T get(final Class<T> entityType, final Map<String, Object> ids) {
final EntityMetaData entityMetaData = cassandraConfiguration.getEntityMetaData(entityType);
List<T> resultSet = doWithRetry((retry) -> {
BoundStatement boundStatement = new EntityMetaDataBasedQueryBinder(cassandraConfiguration, entityMetaData)
.bindFindByIdQuery(ids, retry);
return find(boundStatement, new EntityMetaDataBasedResultSetMapper<T>(entityMetaData));
});
if (resultSet.size() > 1) {
throw new NonUniqueResultException("Multiple objects found with id " + Arrays.toString(ids.entrySet().toArray()));
} else if (resultSet.isEmpty()) {
return null;
}
return resultSet.get(0);
}
EntityMetaDataBasedQueryBinder class bindFindByIdQuery method
public BoundStatement bindFindByIdQuery(Map<String, ? extends Object> ids, boolean refreshCache) {
PreparedStatement statement = (PreparedStatement) SimpleStatement.newInstance(String.valueOf(instance().findByIdStatement(entityMetaData, refreshCache)));
List<Object> values = new ArrayList<>();
for (FieldMetaData idField : entityMetaData.idFields()) {
values.add(ids.get(idField.name()));
}
//also need to bind the client id as the last parameter
if (entityMetaData.supportMultiTenancy()) {
values.add(cassandraConfiguration.getCurrentClient());
}
return statement.bind(values.toArray());
}
This is present in QueryCache class
public PreparedStatement findByIdStatement(EntityMetaData metaData, boolean refreshCache) {
QueryEntry queries = getQueryEntry(metaData);
if (queries.findById == null || refreshCache) {
queries.findById = cassandraConfiguration.getSession(metaData).prepare(metaData.findByIdStatement());
}
return queries.findById;
}
Please help me resolve this issue @Cassandra or any one upgraded to 4+ datastax driver version
Commented on a reddit post on Stress testing cassandra with different... in r/cassandra
I’m late to the party here, but there’s also my tool, easy-cass-stress. Formerly tlp-stress. It’s used to stress some of the biggest deployments in the world.
Pull Request #101 on apache/cassandra-sidecar merged by yifan-c
#101 CASSANDRASC-110 Fix NPE thrown when getting StorageClient from pool
Hey Everyone, if you’d like to see this talk live again / ask more questions, we are hosting an extended session today at noon eastern...
Hey Everyone, if you’d like to see this talk live again / ask more questions, we are hosting an extended session today at noon eastern https://www.linkedin.com/posts/anant_cassandra-lunch-135-prometheus-grafana-activity-7169001417175724032-OC7D?utm_source=share&utm_medium=member_ios
Cassandra works on a "last write wins" scenario. If you were to rerun the SSTableLoader with the old data, it would write that old data into Cassandra, overwriting any data occupying the keys in-question.
Otherwise I'm fine with sharing the video file with someone else (to put up on the channel).
Hey everyone, I have a new podcast episode for the Apache Cassandra® Corner. Usually, I'd just upload it to the Planet Cassandra YouTube channel myself, and I still have access to do that. But just given how everything has changed, I wanted to...
Hey everyone, I have a new podcast episode for the Apache Cassandra® Corner. Usually, I'd just upload it to the Planet Cassandra YouTube channel myself, and I still have access to do that. But just given how everything has changed, I wanted to ask: is that still ok?
Mentioned @cassandra
I want some understanding of sstableloader in cassandra 1.0.12
I have few set of rows inserted recently in cassandra 1
What will happen if I load old set of rows stored in sstables with same key using sstableloader?
Will...
I want some understanding of sstableloader in cassandra 1.0.12
I have few set of rows inserted recently in cassandra 1
What will happen if I load old set of rows stored in sstables with same key using sstableloader?
Will it update same rows with old values or my recently inserted values will be preserved?
opened Pull Request #102 on apache/cassandra-sidecar
#102 CASSANDRASC-111 Improve observability in Sidecar with Dropwizard metrics
opened Pull Request #101 on apache/cassandra-sidecar
#101 CASSANDRASC-110 Fix NPE thrown when getting StorageClient from pool