diff --git a/src/test/java/io/debezium/connector/vitess/AbstractVitessConnectorTest.java b/src/test/java/io/debezium/connector/vitess/AbstractVitessConnectorTest.java index 7842972f..d128157e 100644 --- a/src/test/java/io/debezium/connector/vitess/AbstractVitessConnectorTest.java +++ b/src/test/java/io/debezium/connector/vitess/AbstractVitessConnectorTest.java @@ -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);