Loading src/test/java/io/confluent/connect/elasticsearch/bulk/BulkProcessorTest.java +1 −1 Original line number Diff line number Diff line Loading @@ -167,7 +167,7 @@ public class BulkProcessorTest { assertFalse(client.expectationsMet()); final int flushTimeoutMs = 10; final int flushTimeoutMs = 100; bulkProcessor.flush(flushTimeoutMs); } Loading Loading
src/test/java/io/confluent/connect/elasticsearch/bulk/BulkProcessorTest.java +1 −1 Original line number Diff line number Diff line Loading @@ -167,7 +167,7 @@ public class BulkProcessorTest { assertFalse(client.expectationsMet()); final int flushTimeoutMs = 10; final int flushTimeoutMs = 100; bulkProcessor.flush(flushTimeoutMs); } Loading