tanjialiang created FLINK-32252: ----------------------------------- Summary: SELECT COUNT(*) will return nothing when source no data return Key: FLINK-32252 URL: https://issues.apache.org/jira/browse/FLINK-32252 Project: Flink Issue Type: Bug Components: Table SQL / Planner Affects Versions: 1.16.1 Reporter: tanjialiang
mysql source {code:java} CREATE TABLE student( id int primary key auto_increment, name varchar(32), age int ); INSERT INTO student(name, age) VALUES ('tanjl',18),('jark',20),('mike',16),('rose',21);{code} Flink SQL {code:java} CREATE TABLE student ( `id` INT PRIMARY KEY, `name` STRING, `age` INT ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://localhost/test?serverTimezone=UTC', 'username' = 'root', 'password' = 'root', 'table-name' = 'student' ); SELECT count(*) FROM student WHERE age < 15;{code} flink will return nothing because jdbc connector push the filter down(after flink-connector-jdbc-3.1.0), which make source no data return. -- This message was sent by Atlassian Jira (v8.20.10#820010)