[FLINK-13733] FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.9.0, 1.10.0, 1.11.0, 1.12.0
• Fix Version/s: 1.11.3, 1.12.0
• Component/s: Connectors / Kafka, Tests
• Labels: pull-request-available test-stability
• Assignee: Jiangjie Qin
• Reporter: Till Rohrmann
• Created: 15/Aug/19 06:46
• Updated: 11/Nov/20 06:00
• Resolved: 11/Nov/20 06:00

Description

The FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis with

Test testHappyPath(org.apache.flink.streaming.connectors.kafka.FlinkKafkaInternalProducerITCase) failed with:
java.util.NoSuchElementException
	at org.apache.kafka.common.utils.AbstractIterator.next(AbstractIterator.java:52)
	at org.apache.flink.shaded.guava18.com.google.common.collect.Iterators.getOnlyElement(Iterators.java:302)
	at org.apache.flink.shaded.guava18.com.google.common.collect.Iterables.getOnlyElement(Iterables.java:289)
	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaInternalProducerITCase.assertRecord(FlinkKafkaInternalProducerITCase.java:169)
	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaInternalProducerITCase.testHappyPath(FlinkKafkaInternalProducerITCase.java:70)
	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)

https://api.travis-ci.org/v3/job/571870358/log.txt

Issue Links

• is duplicated by: FLINK-17851 FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement
• links to: GitHub Pull Request #14021