From 25ef933355da0e6aa73e388841c0009e3f3ae85b Mon Sep 17 00:00:00 2001 From: timrobertson100 Date: Wed, 22 Aug 2018 12:31:54 +0200 Subject: [PATCH] [BEAM-5193] Correct typos in KuduIOTest testWrite --- .../test/java/org/apache/beam/sdk/io/kudu/KuduIOTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/sdks/java/io/kudu/src/test/java/org/apache/beam/sdk/io/kudu/KuduIOTest.java b/sdks/java/io/kudu/src/test/java/org/apache/beam/sdk/io/kudu/KuduIOTest.java index a39b87b4e22b8..55a2b72af1585 100644 --- a/sdks/java/io/kudu/src/test/java/org/apache/beam/sdk/io/kudu/KuduIOTest.java +++ b/sdks/java/io/kudu/src/test/java/org/apache/beam/sdk/io/kudu/KuduIOTest.java @@ -125,9 +125,9 @@ public void testRead() throws KuduException { } /** - * Test the write path using a {@link FakeWriter} and verifying the expected log statements are + * Test the write path using a {@link FakeWriter} and verifies the expected log statements are * written. This test ensures that the {@link KuduIO} correctly respects parallelism by - * deserializes writers and that each writer is opening and closing Kudu sessions. + * deserializing writers and that each writer is opening and closing Kudu sessions. */ @Test public void testWrite() throws Exception { @@ -144,14 +144,14 @@ public void testWrite() throws Exception { .withKuduService(mockWriteService)); writePipeline.run().waitUntilFinish(); - for (int i = 1; i <= targetParallelism + 1; i++) { + for (int i = 1; i <= targetParallelism; i++) { expectedWriteLogs.verifyDebug(String.format(FakeWriter.LOG_OPEN_SESSION, i)); expectedWriteLogs.verifyDebug( String.format(FakeWriter.LOG_WRITE, i)); // at least one per writer expectedWriteLogs.verifyDebug(String.format(FakeWriter.LOG_CLOSE_SESSION, i)); } // verify all entries written - for (int n = 0; n > numberRecords; n++) { + for (int n = 0; n < numberRecords; n++) { expectedWriteLogs.verifyDebug( String.format(FakeWriter.LOG_WRITE_VALUE, n)); // at least one per writer }