[jira] [Closed] (FLINK-13528) Kafka E2E tests fail on Java 11

["Chesnay Schepler (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-13528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chesnay Schepler closed FLINK-13528.
------------------------------------
    Resolution: Fixed

Tests disabled on master: d73e25b3f9db814a823cf9b425ca978651b1667f

> Kafka E2E tests fail on Java 11
> -------------------------------
>
>                 Key: FLINK-13528
>                 URL: https://issues.apache.org/jira/browse/FLINK-13528
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / Kafka, Tests
>            Reporter: Chesnay Schepler
>            Assignee: Chesnay Schepler
>            Priority: Major
>             Fix For: 1.10.0
>
>
> The kafka E2E tests fail on Java 11 with a timeout. Since kafka added support for Java 11 in 2.1.0 we may have to just disable them.
> {code}
> [2019-08-15 07:21:47,491] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)
> java.net.ConnectException: Connection refused
> 	at java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 	at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:779)
> 	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> 	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> Exception in thread "main" org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server 'localhost:2181' with timeout of 30000 ms
> 	at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1233)
> 	at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:157)
> 	at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:131)
> 	at kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:79)
> 	at kafka.utils.ZkUtils$.apply(ZkUtils.scala:61)
> 	at kafka.admin.TopicCommand$.main(TopicCommand.scala:53)
> 	at kafka.admin.TopicCommand.main(TopicCommand.scala)
> {code}



--
This message was sent by Atlassian Jira
(v8.3.2#803003)