Robin Moffatt created FLINK-33251: ------------------------------------- Summary: SQL Client query execution aborts after a few seconds: ConnectTimeoutException Key: FLINK-33251 URL: https://issues.apache.org/jira/browse/FLINK-33251 Project: Flink Issue Type: Bug Components: Table SQL / Client Affects Versions: 1.17.1, 1.18.0 Environment: Macbook Pro
Apple M1 Max {code:java} $ uname -a Darwin asgard08 23.0.0 Darwin Kernel Version 23.0.0: Fri Sep 15 14:41:43 PDT 2023; root:xnu-10002.1.13~1/RELEASE_ARM64_T6000 arm64 {code} Reporter: Robin Moffatt Attachments: log.zip If I run a streaming query from an unbounded connector from the SQL Client, it bombs out after ~15 seconds. {code:java} [ERROR] Could not execute SQL statement. Reason: org.apache.flink.shaded.netty4.io.netty.channel.ConnectTimeoutException: connection timed out: localhost/127.0.0.1:52596 {code} This *doesn't* happen on 1.16.2. It *does* happen on *1.17.1* and *1.18* that I have just built locally (git repo hash `9b837727b6d`). The corresponding task's status in the Web UI shows as `CANCELED`. --- h2. To reproduce Launch local cluster and SQL client {code} ➜ flink-1.18-SNAPSHOT ./bin/start-cluster.sh Starting cluster. Starting standalonesession daemon on host asgard08. Starting taskexecutor daemon on host asgard08. ➜ flink-1.18-SNAPSHOT ./bin/sql-client.sh […] Flink SQL> {code} Set streaming mode and result mode {code:sql} Flink SQL> SET 'execution.runtime-mode' = 'STREAMING'; [INFO] Execute statement succeed. Flink SQL> SET 'sql-client.execution.result-mode' = 'changelog'; [INFO] Execute statement succeed. {code} Define a table to read data from CSV files in a folder {code:sql} CREATE TABLE firewall ( event_time STRING, source_ip STRING, dest_ip STRING, source_prt INT, dest_prt INT ) WITH ( 'connector' = 'filesystem', 'path' = 'file:///tmp/firewall/', 'format' = 'csv', 'source.monitor-interval' = '1' -- unclear from the docs what the unit is here ); {code} Create a CSV file to read in {code:bash} $ mkdir /tmp/firewall $ cat > /tmp/firewall/data.csv <<EOF 2018-05-11 00:19:34,151.35.34.162,125.26.20.222,2014,68 2018-05-11 22:20:43,114.24.126.190,21.68.21.69,379,1619 EOF {code} Run a streaming query {code} SELECT * FROM firewall; {code} You will get results showing (and if you add another data file it will show up) - but after ~30 seconds the query aborts and throws an error back to the user at the SQL Client prompt {code} [ERROR] Could not execute SQL statement. Reason: org.apache.flink.shaded.netty4.io.netty.channel.ConnectTimeoutException: connection timed out: localhost/127.0.0.1:58470 Flink SQL> {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)