[
https://issues.apache.org/jira/browse/FLINK-13595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900760#comment-16900760
]
Jiangjie Qin commented on FLINK-13595:
--------------------------------------
This issue is more of a Kafka issue than a Flink issue. It occurs after all the
testing logic has completed while cleaning the testing environment to delete
the Kafka testing topics. The delete took long to finish and cause the test to
fail.
I'll look into this issue and probably fix this on the Kafka side. Meanwhile,
we don't have to make this as a blocker for 1.9 release. Moving to critical
instead.
> KafkaITCase.testBigRecordJob fails on Travis
> --------------------------------------------
>
> Key: FLINK-13595
> URL: https://issues.apache.org/jira/browse/FLINK-13595
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Tests
> Affects Versions: 1.9.0
> Reporter: Till Rohrmann
> Assignee: Jiangjie Qin
> Priority: Blocker
> Labels: test-stability
> Fix For: 1.9.0
>
>
> The {{KafkaITCase.testBigRecordJob}} failed with a {{TestTimedOutException}}
> on Travis.
> {code}
> Test
> testBigRecordJob(org.apache.flink.streaming.connectors.kafka.KafkaITCase)
> failed with:
> org.junit.runners.model.TestTimedOutException: test timed out after 60000
> milliseconds
> at java.lang.Object.wait(Native Method)
> at java.lang.Thread.join(Thread.java:1252)
> at java.lang.Thread.join(Thread.java:1326)
> at
> org.apache.kafka.clients.admin.KafkaAdminClient.close(KafkaAdminClient.java:476)
> at org.apache.kafka.clients.admin.AdminClient.close(AdminClient.java:92)
> at org.apache.kafka.clients.admin.AdminClient.close(AdminClient.java:75)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.deleteTestTopic(KafkaTestEnvironmentImpl.java:153)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.deleteTestTopic(KafkaTestBase.java:204)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runBigRecordTestTopology(KafkaConsumerTestBase.java:1336)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaITCase.testBigRecordJob(KafkaITCase.java:121)
> 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)
> {code}
> https://api.travis-ci.org/v3/job/568176170/log.txt
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
