reduce time spending in poll

confluentinc · Aug 6, 2019 · a66412f · a66412f
1 parent 8279b78
commit a66412f
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceTask.java b/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceTask.java
@@ -296,10 +296,11 @@ public List<SourceRecord> poll() throws InterruptedException {
         // If not in the middle of an update, wait for next update time
         final long nextUpdate = querier.getLastUpdate()
                                 + config.getInt(JdbcSourceTaskConfig.POLL_INTERVAL_MS_CONFIG);
-        final long untilNext = nextUpdate - time.milliseconds();
-        if (untilNext > 0) {
-          log.trace("Waiting {} ms to poll {} next", untilNext, querier.toString());
-          time.sleep(untilNext);
+        final long now = time.milliseconds();
+        final long sleepMs = Math.min(nextUpdate - now, 100);
+        if (sleepMs > 0) {
+          log.trace("Waiting {} ms to poll {} next", nextUpdate - now, querier.toString());
+          time.sleep(sleepMs);
           continue; // Re-check stop flag before continuing
         }
       }