[ https://issues.apache.org/jira/browse/FLINK-24811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444259#comment-17444259 ]
Qingsheng Ren commented on FLINK-24811: --------------------------------------- [~arvid] This should have been fixed by FLINK-22702 on master and 1.14. Should we backport it to 1.12 & 1.13 as well? > KafkaSourceITCase#testRedundantParallelism and testBasicRead failed on azure > ---------------------------------------------------------------------------- > > Key: FLINK-24811 > URL: https://issues.apache.org/jira/browse/FLINK-24811 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Affects Versions: 1.12.5 > Reporter: Yun Gao > Priority: Major > Labels: test-stability > > {code:java} > at > org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:398) > at > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:191) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:622) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:586) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:758) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:573) > at java.base/java.lang.Thread.run(Thread.java:834) > Caused by: java.lang.RuntimeException: SplitFetcher thread 0 received > unexpected exception while polling the records > at > org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:146) > at > org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:101) > at > java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) > at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) > at > java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) > at > java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) > ... 1 more > Caused by: java.lang.IllegalStateException: Consumer is not subscribed to any > topics or assigned any partitions > at > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1223) > at > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211) > at > org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.fetch(KafkaPartitionSplitReader.java:97) > at > org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:56) > at > org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:138) > ... 6 more > {code} > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26068&view=logs&j=ce8f3cc3-c1ea-5281-f5eb-df9ebd24947f&t=f266c805-9429-58ed-2f9e-482e7b82f58b&l=6544 -- This message was sent by Atlassian Jira (v8.20.1#820001)