[
https://issues.apache.org/jira/browse/FLINK-19974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226233#comment-17226233
]
Robert Metzger commented on FLINK-19974:
----------------------------------------
In the attached log files, the {{zookeeper.out}} says:
{code}
[2020-11-04 11:59:41,521] INFO binding to port 0.0.0.0/0.0.0.0:2181
(org.apache.zookeeper.server.NIOServerCnxnFactory)
[2020-11-04 11:59:41,522] ERROR Unexpected exception, exiting abnormally
(org.apache.zookeeper.server.ZooKeeperServerMain)
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind0(Native Method)
at sun.nio.ch.Net.bind(Net.java:461)
at sun.nio.ch.Net.bind(Net.java:453)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:222)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:85)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:78)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.configure(NIOServerCnxnFactory.java:687)
at
org.apache.zookeeper.server.ZooKeeperServerMain.runFromConfig(ZooKeeperServerMain.java:143)
at
org.apache.zookeeper.server.ZooKeeperServerMain.initializeAndRun(ZooKeeperServerMain.java:106)
at
org.apache.zookeeper.server.ZooKeeperServerMain.main(ZooKeeperServerMain.java:64)
at
org.apache.zookeeper.server.quorum.QuorumPeerMain.initializeAndRun(QuorumPeerMain.java:128)
at
org.apache.zookeeper.server.quorum.QuorumPeerMain.main(QuorumPeerMain.java:82)
{code}
Zookeeper is still running from the {{PyFlink end-to-end test}}:
{code}
2020-11-04T11:52:27.9189075Z Nov 04 11:52:27 [PASS] 'PyFlink end-to-end test'
passed after 26 minutes and 22 seconds! Test exited with exit code 0.
2020-11-04T11:52:27.9189635Z Nov 04 11:52:27
2020-11-04T11:52:28.2266995Z Nov 04 11:52:28 No taskexecutor daemon (pid:
72141) is running anymore on fv-az668-178.
2020-11-04T11:52:28.4107336Z Nov 04 11:52:28 No standalonesession daemon to
stop on host fv-az668-178.
2020-11-04T11:52:29.0652923Z Nov 04 11:52:29 Deleted all files under
/home/vsts/work/1/s/flink-dist/target/flink-1.12-SNAPSHOT-bin/flink-1.12-SNAPSHOT/log/
2020-11-04T11:52:29.0795925Z Nov 04 11:52:29 Deleted
/home/vsts/work/1/s/flink-end-to-end-tests/test-scripts/temp-test-directory-04854976498
2020-11-04T11:52:29.0797725Z Nov 04 11:52:29 ##[group]Environment Information
2020-11-04T11:52:29.0798431Z Nov 04 11:52:29 Jps
2020-11-04T11:52:29.2079973Z Nov 04 11:52:29 95041 Kafka
2020-11-04T11:52:29.2285220Z Nov 04 11:52:29 94455 QuorumPeerMain
2020-11-04T11:52:29.2374681Z Nov 04 11:52:29 120263 Jps
2020-11-04T11:52:29.2411676Z Nov 04 11:52:29 Disk information
2020-11-04T11:52:29.2442325Z Nov 04 11:52:29 Filesystem Size Used Avail
Use% Mounted on
2020-11-04T11:52:29.2444296Z Nov 04 11:52:29 udev 3.7G 0 3.7G
0% /dev
2020-11-04T11:52:29.2445121Z Nov 04 11:52:29 tmpfs 729M 18M 712M
3% /run
2020-11-04T11:52:29.2445800Z Nov 04 11:52:29 /dev/sda1 90G 66G 25G
74% /
2020-11-04T11:52:29.2446330Z Nov 04 11:52:29 tmpfs 3.7G 8.2k 3.7G
1% /dev/shm
2020-11-04T11:52:29.2446781Z Nov 04 11:52:29 tmpfs 5.3M 0 5.3M
0% /run/lock
2020-11-04T11:52:29.2447218Z Nov 04 11:52:29 tmpfs 3.7G 0 3.7G
0% /sys/fs/cgroup
2020-11-04T11:52:29.2447652Z Nov 04 11:52:29 /dev/sda15 110M 3.8M 106M
4% /boot/efi
2020-11-04T11:52:29.2448048Z Nov 04 11:52:29 /dev/sdb1 15G 4.4G 9.6G
32% /mnt
2020-11-04T11:52:29.2448401Z Nov 04 11:52:29 Allocated ports
2020-11-04T11:52:29.2982104Z Nov 04 11:52:29 Active Internet connections (only
servers)
2020-11-04T11:52:29.2983531Z Nov 04 11:52:29 Proto Recv-Q Send-Q Local Address
Foreign Address State PID/Program name
2020-11-04T11:52:29.2984193Z Nov 04 11:52:29 tcp 0 0
127.0.0.1:45157 0.0.0.0:* LISTEN 1547/containerd
2020-11-04T11:52:29.2984844Z Nov 04 11:52:29 tcp 0 0 0.0.0.0:22
0.0.0.0:* LISTEN 1543/sshd
2020-11-04T11:52:29.2985510Z Nov 04 11:52:29 tcp6 0 0 :::39011
:::* LISTEN 94455/java
2020-11-04T11:52:29.2986450Z Nov 04 11:52:29 tcp6 0 0 :::9092
:::* LISTEN 95041/java
2020-11-04T11:52:29.2987149Z Nov 04 11:52:29 tcp6 0 0 :::2181
:::* LISTEN 94455/java
2020-11-04T11:52:29.2987793Z Nov 04 11:52:29 tcp6 0 0 :::22
:::* LISTEN 1543/sshd
2020-11-04T11:52:29.2988416Z Nov 04 11:52:29 tcp6 0 0 :::43579
:::* LISTEN 95041/java
2020-11-04T11:52:29.2989057Z Nov 04 11:52:29 udp 0 0 0.0.0.0:68
0.0.0.0:* 1112/dhclient
{code}
> SQLClientKafkaITCase.testKafka times out while creating topic
> -------------------------------------------------------------
>
> Key: FLINK-19974
> URL: https://issues.apache.org/jira/browse/FLINK-19974
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Table SQL / Client
> Affects Versions: 1.12.0
> Reporter: Robert Metzger
> Priority: Critical
> Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=8967&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=ff888d9b-cd34-53cc-d90f-3e446d355529
> {code}
> 2020-11-04T12:00:36.0501135Z Nov 04 12:00:36 [ERROR] Tests run: 1, Failures:
> 0, Errors: 1, Skipped: 0, Time elapsed: 57.959 s <<< FAILURE! - in
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase
> 2020-11-04T12:00:36.0538557Z Nov 04 12:00:36 [ERROR] testKafka[0:
> kafka-version:2.4.1
> kafka-sql-version:universal](org.apache.flink.tests.util.kafka.SQLClientKafkaITCase)
> Time elapsed: 57.949 s <<< ERROR!
> 2020-11-04T12:00:36.0539781Z Nov 04 12:00:36 java.io.IOException: Process
> failed due to timeout.
> 2020-11-04T12:00:36.0540659Z Nov 04 12:00:36 at
> org.apache.flink.tests.util.AutoClosableProcess$AutoClosableProcessBuilder.runBlocking(AutoClosableProcess.java:130)
> 2020-11-04T12:00:36.0548817Z Nov 04 12:00:36 at
> org.apache.flink.tests.util.AutoClosableProcess$AutoClosableProcessBuilder.runBlocking(AutoClosableProcess.java:108)
> 2020-11-04T12:00:36.0549582Z Nov 04 12:00:36 at
> org.apache.flink.tests.util.AutoClosableProcess.runBlocking(AutoClosableProcess.java:70)
> 2020-11-04T12:00:36.0550231Z Nov 04 12:00:36 at
> org.apache.flink.tests.util.kafka.LocalStandaloneKafkaResource.createTopic(LocalStandaloneKafkaResource.java:261)
> 2020-11-04T12:00:36.0550909Z Nov 04 12:00:36 at
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.testKafka(SQLClientKafkaITCase.java:136)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)