[jira] [Created] (FLINK-21533) Kafka011ITCase#testAllDeletes fails on azure

[Shang Yuanchun (Jira)]

Dawid Wysakowicz created FLINK-21533:
----------------------------------------

             Summary: Kafka011ITCase#testAllDeletes fails on azure
                 Key: FLINK-21533
                 URL: https://issues.apache.org/jira/browse/FLINK-21533
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka, Tests
    Affects Versions: 1.11.3
            Reporter: Dawid Wysakowicz


https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13867&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=e4f347ab-2a29-5d7c-3685-b0fcd2b6b051

{code}
2021-02-26T22:27:56.9286925Z [ERROR] testAllDeletes(org.apache.flink.streaming.connectors.kafka.Kafka011ITCase)  Time elapsed: 3.228 s  <<< ERROR!
2021-02-26T22:27:56.9287994Z org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2021-02-26T22:27:56.9288805Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2021-02-26T22:27:56.9290091Z at org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:762)
2021-02-26T22:27:56.9290978Z at org.apache.flink.streaming.util.TestStreamEnvironment.execute(TestStreamEnvironment.java:77)
2021-02-26T22:27:56.9291926Z at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1651)
2021-02-26T22:27:56.9293538Z at org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runAllDeletesTest(KafkaConsumerTestBase.java:1649)
2021-02-26T22:27:56.9294944Z at org.apache.flink.streaming.connectors.kafka.Kafka011ITCase.testAllDeletes(Kafka011ITCase.java:130)
2021-02-26T22:27:56.9295702Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2021-02-26T22:27:56.9296370Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2021-02-26T22:27:56.9299360Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2021-02-26T22:27:56.9299955Z at java.lang.reflect.Method.invoke(Method.java:498)
2021-02-26T22:27:56.9300402Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2021-02-26T22:27:56.9300897Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2021-02-26T22:27:56.9301387Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2021-02-26T22:27:56.9301851Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2021-02-26T22:27:56.9302471Z at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:298)
2021-02-26T22:27:56.9325899Z at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:292)
2021-02-26T22:27:56.9327852Z at java.util.concurrent.FutureTask.run(FutureTask.java:266)
2021-02-26T22:27:56.9328934Z at java.lang.Thread.run(Thread.java:748)
2021-02-26T22:27:56.9329795Z Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
2021-02-26T22:27:56.9330778Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:118)
2021-02-26T22:27:56.9331904Z at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:80)
2021-02-26T22:27:56.9333126Z at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:206)
2021-02-26T22:27:56.9334090Z at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:197)
2021-02-26T22:27:56.9335043Z at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:189)
2021-02-26T22:27:56.9335946Z at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:639)
2021-02-26T22:27:56.9336834Z at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:397)
2021-02-26T22:27:56.9337698Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2021-02-26T22:27:56.9338398Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2021-02-26T22:27:56.9339236Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2021-02-26T22:27:56.9339949Z at java.lang.reflect.Method.invoke(Method.java:498)
2021-02-26T22:27:56.9340681Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:306)
2021-02-26T22:27:56.9341537Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213)
2021-02-26T22:27:56.9342486Z at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
2021-02-26T22:27:56.9343296Z at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:159)
2021-02-26T22:27:56.9343979Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
2021-02-26T22:27:56.9344865Z at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
2021-02-26T22:27:56.9345514Z at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2021-02-26T22:27:56.9346166Z at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2021-02-26T22:27:56.9346796Z at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
2021-02-26T22:27:56.9347604Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2021-02-26T22:27:56.9348550Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2021-02-26T22:27:56.9349242Z at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2021-02-26T22:27:56.9349974Z at akka.actor.Actor.aroundReceive(Actor.scala:517)
2021-02-26T22:27:56.9350568Z at akka.actor.Actor.aroundReceive$(Actor.scala:515)
2021-02-26T22:27:56.9351332Z at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
2021-02-26T22:27:56.9351964Z at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
2021-02-26T22:27:56.9359019Z at akka.actor.ActorCell.invoke(ActorCell.scala:561)
2021-02-26T22:27:56.9359656Z at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
2021-02-26T22:27:56.9360265Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
2021-02-26T22:27:56.9360816Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
2021-02-26T22:27:56.9361396Z at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
2021-02-26T22:27:56.9362089Z at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
2021-02-26T22:27:56.9363015Z at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
2021-02-26T22:27:56.9363736Z at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2021-02-26T22:27:56.9365991Z Caused by: java.util.concurrent.ExecutionException: org.apache.flink.streaming.connectors.kafka.FlinkKafka011Exception: Failed to send data to Kafka: Failed to send data to Kafka: This server does not host this topic-partition.
2021-02-26T22:27:56.9367302Z at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2021-02-26T22:27:56.9368054Z at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2021-02-26T22:27:56.9368990Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:172)
2021-02-26T22:27:56.9370039Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:135)
2021-02-26T22:27:56.9370950Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:139)
2021-02-26T22:27:56.9371841Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:81)
2021-02-26T22:27:56.9372870Z at org.apache.flink.streaming.runtime.tasks.OperatorChain.closeOperators(OperatorChain.java:320)
2021-02-26T22:27:56.9373706Z at org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:618)
2021-02-26T22:27:56.9374500Z at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:582)
2021-02-26T22:27:56.9375229Z at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:752)
2021-02-26T22:27:56.9375885Z at org.apache.flink.runtime.taskmanager.Task.run(Task.java:569)
2021-02-26T22:27:56.9376459Z at java.lang.Thread.run(Thread.java:748)
2021-02-26T22:27:56.9378382Z Caused by: org.apache.flink.streaming.connectors.kafka.FlinkKafka011Exception: Failed to send data to Kafka: Failed to send data to Kafka: This server does not host this topic-partition.
2021-02-26T22:27:56.9379502Z at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.checkErroneous(FlinkKafkaProducer011.java:1083)
2021-02-26T22:27:56.9380419Z at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.close(FlinkKafkaProducer011.java:709)
2021-02-26T22:27:56.9381275Z at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41)
2021-02-26T22:27:56.9382176Z at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:109)
2021-02-26T22:27:56.9383588Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$closeOperator$5(StreamOperatorWrapper.java:217)
2021-02-26T22:27:56.9384625Z at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93)
2021-02-26T22:27:56.9385692Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.closeOperator(StreamOperatorWrapper.java:214)
2021-02-26T22:27:56.9386916Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$deferCloseOperatorToMailbox$3(StreamOperatorWrapper.java:189)
2021-02-26T22:27:56.9388194Z at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93)
2021-02-26T22:27:56.9389154Z at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
2021-02-26T22:27:56.9389993Z at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.tryYield(MailboxExecutorImpl.java:96)
2021-02-26T22:27:56.9390987Z at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:166)
2021-02-26T22:27:56.9391688Z ... 9 more
2021-02-26T22:27:56.9393234Z Caused by: org.apache.flink.streaming.connectors.kafka.FlinkKafka011Exception: Failed to send data to Kafka: This server does not host this topic-partition.
2021-02-26T22:27:56.9394354Z at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.checkErroneous(FlinkKafkaProducer011.java:1083)
2021-02-26T22:27:56.9395313Z at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.flush(FlinkKafkaProducer011.java:817)
2021-02-26T22:27:56.9396226Z at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.close(FlinkKafkaProducer011.java:680)
2021-02-26T22:27:56.9396859Z ... 19 more
2021-02-26T22:27:56.9398151Z Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)