[
https://issues.apache.org/jira/browse/FLINK-13595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002735#comment-17002735
]
Jiangjie Qin commented on FLINK-13595:
--------------------------------------
Two out of the three reported failures occurred in the cleanup stage due to the
timeout when closing the {{KafkaAdminClient}}. I am not sure if this is an
actual issue but for our testing purpose, closing the {{KafkaAdminClient}} with
a timeout should avoid the problem.
The logging information from the third case was too vague to debug.
I'll address the timeout problem and close the ticket. If there are further
occurrence, let's reopen the ticket.
> 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: Critical
> Labels: test-stability
> Fix For: 1.10.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
(v8.3.4#803005)
