[
https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133949#comment-17133949
]
Robert Metzger commented on FLINK-12030:
----------------------------------------
{code}
2020-06-11T22:22:31.4964111Z Test testKafkaDebeziumChangelogSource[legacy =
false, format =
csv](org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase) failed
with:
2020-06-11T22:22:31.4965146Z java.lang.Exception: Failed to write debezium data
to Kafka.
2020-06-11T22:22:31.4965971Z at
org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase.testKafkaDebeziumChangelogSource(KafkaTableITCase.java:83)
2020-06-11T22:22:31.4966755Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-06-11T22:22:31.4967404Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-06-11T22:22:31.4968255Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-11T22:22:31.4968920Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-11T22:22:31.4969606Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-06-11T22:22:31.4970360Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-06-11T22:22:31.4971261Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-06-11T22:22:31.4972012Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-06-11T22:22:31.4972736Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-11T22:22:31.4973440Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2020-06-11T22:22:31.4974035Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-11T22:22:31.4974856Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2020-06-11T22:22:31.4975531Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2020-06-11T22:22:31.4976286Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2020-06-11T22:22:31.4977310Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-11T22:22:31.4978082Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-11T22:22:31.4978744Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-11T22:22:31.4979373Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-11T22:22:31.4980033Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-11T22:22:31.4980658Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-11T22:22:31.4981368Z at
org.junit.runners.Suite.runChild(Suite.java:128)
2020-06-11T22:22:31.4981916Z at
org.junit.runners.Suite.runChild(Suite.java:27)
2020-06-11T22:22:31.4982487Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-11T22:22:31.4983113Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-11T22:22:31.4983714Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-11T22:22:31.4984326Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-11T22:22:31.4985118Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-11T22:22:31.4985789Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-11T22:22:31.4986460Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-06-11T22:22:31.4987159Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-11T22:22:31.4987957Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-11T22:22:31.4988691Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-11T22:22:31.4989058Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-11T22:22:31.4989459Z at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-06-11T22:22:31.4989941Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-06-11T22:22:31.4990438Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-06-11T22:22:31.4990894Z at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-06-11T22:22:31.4991499Z at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-06-11T22:22:31.4991995Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-06-11T22:22:31.4992507Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-06-11T22:22:31.4993036Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-06-11T22:22:31.4993474Z Caused by:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2020-06-11T22:22:31.4993937Z at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
2020-06-11T22:22:31.4994407Z at
org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:677)
2020-06-11T22:22:31.4995096Z at
org.apache.flink.streaming.util.TestStreamEnvironment.execute(TestStreamEnvironment.java:81)
2020-06-11T22:22:31.4995629Z at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1686)
2020-06-11T22:22:31.4996244Z at
org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase.testKafkaDebeziumChangelogSource(KafkaTableITCase.java:80)
2020-06-11T22:22:31.4996645Z ... 41 more
2020-06-11T22:22:31.4996968Z Caused by: org.apache.flink.runtime.JobException:
Recovery is suppressed by NoRestartBackoffTimeStrategy
2020-06-11T22:22:31.4997622Z at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:116)
2020-06-11T22:22:31.4998255Z at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:78)
2020-06-11T22:22:31.4999122Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:192)
2020-06-11T22:22:31.4999653Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:185)
2020-06-11T22:22:31.5000186Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:179)
2020-06-11T22:22:31.5000734Z at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:503)
2020-06-11T22:22:31.5001325Z at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:386)
2020-06-11T22:22:31.5001729Z at
sun.reflect.GeneratedMethodAccessor29.invoke(Unknown Source)
2020-06-11T22:22:31.5002131Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-11T22:22:31.5002525Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-11T22:22:31.5002946Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:284)
2020-06-11T22:22:31.5003400Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:199)
2020-06-11T22:22:31.5003906Z at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
2020-06-11T22:22:31.5004407Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
2020-06-11T22:22:31.5004970Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
2020-06-11T22:22:31.5005359Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
2020-06-11T22:22:31.5005725Z at
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2020-06-11T22:22:31.5006388Z at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2020-06-11T22:22:31.5006966Z at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
2020-06-11T22:22:31.5007366Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2020-06-11T22:22:31.5007858Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2020-06-11T22:22:31.5008248Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2020-06-11T22:22:31.5008613Z at
akka.actor.Actor.aroundReceive(Actor.scala:517)
2020-06-11T22:22:31.5008938Z at
akka.actor.Actor.aroundReceive$(Actor.scala:515)
2020-06-11T22:22:31.5009299Z at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
2020-06-11T22:22:31.5009679Z at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
2020-06-11T22:22:31.5010016Z at
akka.actor.ActorCell.invoke(ActorCell.scala:561)
2020-06-11T22:22:31.5010362Z at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
2020-06-11T22:22:31.5010694Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
2020-06-11T22:22:31.5011089Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
2020-06-11T22:22:31.5011438Z at
akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
2020-06-11T22:22:31.5011863Z at
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
2020-06-11T22:22:31.5012289Z at
akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
2020-06-11T22:22:31.5012702Z at
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2020-06-11T22:22:31.5014110Z 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-06-11T22:22:31.5014960Z at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2020-06-11T22:22:31.5015408Z at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2020-06-11T22:22:31.5015957Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:161)
2020-06-11T22:22:31.5016528Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:130)
2020-06-11T22:22:31.5017172Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:134)
2020-06-11T22:22:31.5017908Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:80)
2020-06-11T22:22:31.5018408Z at
org.apache.flink.streaming.runtime.tasks.OperatorChain.closeOperators(OperatorChain.java:302)
2020-06-11T22:22:31.5018889Z at
org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:567)
2020-06-11T22:22:31.5019334Z at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:538)
2020-06-11T22:22:31.5019759Z at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:720)
2020-06-11T22:22:31.5020140Z at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:545)
2020-06-11T22:22:31.5020445Z at java.lang.Thread.run(Thread.java:748)
2020-06-11T22:22:31.5021350Z 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-06-11T22:22:31.5022021Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.checkErroneous(FlinkKafkaProducer.java:1257)
2020-06-11T22:22:31.5022557Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.close(FlinkKafkaProducer.java:898)
2020-06-11T22:22:31.5023077Z at
org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
2020-06-11T22:22:31.5023591Z at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:109)
2020-06-11T22:22:31.5024175Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$closeOperator$5(StreamOperatorWrapper.java:205)
2020-06-11T22:22:31.5025085Z at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
2020-06-11T22:22:31.5025715Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.closeOperator(StreamOperatorWrapper.java:203)
2020-06-11T22:22:31.5026324Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$deferCloseOperatorToMailbox$3(StreamOperatorWrapper.java:177)
2020-06-11T22:22:31.5026999Z at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
2020-06-11T22:22:31.5027633Z at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:78)
2020-06-11T22:22:31.5028126Z at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.tryYield(MailboxExecutorImpl.java:91)
2020-06-11T22:22:31.5028718Z at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:155)
2020-06-11T22:22:31.5029108Z ... 9 more
2020-06-11T22:22:31.5029804Z Caused by:
org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Failed to send
data to Kafka: This server does not host this topic-partition.
2020-06-11T22:22:31.5030416Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.checkErroneous(FlinkKafkaProducer.java:1257)
2020-06-11T22:22:31.5030952Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.flush(FlinkKafkaProducer.java:1010)
2020-06-11T22:22:31.5031556Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.close(FlinkKafkaProducer.java:871)
2020-06-11T22:22:31.5031887Z ... 19 more
2020-06-11T22:22:31.5032465Z Caused by:
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=3343&view=logs&j=4be4ed2b-549a-533d-aa33-09e28e360cc8&t=f09203c9-1af8-53a6-da0c-2e60f5418512
> KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not
> host this topic-partition
> -------------------------------------------------------------------------------------------------------
>
> Key: FLINK-12030
> URL: https://issues.apache.org/jira/browse/FLINK-12030
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Tests
> Affects Versions: 1.11.0
> Reporter: Aljoscha Krettek
> Assignee: Jiangjie Qin
> Priority: Critical
> Labels: pull-request-available, 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)
