You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "sleepy0521 (Jira)" <ji...@apache.org> on 2025/05/16 02:30:00 UTC

[jira] [Created] (FLINK-37809) sqlserver limit statement support

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)