[
https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136431#comment-17136431
]
Robert Metzger commented on FLINK-16908:
----------------------------------------
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=3554&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=684b1416-4c17-504e-d5ab-97ee44e08a20
{code}
2020-06-16T05:14:44.5620455Z 05:14:44,561 [ main] ERROR
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase [] -
2020-06-16T05:14:44.5621747Z
--------------------------------------------------------------------------------
2020-06-16T05:14:44.5622484Z Test
testScaleDownBeforeFirstCheckpoint(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
failed with:
2020-06-16T05:14:44.5623719Z java.lang.AssertionError: Detected producer leak.
Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:14:44.5624390Z at org.junit.Assert.fail(Assert.java:88)
2020-06-16T05:14:44.5625212Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675)
2020-06-16T05:14:44.5626117Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint(FlinkKafkaProducerITCase.java:370)
2020-06-16T05:14:44.5626859Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-06-16T05:14:44.5627410Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-06-16T05:14:44.5628088Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-16T05:14:44.5628695Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-16T05:14:44.5629281Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-06-16T05:14:44.5629953Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-06-16T05:14:44.5630614Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-06-16T05:14:44.5631352Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-06-16T05:14:44.5631984Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:14:44.5632575Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2020-06-16T05:14:44.5632941Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:14:44.5633277Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2020-06-16T05:14:44.5633681Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2020-06-16T05:14:44.5634120Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2020-06-16T05:14:44.5634657Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-16T05:14:44.5635091Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-16T05:14:44.5635473Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-16T05:14:44.5635866Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-16T05:14:44.5636241Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-16T05:14:44.5636666Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:14:44.5637099Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-06-16T05:14:44.5637504Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-16T05:14:44.5638018Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:14:44.5638359Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-16T05:14:44.5639032Z at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-06-16T05:14:44.5639488Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-06-16T05:14:44.5639970Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-06-16T05:14:44.5640436Z at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-06-16T05:14:44.5641091Z at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-06-16T05:14:44.5641659Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-06-16T05:14:44.5642102Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-06-16T05:14:44.5642531Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-06-16T05:14:44.5642775Z
2020-06-16T05:14:44.5643037Z
================================================================================
2020-06-16T05:14:44.5643981Z 05:14:44,561 [ main] INFO
org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] -
-------------------------------------------------------------------------
2020-06-16T05:14:44.5644958Z 05:14:44,561 [ main] INFO
org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Shut down
KafkaTestBase
2020-06-16T05:14:44.5645825Z 05:14:44,561 [ main] INFO
org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] -
-------------------------------------------------------------------------
2020-06-16T05:15:07.5979964Z 05:15:07,597 [ main] INFO
org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] -
-------------------------------------------------------------------------
2020-06-16T05:15:07.5981141Z 05:15:07,597 [ main] INFO
org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] -
KafkaTestBase finished
2020-06-16T05:15:07.5982051Z 05:15:07,597 [ main] INFO
org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] -
-------------------------------------------------------------------------
2020-06-16T05:15:07.6570482Z [ERROR] Tests run: 12, Failures: 7, Errors: 1,
Skipped: 0, Time elapsed: 264.871 s <<< FAILURE! - in
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase
2020-06-16T05:15:07.6571531Z [ERROR]
testFailAndRecoverSameCheckpointTwice(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
Time elapsed: 62.869 s <<< ERROR!
2020-06-16T05:15:07.6572166Z org.apache.kafka.common.errors.TimeoutException:
Timeout expired after 60000milliseconds while awaiting InitProducerId
2020-06-16T05:15:07.6572559Z
2020-06-16T05:15:07.6572979Z [ERROR]
testRestoreToCheckpointAfterExceedingProducersPool(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
Time elapsed: 4.426 s <<< FAILURE!
2020-06-16T05:15:07.6573960Z java.lang.AssertionError: Detected producer leak.
Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:07.6574765Z at org.junit.Assert.fail(Assert.java:88)
2020-06-16T05:15:07.6575328Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675)
2020-06-16T05:15:07.6576137Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool(FlinkKafkaProducerITCase.java:163)
2020-06-16T05:15:07.6576662Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-06-16T05:15:07.6577053Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-06-16T05:15:07.6577531Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-16T05:15:07.6577919Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-16T05:15:07.6578321Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-06-16T05:15:07.6579030Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-06-16T05:15:07.6579528Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-06-16T05:15:07.6579989Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-06-16T05:15:07.6580464Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6581147Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2020-06-16T05:15:07.6581510Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6581859Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2020-06-16T05:15:07.6582275Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2020-06-16T05:15:07.6582797Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2020-06-16T05:15:07.6583214Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-16T05:15:07.6583575Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-16T05:15:07.6583969Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-16T05:15:07.6584359Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-16T05:15:07.6584934Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-16T05:15:07.6585355Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6585779Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-06-16T05:15:07.6586202Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-16T05:15:07.6586560Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6586924Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-16T05:15:07.6587337Z at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-06-16T05:15:07.6587793Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-06-16T05:15:07.6588283Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-06-16T05:15:07.6588726Z at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-06-16T05:15:07.6589224Z at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-06-16T05:15:07.6589736Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-06-16T05:15:07.6590172Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-06-16T05:15:07.6590625Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-06-16T05:15:07.6590942Z
2020-06-16T05:15:07.6591367Z [ERROR]
testMigrateFromAtExactlyOnceToAtLeastOnce(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
Time elapsed: 2.08 s <<< FAILURE!
2020-06-16T05:15:07.6592476Z java.lang.AssertionError: Detected producer leak.
Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:07.6592939Z at org.junit.Assert.fail(Assert.java:88)
2020-06-16T05:15:07.6593370Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675)
2020-06-16T05:15:07.6593998Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testRecoverWithChangeSemantics(FlinkKafkaProducerITCase.java:581)
2020-06-16T05:15:07.6594850Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce(FlinkKafkaProducerITCase.java:550)
2020-06-16T05:15:07.6595561Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-06-16T05:15:07.6595995Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-06-16T05:15:07.6596671Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-16T05:15:07.6597131Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-16T05:15:07.6597658Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-06-16T05:15:07.6598118Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-06-16T05:15:07.6598559Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-06-16T05:15:07.6599106Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-06-16T05:15:07.6599558Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6599948Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2020-06-16T05:15:07.6600306Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6600650Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2020-06-16T05:15:07.6601169Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2020-06-16T05:15:07.6601602Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2020-06-16T05:15:07.6602015Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-16T05:15:07.6602467Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-16T05:15:07.6602842Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-16T05:15:07.6603237Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-16T05:15:07.6603606Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-16T05:15:07.6604023Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6604436Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-06-16T05:15:07.6605002Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-16T05:15:07.6605393Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6605732Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-16T05:15:07.6606142Z at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-06-16T05:15:07.6606597Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-06-16T05:15:07.6607082Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-06-16T05:15:07.6607552Z at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-06-16T05:15:07.6608021Z at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-06-16T05:15:07.6608524Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-06-16T05:15:07.6608965Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-06-16T05:15:07.6609407Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-06-16T05:15:07.6609648Z
2020-06-16T05:15:07.6610072Z [ERROR]
testMigrateFromAtLeastOnceToExactlyOnce(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
Time elapsed: 1.773 s <<< FAILURE!
2020-06-16T05:15:07.6611106Z java.lang.AssertionError: Detected producer leak.
Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:07.6611569Z at org.junit.Assert.fail(Assert.java:88)
2020-06-16T05:15:07.6612022Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675)
2020-06-16T05:15:07.6612696Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testRecoverWithChangeSemantics(FlinkKafkaProducerITCase.java:581)
2020-06-16T05:15:07.6613359Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce(FlinkKafkaProducerITCase.java:542)
2020-06-16T05:15:07.6613971Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-06-16T05:15:07.6614340Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-06-16T05:15:07.6614946Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-16T05:15:07.6615336Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-16T05:15:07.6615886Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-06-16T05:15:07.6616331Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-06-16T05:15:07.6616786Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-06-16T05:15:07.6617246Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-06-16T05:15:07.6617671Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6618085Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2020-06-16T05:15:07.6618429Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6618791Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2020-06-16T05:15:07.6619191Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2020-06-16T05:15:07.6619639Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2020-06-16T05:15:07.6620067Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-16T05:15:07.6620430Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-16T05:15:07.6620825Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-16T05:15:07.6621258Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-16T05:15:07.6621649Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-16T05:15:07.6622066Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6622576Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-06-16T05:15:07.6622995Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-16T05:15:07.6623354Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6623715Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-16T05:15:07.6624110Z at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-06-16T05:15:07.6624721Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-06-16T05:15:07.6625243Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-06-16T05:15:07.6625690Z at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-06-16T05:15:07.6626187Z at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-06-16T05:15:07.6626671Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-06-16T05:15:07.6627127Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-06-16T05:15:07.6627559Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-06-16T05:15:07.6627800Z
2020-06-16T05:15:07.6628185Z [ERROR]
testRecoverCommittedTransaction(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
Time elapsed: 3.307 s <<< FAILURE!
2020-06-16T05:15:07.6629145Z java.lang.AssertionError: Detected producer leak.
Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:07.6629600Z at org.junit.Assert.fail(Assert.java:88)
2020-06-16T05:15:07.6630030Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675)
2020-06-16T05:15:07.6630755Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testRecoverCommittedTransaction(FlinkKafkaProducerITCase.java:513)
2020-06-16T05:15:07.6631324Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-06-16T05:15:07.6631696Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-06-16T05:15:07.6632158Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-16T05:15:07.6632699Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-16T05:15:07.6633101Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-06-16T05:15:07.6633546Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-06-16T05:15:07.6634003Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-06-16T05:15:07.6634456Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-06-16T05:15:07.6634970Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6635374Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2020-06-16T05:15:07.6635717Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6636121Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2020-06-16T05:15:07.6636742Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2020-06-16T05:15:07.6637438Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2020-06-16T05:15:07.6637900Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-16T05:15:07.6638266Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-16T05:15:07.6638657Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-16T05:15:07.6639031Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-16T05:15:07.6639430Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-16T05:15:07.6639890Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6640368Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-06-16T05:15:07.6640788Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-16T05:15:07.6641216Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6641580Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-16T05:15:07.6641973Z at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-06-16T05:15:07.6642516Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-06-16T05:15:07.6643001Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-06-16T05:15:07.6643504Z at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-06-16T05:15:07.6644121Z at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-06-16T05:15:07.6644907Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-06-16T05:15:07.6645457Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-06-16T05:15:07.6645889Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-06-16T05:15:07.6646138Z
2020-06-16T05:15:07.6646508Z [ERROR]
resourceCleanUpNone(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
Time elapsed: 0.455 s <<< FAILURE!
2020-06-16T05:15:07.6647637Z java.lang.AssertionError: Detected producer leak.
Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:07.6648099Z at org.junit.Assert.fail(Assert.java:88)
2020-06-16T05:15:07.6648590Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675)
2020-06-16T05:15:07.6649333Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.resourceCleanUp(FlinkKafkaProducerITCase.java:115)
2020-06-16T05:15:07.6649912Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.resourceCleanUpNone(FlinkKafkaProducerITCase.java:82)
2020-06-16T05:15:07.6650375Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-06-16T05:15:07.6650828Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-06-16T05:15:07.6651337Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-16T05:15:07.6651738Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-16T05:15:07.6652122Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-06-16T05:15:07.6652671Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-06-16T05:15:07.6653138Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-06-16T05:15:07.6653574Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-06-16T05:15:07.6654020Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6654406Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2020-06-16T05:15:07.6654837Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6655188Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2020-06-16T05:15:07.6655604Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2020-06-16T05:15:07.6656053Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2020-06-16T05:15:07.6656445Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-16T05:15:07.6656827Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-16T05:15:07.6657204Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-16T05:15:07.6657598Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-16T05:15:07.6657983Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-16T05:15:07.6658381Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6658812Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-06-16T05:15:07.6659221Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-16T05:15:07.6659598Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6659935Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-16T05:15:07.6660341Z at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-06-16T05:15:07.6660809Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-06-16T05:15:07.6661341Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-06-16T05:15:07.6661810Z at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-06-16T05:15:07.6662281Z at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-06-16T05:15:07.6662855Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-06-16T05:15:07.6663315Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-06-16T05:15:07.6663731Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-06-16T05:15:07.6663969Z
2020-06-16T05:15:07.6664370Z [ERROR]
testRunOutOfProducersInThePool(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
Time elapsed: 1.946 s <<< FAILURE!
2020-06-16T05:15:07.6665360Z java.lang.AssertionError: Detected producer leak.
Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:07.6665895Z at org.junit.Assert.fail(Assert.java:88)
2020-06-16T05:15:07.6666342Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675)
2020-06-16T05:15:07.6666946Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testRunOutOfProducersInThePool(FlinkKafkaProducerITCase.java:536)
2020-06-16T05:15:07.6667528Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-06-16T05:15:07.6667910Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-06-16T05:15:07.6668351Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-16T05:15:07.6668757Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-16T05:15:07.6669138Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-06-16T05:15:07.6669605Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-06-16T05:15:07.6670070Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-06-16T05:15:07.6670504Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-06-16T05:15:07.6671015Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6671406Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2020-06-16T05:15:07.6671769Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6672116Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2020-06-16T05:15:07.6672600Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2020-06-16T05:15:07.6673049Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2020-06-16T05:15:07.6673440Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-16T05:15:07.6673824Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-16T05:15:07.6674198Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-16T05:15:07.6674663Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-16T05:15:07.6675057Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-16T05:15:07.6675455Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6675888Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-06-16T05:15:07.6676289Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-16T05:15:07.6676665Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6677006Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-16T05:15:07.6677414Z at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-06-16T05:15:07.6677888Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-06-16T05:15:07.6678353Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-06-16T05:15:07.6678825Z at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-06-16T05:15:07.6679293Z at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-06-16T05:15:07.6679806Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-06-16T05:15:07.6680257Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-06-16T05:15:07.6680674Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-06-16T05:15:07.6680971Z
2020-06-16T05:15:07.6681383Z [ERROR]
testScaleDownBeforeFirstCheckpoint(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
Time elapsed: 7.701 s <<< FAILURE!
2020-06-16T05:15:07.6682445Z java.lang.AssertionError: Detected producer leak.
Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:07.6682868Z at org.junit.Assert.fail(Assert.java:88)
2020-06-16T05:15:07.6683317Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675)
2020-06-16T05:15:07.6683928Z at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint(FlinkKafkaProducerITCase.java:370)
2020-06-16T05:15:07.6684603Z at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-06-16T05:15:07.6684985Z at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-06-16T05:15:07.6685424Z at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-06-16T05:15:07.6685829Z at
java.lang.reflect.Method.invoke(Method.java:498)
2020-06-16T05:15:07.6686216Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2020-06-16T05:15:07.6686674Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2020-06-16T05:15:07.6687134Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2020-06-16T05:15:07.6687568Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2020-06-16T05:15:07.6688016Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6688406Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2020-06-16T05:15:07.6688771Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6689116Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2020-06-16T05:15:07.6689531Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2020-06-16T05:15:07.6689981Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2020-06-16T05:15:07.6690379Z at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2020-06-16T05:15:07.6690760Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2020-06-16T05:15:07.6691214Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2020-06-16T05:15:07.6691820Z at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2020-06-16T05:15:07.6692278Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2020-06-16T05:15:07.6692765Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2020-06-16T05:15:07.6693196Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2020-06-16T05:15:07.6693602Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2020-06-16T05:15:07.6693983Z at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2020-06-16T05:15:07.6694319Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2020-06-16T05:15:07.6694803Z at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2020-06-16T05:15:07.6695272Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2020-06-16T05:15:07.6695737Z at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2020-06-16T05:15:07.6696206Z at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2020-06-16T05:15:07.6696675Z at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2020-06-16T05:15:07.6697191Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2020-06-16T05:15:07.6697651Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2020-06-16T05:15:07.6698063Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2020-06-16T05:15:07.6698301Z
2020-06-16T05:15:08.2049387Z [INFO]
2020-06-16T05:15:08.2049984Z [INFO] Results:
2020-06-16T05:15:08.2050195Z [INFO]
2020-06-16T05:15:08.2050377Z [ERROR] Failures:
2020-06-16T05:15:08.2051943Z [ERROR]
FlinkKafkaProducerITCase.resourceCleanUpNone:82->resourceCleanUp:115->checkProducerLeak:675
Detected producer leak. Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:08.2053472Z [ERROR]
FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce:550->testRecoverWithChangeSemantics:581->checkProducerLeak:675
Detected producer leak. Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:08.2055333Z [ERROR]
FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce:542->testRecoverWithChangeSemantics:581->checkProducerLeak:675
Detected producer leak. Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:08.2056797Z [ERROR]
FlinkKafkaProducerITCase.testRecoverCommittedTransaction:513->checkProducerLeak:675
Detected producer leak. Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:08.2058252Z [ERROR]
FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool:163->checkProducerLeak:675
Detected producer leak. Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:08.2059647Z [ERROR]
FlinkKafkaProducerITCase.testRunOutOfProducersInThePool:536->checkProducerLeak:675
Detected producer leak. Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:08.2060965Z [ERROR]
FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint:370->checkProducerLeak:675
Detected producer leak. Thread name: kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-2
2020-06-16T05:15:08.2061551Z [ERROR] Errors:
2020-06-16T05:15:08.2062059Z [ERROR]
FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice » Timeout
Timeo...
{code}
> FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while
> initializing transactional state in 60000ms.
> -----------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-16908
> URL: https://issues.apache.org/jira/browse/FLINK-16908
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.11.0
> Reporter: Piotr Nowojski
> Priority: Major
> Labels: test-stability
>
> https://dev.azure.com/rmetzger/Flink/_build/results?buildId=6889&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=f66652e3-384e-5b25-be29-abfea69ea8da
> {noformat}
> [ERROR]
> testScaleUpAfterScalingDown(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
> Time elapsed: 64.353 s <<< ERROR!
> org.apache.kafka.common.errors.TimeoutException: Timeout expired while
> initializing transactional state in 60000ms.
> {noformat}
> After this initial error many other tests (I think all following unit tests)
> failed with errors like:
> {noformat}
> [ERROR]
> testFailAndRecoverSameCheckpointTwice(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
> Time elapsed: 7.895 s <<< FAILURE!
> java.lang.AssertionError: Detected producer leak. Thread name:
> kafka-producer-network-thread | producer-196
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675)
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice(FlinkKafkaProducerITCase.java:311)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
