Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
jakubmalek committed Aug 8, 2024
1 parent 42db7db commit a17edf9
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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 "
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ List<SourceRecord> poll() throws InterruptedException {
return NO_DATA;
}
if (pollMaxWaitTimeMs <= 0) {
// waiting without timeout
// executing polling directly without any timeout
return pollOperation.get();
}
PollingFuture polling = getOrCreatePollingFuture();
Expand Down

0 comments on commit a17edf9

Please sign in to comment.