Details
-
Bug
-
Resolution: Fixed
-
Major
-
Columnar 1.0.0
-
Columnar Edition 1.0.0 build 2172
-
Untriaged
-
0
-
Unknown
Description
Unsure if it's related to https://issues.couchbase.com/browse/MB-62461, but there are a bunch of illegal state exceptions seen on nodes 003 and 004 -
2024-06-25T07:00:08.960+00:00 INFO CBAS.adapter.TopicRecordReader [Executor-9552:f21c19c32f7c6e1642ddee41b4702e0a] Error while polling data from Kafka |
java.lang.IllegalStateException: Consumer is not subscribed to any topics or assigned any partitions
|
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1171) ~[kafka-clients-3.6.0.jar:?] |
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1159) ~[kafka-clients-3.6.0.jar:?] |
at com.couchbase.analytics.adapter.TopicRecordReader.dataPoll(TopicRecordReader.java:365) [columnar-connector.jar:1.0.0-2172] |
at com.couchbase.analytics.adapter.TopicRecordReader$KafkaTopicDataPoller.run(TopicRecordReader.java:393) [columnar-connector.jar:1.0.0-2172] |
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] |
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] |
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] |
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] |
at java.base/java.lang.Thread.run(Thread.java:840) [?:?] |
2024-06-25T07:00:08.960+00:00 INFO CBAS.adapter.TopicRecordReader [Executor-10890:f21c19c32f7c6e1642ddee41b4702e0a] Error while polling data from Kafka |
java.lang.IllegalStateException: Consumer is not subscribed to any topics or assigned any partitions
|
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1171) ~[kafka-clients-3.6.0.jar:?] |
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1159) ~[kafka-clients-3.6.0.jar:?] |
at com.couchbase.analytics.adapter.TopicRecordReader.dataPoll(TopicRecordReader.java:365) [columnar-connector.jar:1.0.0-2172] |
at com.couchbase.analytics.adapter.TopicRecordReader$KafkaTopicDataPoller.run(TopicRecordReader.java:393) [columnar-connector.jar:1.0.0-2172] |
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] |
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] |
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] |
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] |
at java.base/java.lang.Thread.run(Thread.java:840) [?:?] |
2024-06-25T07:00:08.960+00:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.2825:TAID:TID:ANID:ODID:8:0:41:0:(Default.KafkaLinkvgbWGyPLsh.b-3-public.qekafkatestcluster.7b9vtv.c13.kafka.us-east-1.amazonaws.com:9196,b-2-public.qekafkatestcluster.7b9vtv.c13.kafka.us-east-1.amazonaws.com:9196,b-1-public.qekafkatestcluster.7b9vtv.c13.kafka.us-east-1.amazonaws.com:9196(CB))[41]:TO] controller is being set from CREATED to STARTED |
2024-06-25T07:00:08.960+00:00 INFO CBAS.adapter.TopicRecordReader [Executor-10890:f21c19c32f7c6e1642ddee41b4702e0a] Data Polling started... |
2024-06-25T07:00:08.960+00:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.2825:TAID:TID:ANID:ODID:8:0:39:0:(Default.KafkaLinkvgbWGyPLsh.b-3-public.qekafkatestcluster.7b9vtv.c13.kafka.us-east-1.amazonaws.com:9196,b-2-public.qekafkatestcluster.7b9vtv.c13.kafka.us-east-1.amazonaws.com:9196,b-1-public.qekafkatestcluster.7b9vtv.c13.kafka.us-east-1.amazonaws.com:9196(CB))[39]:TO] controller is being set from CREATED to STARTED |
2024-06-25T07:00:08.960+00:00 INFO CBAS.adapter.TopicRecordReader [Executor-10890:f21c19c32f7c6e1642ddee41b4702e0a] Error while polling data from Kafka |
java.lang.IllegalStateException: Consumer is not subscribed to any topics or assigned any partitions
|
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1171) ~[kafka-clients-3.6.0.jar:?] |
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1159) ~[kafka-clients-3.6.0.jar:?] |
at com.couchbase.analytics.adapter.TopicRecordReader.dataPoll(TopicRecordReader.java:365) [columnar-connector.jar:1.0.0-2172] |
at com.couchbase.analytics.adapter.TopicRecordReader$KafkaTopicDataPoller.run(TopicRecordReader.java:393) [columnar-connector.jar:1.0.0-2172] |
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] |
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] |
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] |
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] |
at java.base/java.lang.Thread.run(Thread.java:840) [?:?] |
cbcollect ->
https://cb-engineering.s3.amazonaws.com/SysTestColumnarJun24/collectinfo-2024-06-25T070705-ns_1%40svc-da-node-001.nxp9u2dolhjxwjtf.sandbox.nonprod-project-avengers.com.zip
https://cb-engineering.s3.amazonaws.com/SysTestColumnarJun24/collectinfo-2024-06-25T070705-ns_1%40svc-da-node-002.nxp9u2dolhjxwjtf.sandbox.nonprod-project-avengers.com.zip
https://cb-engineering.s3.amazonaws.com/SysTestColumnarJun24/collectinfo-2024-06-25T070705-ns_1%40svc-da-node-003.nxp9u2dolhjxwjtf.sandbox.nonprod-project-avengers.com.zip
https://cb-engineering.s3.amazonaws.com/SysTestColumnarJun24/collectinfo-2024-06-25T070705-ns_1%40svc-da-node-004.nxp9u2dolhjxwjtf.sandbox.nonprod-project-avengers.com.zip
It's a 4-node cluster (16 VCPUs + 64 GB).