com.aerospike.client.AerospikeException: Error Code 201: Index not found
at com.aerospike.client.command.MultiCommand.parseGroup(MultiCommand.java:96)
at com.aerospike.client.command.MultiCommand.parseResult(MultiCommand.java:71)
at com.aerospike.client.command.SyncCommand.execute(SyncCommand.java:60)
at com.aerospike.client.query.QueryExecutor$QueryThread.run(QueryExecutor.java:137)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
This is how i am querying it
public List<DBRecord> getMultiByLua(String table, Map<String, Object> queryParams) throws AerospikeException {
QueryPolicy policy = new QueryPolicy();
Statement statement = new Statement();
statement.setNamespace(namespace);
statement.setSetName(table);
if (queryParams != null && queryParams.size() > 0) {
List<Filter> filters = new ArrayList<>();
for (Entry<String, Object> en : queryParams.entrySet()) {
Filter filter = Filter.equal(en.getKey(), Value.get(en.getValue()).toString());
filters.add(filter);
}
statement.setFilters(filters.get(0));
}
statement.setAggregateFunction("ConversionLogs", "profile_filter", Value.get(queryParams.get("tenantId")));
ResultSet recordSet = client.queryAggregate(null, statement);
if (recordSet != null) {
List<DBRecord> records = new ArrayList<DBRecord>();
while (recordSet.next()) {
Record record = (Record) recordSet.getObject();
DBRecord dbRecord = DBRecord.fromRecord(record);
records.add(dbRecord);
}
return records;
}
return null;
}