jgerew
commented
6 years ago The problem appears to lie with how the values are separated by UDT fields. All of the data saved prior to the ALTER statement has only 2 values (index 0 and 1), but the UDT now has 3 fields (index 0, 1, and 2). The UDT field names are iterated over and expects the same number of indexes in the value as there are in the field names causing the exception. See current code below:
private[mapping] def columns(column: Column, udt: UserType, value: ByteBuffer): Columns = {
val itemValues = udt.split(value)
((0 until udt.fieldNames.size) :\ Columns()) ((i, columns) => {
val itemValue = itemValues(i) #causes ArrayIndexOutOfBoundsException
if (itemValue == null) {
columns
} else {
val itemName = udt.fieldNameAsString(i)
val itemType = udt.fieldType(i)
val itemColumn = column.withUDTName(itemName)
this.columns(itemColumn, itemType, itemValue) ++ columns
}
})
}If we change the code to expect the possibility of an index mismatch we can resolve the issue:
private[mapping] def columns(column: Column, udt: UserType, value: ByteBuffer): Columns = {
val itemValues = udt.split(value)
((0 until udt.fieldNames.size) :\ Columns()) ((i, columns) => {
val itemValue = if (i < itemValues.length) itemValues(i) else null #see here
if (itemValue == null) {
columns
} else {
val itemName = udt.fieldNameAsString(i)
val itemType = udt.fieldType(i)
val itemColumn = column.withUDTName(itemName)
this.columns(itemColumn, itemType, itemValue) ++ columns
}
})
}
smiklosovic
rampeni
Apache Cassandra Version: 3.11.2 Stratio Cassandra Lucene Index Version: 3.11.1.0
Reproduction steps:
Create a UDT
CREATE TYPE test_udt (name text, type text);Create a stratio lucene index using the UDT
Insert data into the test_table
Execute a query using stratio lucene expression to verify results
SELECT * FROM test_table WHERE expr(test_index, '{query:[{type:"boolean","should":[{type:"wildcard",field:"raw_data.test.name",value:"*"}]}]}');Add a field to the UDT
ALTER TYPE test_udt ADD test_code int;Execute a query again