[
https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106050#comment-17106050
]
Robert Metzger commented on FLINK-12030:
----------------------------------------
Same exception, different test:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=1121&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=684b1416-4c17-504e-d5ab-97ee44e08a20
{code}
2020-05-12T19:15:16.8004940Z [ERROR] Failures:
2020-05-12T19:15:16.8006368Z [ERROR]
KafkaProducerExactlyOnceITCase.testMultipleSinkOperators:55->KafkaProducerTestBase.testExactlyOnce:370
Test failed: Job execution failed.
2020-05-12T19:08:06.8513168Z 19:08:06,850 [ Time-limited test] INFO
org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Writing
attempt #1
2020-05-12T19:08:06.8513971Z 19:08:06,850 [ Time-limited test] INFO
org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl [] -
Creating topic testEndOfStream-1
2020-05-12T19:08:06.8761388Z 19:08:06,875 [ Time-limited test] WARN
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Property
[transaction.timeout.ms] not specified. Setting it to 3600000 ms
2020-05-12T19:08:06.8987875Z 19:08:06,896 [Source: Custom Source -> Sink:
Unnamed (1/1)] WARN
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Using
AT_LEAST_ONCE semantic, but checkpointing is not enabled. Switching to NONE
semantic.
2020-05-12T19:08:06.8998360Z 19:08:06,899 [Source: Custom Source -> Sink:
Unnamed (1/1)] INFO
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Starting
FlinkKafkaInternalProducer (1/1) to produce into default topic testEndOfStream-1
2020-05-12T19:08:07.0247487Z 19:08:07,019 [ Time-limited test] ERROR
org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Write attempt
failed, trying again
2020-05-12T19:08:07.0248442Z
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2020-05-12T19:08:07.0250051Z at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0251647Z at
org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:659)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0253275Z at
org.apache.flink.streaming.util.TestStreamEnvironment.execute(TestStreamEnvironment.java:81)
~[flink-test-utils_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0255042Z at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1645)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0257769Z at
org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.writeSequence(KafkaConsumerTestBase.java:1994)
[flink-connector-kafka-base_2.11-1.11-SNAPSHOT-tests.jar:?]
2020-05-12T19:08:07.0259661Z at
org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runEndOfStreamTest(KafkaConsumerTestBase.java:1517)
[flink-connector-kafka-base_2.11-1.11-SNAPSHOT-tests.jar:?]
2020-05-12T19:08:07.0261292Z at
org.apache.flink.streaming.connectors.kafka.KafkaITCase.testMetricsAndEndOfStream(KafkaITCase.java:141)
[test-classes/:?]
2020-05-12T19:08:07.0262096Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_242]
2020-05-12T19:08:07.0262851Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_242]
2020-05-12T19:08:07.0263723Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_242]
2020-05-12T19:08:07.0264508Z at
java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242]
2020-05-12T19:08:07.0265652Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
[junit-4.12.jar:4.12]
2020-05-12T19:08:07.0267210Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
[junit-4.12.jar:4.12]
2020-05-12T19:08:07.0268544Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
[junit-4.12.jar:4.12]
2020-05-12T19:08:07.0269775Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
[junit-4.12.jar:4.12]
2020-05-12T19:08:07.0271042Z at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:298)
[junit-4.12.jar:4.12]
2020-05-12T19:08:07.0272388Z at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:292)
[junit-4.12.jar:4.12]
2020-05-12T19:08:07.0273203Z at
java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_242]
2020-05-12T19:08:07.0273823Z at java.lang.Thread.run(Thread.java:748)
[?:1.8.0_242]
2020-05-12T19:08:07.0274505Z Caused by: org.apache.flink.runtime.JobException:
Recovery is suppressed by NoRestartBackoffTimeStrategy
2020-05-12T19:08:07.0276095Z at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:112)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0278249Z at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:78)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0279962Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:189)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0281576Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:183)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0283556Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:177)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0285401Z at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:497)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0287227Z at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:384)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0288103Z at
sun.reflect.GeneratedMethodAccessor25.invoke(Unknown Source) ~[?:?]
2020-05-12T19:08:07.0288831Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_242]
2020-05-12T19:08:07.0289538Z at
java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242]
2020-05-12T19:08:07.0290912Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:284)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0292717Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:199)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0294302Z at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0295831Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0297425Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0298638Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0299842Z at
scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
~[scala-library-2.11.12.jar:?]
2020-05-12T19:08:07.0301079Z at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0302318Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
~[scala-library-2.11.12.jar:?]
2020-05-12T19:08:07.0303535Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[scala-library-2.11.12.jar:?]
2020-05-12T19:08:07.0304733Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[scala-library-2.11.12.jar:?]
2020-05-12T19:08:07.0305961Z at
akka.actor.Actor$class.aroundReceive(Actor.scala:517)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0307394Z at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0308628Z at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0309767Z at
akka.actor.ActorCell.invoke(ActorCell.scala:561)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0310939Z at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0312127Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0313463Z at
akka.dispatch.Mailbox.exec(Mailbox.scala:235)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0314815Z at
akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0316247Z at
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0317742Z at
akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0319297Z at
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
~[akka-actor_2.11-2.5.21.jar:2.5.21]
2020-05-12T19:08:07.0321225Z Caused by:
java.util.concurrent.ExecutionException:
org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Failed to send
data to Kafka: Failed to send data to Kafka: This server does not host this
topic-partition.
2020-05-12T19:08:07.0322367Z at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
~[?:1.8.0_242]
2020-05-12T19:08:07.0323427Z at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
~[?:1.8.0_242]
2020-05-12T19:08:07.0325246Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:144)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0327515Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:113)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0328743Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:117)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0329762Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:78)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0330991Z at
org.apache.flink.streaming.runtime.tasks.OperatorChain.closeOperators(OperatorChain.java:300)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0332025Z at
org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:553)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0332952Z at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:532)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0333799Z at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:713)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0334610Z at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:539)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0335043Z ... 1 more
2020-05-12T19:08:07.0335779Z Caused by:
org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Failed to send
data to Kafka: Failed to send data to Kafka: This server does not host this
topic-partition.
2020-05-12T19:08:07.0336481Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.checkErroneous(FlinkKafkaProducer.java:1224)
~[classes/:?]
2020-05-12T19:08:07.0337417Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.close(FlinkKafkaProducer.java:865)
~[classes/:?]
2020-05-12T19:08:07.0338279Z at
org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
~[flink-core-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0339308Z at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:109)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0340601Z at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0341733Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.closeOperator(StreamOperatorWrapper.java:186)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0342826Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$deferCloseOperatorToMailbox$3(StreamOperatorWrapper.java:160)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0343978Z at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0345062Z at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:78)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0346241Z at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.tryYield(MailboxExecutorImpl.java:79)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0347602Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:138)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0348685Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:113)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0349687Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:117)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0350657Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:78)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0351648Z at
org.apache.flink.streaming.runtime.tasks.OperatorChain.closeOperators(OperatorChain.java:300)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0352733Z at
org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:553)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0353635Z at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:532)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0354484Z at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:713)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0355355Z at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:539)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0355721Z ... 1 more
2020-05-12T19:08:07.0356380Z Caused by:
org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Failed to send
data to Kafka: This server does not host this topic-partition.
2020-05-12T19:08:07.0357181Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.checkErroneous(FlinkKafkaProducer.java:1224)
~[classes/:?]
2020-05-12T19:08:07.0357769Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.flush(FlinkKafkaProducer.java:977)
~[classes/:?]
2020-05-12T19:08:07.0358327Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.close(FlinkKafkaProducer.java:838)
~[classes/:?]
2020-05-12T19:08:07.0359163Z at
org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
~[flink-core-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0360140Z at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:109)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0361252Z at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0362367Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.closeOperator(StreamOperatorWrapper.java:186)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0363468Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$deferCloseOperatorToMailbox$3(StreamOperatorWrapper.java:160)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0364675Z at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0365699Z at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:78)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0366652Z at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.tryYield(MailboxExecutorImpl.java:79)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0378098Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:138)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0379166Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:113)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0380169Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:117)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0381140Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:78)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0382124Z at
org.apache.flink.streaming.runtime.tasks.OperatorChain.closeOperators(OperatorChain.java:300)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0383075Z at
org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:553)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0384132Z at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:532)
~[flink-streaming-java_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0385049Z at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:713)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0385853Z at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:539)
~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
2020-05-12T19:08:07.0386222Z ... 1 more
2020-05-12T19:08:07.0386948Z Caused by:
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
{code}
> KafkaITCase.testMultipleSourcesOnePartition is unstable
> -------------------------------------------------------
>
> Key: FLINK-12030
> URL: https://issues.apache.org/jira/browse/FLINK-12030
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Tests
> Reporter: Aljoscha Krettek
> Assignee: Jiangjie Qin
> Priority: Critical
> Labels: test-stability
> Fix For: 1.11.0
>
>
> This is a relevant part from the log:
> {code}
> 14:11:45,305 INFO org.apache.flink.streaming.connectors.kafka.KafkaITCase
> -
> ================================================================================
> Test
> testMetricsAndEndOfStream(org.apache.flink.streaming.connectors.kafka.KafkaITCase)
> is running.
> --------------------------------------------------------------------------------
> 14:11:45,310 INFO org.apache.flink.streaming.connectors.kafka.KafkaTestBase
> -
> ===================================
> == Writing sequence of 300 into testEndOfStream with p=1
> ===================================
> 14:11:45,311 INFO org.apache.flink.streaming.connectors.kafka.KafkaTestBase
> - Writing attempt #1
> 14:11:45,316 INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl -
> Creating topic testEndOfStream-1
> 14:11:45,863 WARN
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer - Property
> [transaction.timeout.ms] not specified. Setting it to 3600000 ms
> 14:11:45,910 WARN
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer - Using
> AT_LEAST_ONCE semantic, but checkpointing is not enabled. Switching to NONE
> semantic.
> 14:11:45,921 INFO
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer - Starting
> FlinkKafkaInternalProducer (1/1) to produce into default topic
> testEndOfStream-1
> 14:11:46,006 ERROR org.apache.flink.streaming.connectors.kafka.KafkaTestBase
> - Write attempt failed, trying again
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146)
> at
> org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:638)
> at
> org.apache.flink.streaming.util.TestStreamEnvironment.execute(TestStreamEnvironment.java:79)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.writeSequence(KafkaConsumerTestBase.java:1918)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runEndOfStreamTest(KafkaConsumerTestBase.java:1537)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaITCase.testMetricsAndEndOfStream(KafkaITCase.java:136)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:298)
> at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:292)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: org.apache.flink.streaming.connectors.kafka.FlinkKafkaException:
> Failed to send data to Kafka: This server does not host this topic-partition.
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.checkErroneous(FlinkKafkaProducer.java:1002)
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.flush(FlinkKafkaProducer.java:787)
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.close(FlinkKafkaProducer.java:658)
> at
> org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
> at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:109)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:443)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:318)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
> ... 1 more
> {code}
> Travis run: https://travis-ci.org/apache/flink/jobs/510953235
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
