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)
