Skip to content

Conversation

@rainerschamm
Copy link

Added a new config option:

  private static final String WORKER_POLL_DURATION_MS_PROP = "iceberg.worker.poll.duration-ms";
  private static final int WORKER_POLL_DURATION_MS_DEFAULT = 0;

I kept the duration at 0 so that there in effect no change to the existing behavior in Worker.java:

   void process() {
-    consumeAvailable(Duration.ZERO);
+    consumeAvailable(pollDuration);
   }

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant