search

TIBCOSoftware / be-contribution

This repository is to add various contributions across different modules within TIBCO BusinessEvents. It will include contributions by TIBCO BusinessEvents team as well external users/customers/fields teams.
BSD 3-Clause "New" or "Revised" License
0 stars 9 forks source link

Cassandra Store Catalog Function || Unable to fetch data from Cassandra Store when concept has array properties #96

Closed spingale-tibco closed 1 year ago

spingale-tibco commented 1 year ago

Version Information

Software Version(s)
BusinessEvents 6.3.0
OS Type? NA
OS Version? NA

What is the expected behavior?

User should be able to fetch the data from Store when concept has array properties

What is the actual behavior?

Getting below exception while fetching the data from store:: java.lang.RuntimeException: Error occurred while getting item from Store with url[10.69.136.106:9042] and container[EmployeeArray] at com.tibco.cep.store.functions.StoreFunctions.get(StoreFunctions.java:244) at be.gen.RuleFunctions.nullGetEmployeeFromGrid$9y002fEvents$9y002fGetEmployee$.GetEmployeeFromGrid(nullGetEmployeeFromGrid$9y002fEvents$9y002fGetEmployee$.java:19) at be.gen.RuleFunctions.GetEmployeeFromGrid.invoke(GetEmployeeFromGrid.java:11) at com.tibco.cep.runtime.session.impl.RuleSessionImpl$4.doTxnWork(RuleSessionImpl.java:1168) at com.tibco.cep.kernel.core.rete.BeTransaction.run(SourceFile:141) at com.tibco.cep.kernel.core.rete.BeTransaction.execute(SourceFile:101) at com.tibco.cep.runtime.session.impl.RuleSessionImpl.preprocessPassthru(RuleSessionImpl.java:1197) at com.tibco.cep.runtime.scheduler.impl.WorkerBasedControllerV2$2.doTxnWork(WorkerBasedControllerV2.java:488) at com.tibco.cep.kernel.core.rete.BeTransaction.run(SourceFile:156) at com.tibco.cep.kernel.core.rete.BeTransaction.execute(SourceFile:101) at com.tibco.cep.runtime.scheduler.impl.WorkerBasedControllerV2.executeTask(WorkerBasedControllerV2.java:502) at com.tibco.cep.runtime.scheduler.impl.WorkerBasedControllerV2$WorkerTask.run(WorkerBasedControllerV2.java:530) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at com.tibco.cep.runtime.util.CustomBEManagedThread.run(CustomBEManagedThread.java:24) Caused by: java.lang.IllegalArgumentException: newLimit > capacity: (1970405395 > 1876) at java.base/java.nio.Buffer.createLimitException(Buffer.java:372) at java.base/java.nio.Buffer.limit(Buffer.java:346) at java.base/java.nio.ByteBuffer.limit(ByteBuffer.java:1171) at java.base/java.nio.ByteBuffer.limit(ByteBuffer.java:263) at com.datastax.oss.driver.internal.core.type.codec.TupleCodec.decode(TupleCodec.java:116) at com.datastax.oss.driver.internal.core.type.codec.TupleCodec.decode(TupleCodec.java:31) at com.datastax.oss.driver.api.core.type.codec.MappingCodec.decode(MappingCodec.java:87) at com.datastax.oss.driver.api.core.data.GettableByIndex.getObject(GettableByIndex.java:153) at com.datastax.oss.driver.api.core.data.GettableByName.getObject(GettableByName.java:175) at com.tibco.cep.store.cassandra.CassandraStoreContainer.getValue(CassandraStoreContainer.java:173) at com.tibco.cep.store.cassandra.CassandraStoreContainer.getItem(CassandraStoreContainer.java:139) at com.tibco.cep.store.cassandra.CassandraStoreContainer.getItem(CassandraStoreContainer.java:42) at com.tibco.cep.store.StoreContainer.get(StoreContainer.java:68) at com.tibco.cep.store.functions.StoreFunctions.get(StoreFunctions.java:237) ... 14 more

Please provide log files.

CS312_2_1.log

rakulkar-tibco commented 1 year ago

QA was using incorrect column data type for array field. For array/history enabled field it column data type should always be blob.

spingale-tibco commented 1 year ago

Working. After changing the datatype as BLOB for array fields