Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
None
Description
In ctor:
if (PersistentBase.class.isAssignableFrom(dataStore.getPersistentClass())) { persistentSchema = ((PersistentBase) dataStore.getBeanFactory().getCachedPersistent()).getSchema(); } else { persistentSchema = null;
In updateByQuery, persistentSchema is passed to CassandraQueryFactory.getUpdateByQueryForAvro() which dereferences the schema without checking:
public boolean updateByQuery(Query query) { List<Object> objectArrayList = new ArrayList<>(); String cqlQuery = CassandraQueryFactory.getUpdateByQueryForAvro(mapping, query, objectArrayList, persistentSchema);
Attachments
Issue Links
- links to