added limit statement to jdbc source timestamp incrementing table query

Bridg · Jan 24, 2018 · 33f7e81 · 33f7e81
1 parent acdfbe0
commit 33f7e81
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/io/confluent/connect/jdbc/source/TimestampIncrementingTableQuerier.java b/src/main/java/io/confluent/connect/jdbc/source/TimestampIncrementingTableQuerier.java
@@ -141,6 +141,7 @@ protected void createPreparedStatement(Connection db) throws SQLException {
       builder.append(JdbcUtils.quoteString(timestampColumn, quoteString));
       builder.append(" ASC");
     }
+    builder.append(" LIMIT 10000");
     String queryString = builder.toString();
     log.debug("{} prepared SQL query: {}", this, queryString);
     stmt = db.prepareStatement(queryString);