[
https://issues.apache.org/jira/browse/FLINK-15745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204010#comment-17204010
]
Robert Metzger commented on FLINK-15745:
----------------------------------------
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=7068&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=1fb1a56f-e8b5-5a82-00a0-a2db7757b4f5
{code}
2020-09-29T10:19:06.4701674Z 10:19:06,469 [Source: Custom Source -> Flat Map
(1/1)] INFO org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase
[] - Consumer subtask 0 will start reading the following 1 partitions from the
committed group offsets in Kafka: [KafkaTopicPartition{topic='keyvaluetest',
partition=0}]
2020-09-29T10:19:06.4704923Z 10:19:06,469 [Legacy Source Thread - Source:
Custom Source -> Flat Map (1/1)] INFO
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase [] -
Consumer subtask 0 creating fetcher with offsets
{KafkaTopicPartition{topic='keyvaluetest', partition=0}=-915623761773}.
2020-09-29T10:19:06.5098383Z
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2020-09-29T10:19:06.5099271Z at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
2020-09-29T10:19:06.5100054Z at
org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:677)
2020-09-29T10:19:06.5100918Z at
org.apache.flink.streaming.util.TestStreamEnvironment.execute(TestStreamEnvironment.java:81)
2020-09-29T10:19:06.5101654Z at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1706)
2020-09-29T10:19:06.5102223Z at
org.apache.flink.test.util.TestUtils.tryExecute(TestUtils.java:40)
2020-09-29T10:19:06.5102913Z at
org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runKeyValueTest(KafkaConsumerTestBase.java:1425)
2020-09-29T10:19:06.5103702Z at
org.apache.flink.streaming.connectors.kafka.KafkaITCase.testKeyValueSupport(KafkaITCase.java:78)
2020-09-29T10:19:06.5104200Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-09-29T10:19:06.5104618Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-09-29T10:19:06.5105091Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-09-29T10:19:06.5105529Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-09-29T10:19:06.5105963Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-09-29T10:19:06.5106436Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-09-29T10:19:06.5106921Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-09-29T10:19:06.5107405Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-09-29T10:19:06.5107891Z at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:298)
2020-09-29T10:19:06.5108442Z at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:292)
2020-09-29T10:19:06.5108985Z at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
2020-09-29T10:19:06.5109317Z at java.lang.Thread.run(Thread.java:748)
2020-09-29T10:19:06.5109731Z Caused by: org.apache.flink.runtime.JobException:
Recovery is suppressed by NoRestartBackoffTimeStrategy
2020-09-29T10:19:06.5110631Z at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:116)
2020-09-29T10:19:06.5111291Z at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:78)
2020-09-29T10:19:06.5111912Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:217)
2020-09-29T10:19:06.5112552Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:210)
2020-09-29T10:19:06.5113230Z at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:204)
2020-09-29T10:19:06.5113803Z at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:527)
2020-09-29T10:19:06.5114331Z at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:421)
2020-09-29T10:19:06.5114766Z at
sun.reflect.GeneratedMethodAccessor24.invoke(Unknown Source)
2020-09-29T10:19:06.5115178Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-09-29T10:19:06.5115617Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-09-29T10:19:06.5116035Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:284)
2020-09-29T10:19:06.5116554Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:199)
2020-09-29T10:19:06.5117083Z at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
2020-09-29T10:19:06.5117612Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
2020-09-29T10:19:06.5118042Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
2020-09-29T10:19:06.5118447Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
2020-09-29T10:19:06.5118901Z at
scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
2020-09-29T10:19:06.5119334Z at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
2020-09-29T10:19:06.5119773Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
2020-09-29T10:19:06.5120228Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2020-09-29T10:19:06.5120655Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2020-09-29T10:19:06.5121058Z at
akka.actor.Actor$class.aroundReceive(Actor.scala:517)
2020-09-29T10:19:06.5121438Z at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
2020-09-29T10:19:06.5121847Z at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
2020-09-29T10:19:06.5122222Z at
akka.actor.ActorCell.invoke(ActorCell.scala:561)
2020-09-29T10:19:06.5122661Z at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
2020-09-29T10:19:06.5123029Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
2020-09-29T10:19:06.5123371Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
2020-09-29T10:19:06.5123736Z at
akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
2020-09-29T10:19:06.5124179Z at
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
2020-09-29T10:19:06.5124628Z at
akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
2020-09-29T10:19:06.5125059Z at
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2020-09-29T10:19:06.5125465Z Caused by: java.lang.AssertionError: Wrong value 33
2020-09-29T10:19:06.5125790Z at org.junit.Assert.fail(Assert.java:88)
2020-09-29T10:19:06.5126102Z at org.junit.Assert.assertTrue(Assert.java:41)
2020-09-29T10:19:06.5126567Z at
org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase$15.flatMap(KafkaConsumerTestBase.java:1411)
2020-09-29T10:19:06.5127154Z at
org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase$15.flatMap(KafkaConsumerTestBase.java:1406)
2020-09-29T10:19:06.5127687Z at
org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:50)
2020-09-29T10:19:06.5128314Z at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:71)
2020-09-29T10:19:06.5128933Z at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:46)
2020-09-29T10:19:06.5129467Z at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:26)
2020-09-29T10:19:06.5130036Z at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52)
2020-09-29T10:19:06.5130614Z at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30)
2020-09-29T10:19:06.5131150Z at
org.apache.flink.streaming.api.operators.StreamSourceContexts$NonTimestampContext.collect(StreamSourceContexts.java:104)
2020-09-29T10:19:06.5131796Z at
org.apache.flink.streaming.api.operators.StreamSourceContexts$NonTimestampContext.collectWithTimestamp(StreamSourceContexts.java:111)
2020-09-29T10:19:06.5132538Z at
org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.emitRecordsWithTimestamps(AbstractFetcher.java:352)
2020-09-29T10:19:06.5133149Z at
org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher.partitionConsumerRecordsHandler(KafkaFetcher.java:185)
2020-09-29T10:19:06.5133735Z at
org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher.runFetchLoop(KafkaFetcher.java:141)
2020-09-29T10:19:06.5134298Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.run(FlinkKafkaConsumerBase.java:755)
2020-09-29T10:19:06.5134801Z at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
2020-09-29T10:19:06.5135273Z at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
2020-09-29T10:19:06.5135820Z at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:213)
{code}
> KafkaITCase.testKeyValueSupport failure due to assertion error.
> ---------------------------------------------------------------
>
> Key: FLINK-15745
> URL: https://issues.apache.org/jira/browse/FLINK-15745
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Tests
> Affects Versions: 1.10.0
> Reporter: Jiangjie Qin
> Assignee: Jiangjie Qin
> Priority: Major
> Labels: test-stability
> Fix For: 1.12.0
>
>
> The failure cause was:
> {code:java}
> Caused by: java.lang.AssertionError: Wrong value 50
> at org.junit.Assert.fail(Assert.java:88)
> at org.junit.Assert.assertTrue(Assert.java:41)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase$15.flatMap(KafkaConsumerTestBase.java:1411)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase$15.flatMap(KafkaConsumerTestBase.java:1406)
> at
> org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:50)
> at
> org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:641)
> at
> org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:616)
> at
> org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:596)
> at
> org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:730)
> at
> org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:708)
> at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$NonTimestampContext.collect(StreamSourceContexts.java:104)
> at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$NonTimestampContext.collectWithTimestamp(StreamSourceContexts.java:111)
> at
> org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.emitRecordWithTimestamp(AbstractFetcher.java:398)
> at
> org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher.emitRecord(KafkaFetcher.java:185)
> at
> org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher.runFetchLoop(KafkaFetcher.java:150)
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.run(FlinkKafkaConsumerBase.java:715)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
> at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:196)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
