[
https://issues.apache.org/jira/browse/FLINK-13528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-13528:
-------------------------------------
Description:
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}
was:
The kafka 0.10/0.11 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}
> 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)
