[
https://issues.apache.org/jira/browse/FLINK-25449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-25449:
----------------------------
Description:
{code:java}
Dec 25 00:51:07 at akka.dispatch.Mailbox.run(Mailbox.scala:225)
Dec 25 00:51:07 at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
Dec 25 00:51:07 ... 4 more
Dec 25 00:51:07 Caused by: java.lang.RuntimeException: One or more fetchers
have encountered exception
Dec 25 00:51:07 at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:223)
Dec 25 00:51:07 at
org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:154)
Dec 25 00:51:07 at
org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:116)
Dec 25 00:51:07 at
org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:305)
Dec 25 00:51:07 at
org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:69)
Dec 25 00:51:07 at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:66)
Dec 25 00:51:07 at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:423)
Dec 25 00:51:07 at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:204)
Dec 25 00:51:07 at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
Dec 25 00:51:07 at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
Dec 25 00:51:07 at
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
Dec 25 00:51:07 at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
Dec 25 00:51:07 at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
Dec 25 00:51:07 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
Dec 25 00:51:07 at java.lang.Thread.run(Thread.java:748)
Dec 25 00:51:07 Caused by: java.lang.RuntimeException: SplitFetcher thread 0
received unexpected exception while polling the records
Dec 25 00:51:07 at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:148)
Dec 25 00:51:07 at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:103)
Dec 25 00:51:07 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
Dec 25 00:51:07 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
Dec 25 00:51:07 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
Dec 25 00:51:07 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
Dec 25 00:51:07 ... 1 more
Dec 25 00:51:07 Caused by: java.lang.IllegalStateException: Consumer is not
subscribed to any topics or assigned any partitions
Dec 25 00:51:07 at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1223)
Dec 25 00:51:07 at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211)
Dec 25 00:51:07 at
org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.fetch(KafkaPartitionSplitReader.java:108)
Dec 25 00:51:07 at
org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:56)
Dec 25 00:51:07 at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:140)
Dec 25 00:51:07 ... 6 more
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28589&view=logs&j=1fc6e7bf-633c-5081-c32a-9dea24b05730&t=80a658d1-f7f6-5d93-2758-53ac19fd5b19&l=6612
was:
{code:java}
Dec 25 00:51:07 [ERROR] Tests run: 5, Failures: 1, Errors: 1, Skipped: 0, Time
elapsed: 88.463 s <<< FAILURE! - in
org.apache.flink.connector.kafka.source.KafkaSourceITCase
Dec 25 00:51:07 [ERROR]
testRedundantParallelism(org.apache.flink.connector.kafka.source.KafkaSourceITCase)
Time elapsed: 4.188 s <<< ERROR!
Dec 25 00:51:07 org.apache.flink.runtime.client.JobExecutionException: Job
execution failed.
Dec 25 00:51:07 at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
Dec 25 00:51:07 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
Dec 25 00:51:07 at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
Dec 25 00:51:07 at
org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081)
Dec 25 00:51:07 at akka.dispatch.OnComplete.internal(Future.scala:264)
Dec 25 00:51:07 at akka.dispatch.OnComplete.internal(Future.scala:261)
Dec 25 00:51:07 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
Dec 25 00:51:07 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
Dec 25 00:51:07 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
Dec 25 00:51:07 at
org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73)
Dec 25 00:51:07 at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
Dec 25 00:51:07 at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
Dec 25 00:51:07 at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)
Dec 25 00:51:07 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
Dec 25 00:51:07 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
Dec 25 00:51:07 at
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)
Dec 25 00:51:07 at
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)
Dec 25 00:51:07 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
Dec 25 00:51:07 at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
{code}
> KafkaSourceITCase.testRedundantParallelism failed on azure
> ----------------------------------------------------------
>
> Key: FLINK-25449
> URL: https://issues.apache.org/jira/browse/FLINK-25449
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.13.5
> Reporter: Yun Gao
> Priority: Major
> Labels: test-stability
>
> {code:java}
> Dec 25 00:51:07 at akka.dispatch.Mailbox.run(Mailbox.scala:225)
> Dec 25 00:51:07 at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
> Dec 25 00:51:07 ... 4 more
> Dec 25 00:51:07 Caused by: java.lang.RuntimeException: One or more fetchers
> have encountered exception
> Dec 25 00:51:07 at
> org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:223)
> Dec 25 00:51:07 at
> org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:154)
> Dec 25 00:51:07 at
> org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:116)
> Dec 25 00:51:07 at
> org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:305)
> Dec 25 00:51:07 at
> org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:69)
> Dec 25 00:51:07 at
> org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:66)
> Dec 25 00:51:07 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:423)
> Dec 25 00:51:07 at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:204)
> Dec 25 00:51:07 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
> Dec 25 00:51:07 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
> Dec 25 00:51:07 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
> Dec 25 00:51:07 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
> Dec 25 00:51:07 at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
> Dec 25 00:51:07 at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
> Dec 25 00:51:07 at java.lang.Thread.run(Thread.java:748)
> Dec 25 00:51:07 Caused by: java.lang.RuntimeException: SplitFetcher thread 0
> received unexpected exception while polling the records
> Dec 25 00:51:07 at
> org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:148)
> Dec 25 00:51:07 at
> org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:103)
> Dec 25 00:51:07 at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> Dec 25 00:51:07 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> Dec 25 00:51:07 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> Dec 25 00:51:07 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> Dec 25 00:51:07 ... 1 more
> Dec 25 00:51:07 Caused by: java.lang.IllegalStateException: Consumer is not
> subscribed to any topics or assigned any partitions
> Dec 25 00:51:07 at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1223)
> Dec 25 00:51:07 at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211)
> Dec 25 00:51:07 at
> org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.fetch(KafkaPartitionSplitReader.java:108)
> Dec 25 00:51:07 at
> org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:56)
> Dec 25 00:51:07 at
> org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:140)
> Dec 25 00:51:07 ... 6 more
> {code}
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28589&view=logs&j=1fc6e7bf-633c-5081-c32a-9dea24b05730&t=80a658d1-f7f6-5d93-2758-53ac19fd5b19&l=6612
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
