You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/06/20 02:44:17 UTC
[incubator-seatunnel] branch dev updated: Add include upper bound (<=) (#2033)
This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new d64c1fa31 Add include upper bound (<=) (#2033)
d64c1fa31 is described below
commit d64c1fa3116b5b57edc7cc91300573b20fc05ef6
Author: ic4y <83...@users.noreply.github.com>
AuthorDate: Mon Jun 20 10:44:13 2022 +0800
Add include upper bound (<=) (#2033)
---
.../main/java/org/apache/seatunnel/flink/jdbc/source/JdbcSource.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/source/JdbcSource.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/source/JdbcSource.java
index a8540f46a..c01e1e0ee 100644
--- a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/source/JdbcSource.java
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/source/JdbcSource.java
@@ -149,7 +149,7 @@ public class JdbcSource implements FlinkBatchSource {
JdbcParameterValuesProvider jdbcParameterValuesProvider =
initPartition(partitionColumn, connection, query);
builder.setParametersProvider(jdbcParameterValuesProvider);
- query = String.format("SELECT * FROM (%s) tt where " + partitionColumn + " >= ? AND " + partitionColumn + " < ?", query);
+ query = String.format("SELECT * FROM (%s) tt where " + partitionColumn + " >= ? AND " + partitionColumn + " <= ?", query);
}
builder.setDrivername(driverName).setDBUrl(dbUrl).setUsername(username)
.setPassword(password).setQuery(query).setFetchSize(fetchSize)