sleepy0521 created FLINK-37809:
----------------------------------
Summary: sqlserver limit statement support
Key: FLINK-37809
URL: https://issues.apache.org/jira/browse/FLINK-37809
Project: Flink
Issue Type: Improvement
Components: Table SQL / JDBC
Affects Versions: 1.20.1, 1.19.2, 1.18.1
Reporter: sleepy0521
* The problem occurs when you use the SQL Server JDBC connector to query a SQL
Server table. If you don't add a LIMIT statement or any WHERE clause, the Flink
connector will query the entire table, which can impose IO pressure on the SQL
Server.
* For simple queries or tests where you only need to retrieve a few hundred
records, using the LIMIT statement would be more efficient. However, Flink
sqlserver connector does not support this feature. SqlServerDialect.java
@Overridepublic String getLimitClause(long limit) { throw new
IllegalArgumentException("SqlServerDialect does not support limit clause");
}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
