Skip to content

Commit

Permalink
DBZ-7250 Remove unuseful prints
Browse files Browse the repository at this point in the history
  • Loading branch information
jpechane committed Jan 24, 2024
1 parent 2ad465e commit f209273
Showing 1 changed file with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -423,9 +423,7 @@ protected void await(long timeout, TimeUnit unit) throws InterruptedException {

protected void await(long timeout, long extraRecordsTimeout, TimeUnit unit) throws InterruptedException {
final ElapsedTimeStrategy timer = ElapsedTimeStrategy.constant(Clock.SYSTEM, unit.toMillis(timeout));
System.out.println(timer);
while (!timer.hasElapsed()) {
System.out.println(timer);
final SourceRecord r = consumeRecord();
if (r != null) {
accept(r);
Expand Down

0 comments on commit f209273

Please sign in to comment.