From a17edf94e2e730c0474cf0378c2f36bc36d57f00 Mon Sep 17 00:00:00 2001 From: Jakub Malek Date: Thu, 8 Aug 2024 10:34:59 +0200 Subject: [PATCH] #1360 Typos --- .../connect/jdbc/source/JdbcSourceConnectorConfig.java | 2 +- .../connect/jdbc/source/JdbcSourceTaskPollExecutor.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceConnectorConfig.java b/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceConnectorConfig.java index d294287c2..8a58b6945 100644 --- a/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceConnectorConfig.java +++ b/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceConnectorConfig.java @@ -107,7 +107,7 @@ public class JdbcSourceConnectorConfig extends AbstractConfig { + "the worker task for the poll operation. This includes additional poll.interval.ms " + "wait time applied in between subsequent poll calls. If the set maximum time is exceeded, " + "the task will signal no-data to the worker. The polling operation however will not be " - + "interrupted until the task is stopped. Each time the worker is poll the records from the " + + "interrupted until the task is stopped. Each time the worker polls the records from the " + "source task it will either wait for the result from the previously started polling " + "operation or a new polling operation will be started. " + "When the poll.max.wait.time.ms is set to zero, then the worker will wait indefinitely " diff --git a/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceTaskPollExecutor.java b/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceTaskPollExecutor.java index b72f45420..4bc0e02fe 100644 --- a/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceTaskPollExecutor.java +++ b/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceTaskPollExecutor.java @@ -89,7 +89,7 @@ List poll() throws InterruptedException { return NO_DATA; } if (pollMaxWaitTimeMs <= 0) { - // waiting without timeout + // executing polling directly without any timeout return pollOperation.get(); } PollingFuture polling = getOrCreatePollingFuture();