cleanup

apache · Oct 31, 2024 · d9dd509 · d9dd509
1 parent 6ee2e01
commit d9dd509
Showing 1 changed file with 0 additions and 25 deletions.
diff --git a/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOTest.java b/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOTest.java
@@ -240,31 +240,6 @@ public void testRead() {
     PAssert.thatSingleton(rows.apply("Count All", Count.globally()))
         .isEqualTo((long) EXPECTED_ROW_COUNT);
 
-    expectedLogs.verifyInfo("Autocommit has been disabled");
-
-    Iterable<TestRow> expectedValues = TestRow.getExpectedValues(0, EXPECTED_ROW_COUNT);
-    PAssert.that(rows).containsInAnyOrder(expectedValues);
-
-    pipeline.run();
-  }
-
-  @Test
-  public void testReadDisableAutoCommitFalse() {
-    PCollection<TestRow> rows =
-        pipeline.apply(
-            JdbcIO.<TestRow>read()
-                .withFetchSize(12)
-                .withDisableAutoCommit(false)
-                .withDataSourceConfiguration(DATA_SOURCE_CONFIGURATION)
-                .withQuery("select name,id from " + READ_TABLE_NAME)
-                .withRowMapper(new JdbcTestHelper.CreateTestRowOfNameAndId())
-                .withCoder(SerializableCoder.of(TestRow.class)));
-
-    PAssert.thatSingleton(rows.apply("Count All", Count.globally()))
-        .isEqualTo((long) EXPECTED_ROW_COUNT);
-
-    expectedLogs.verifyNotLogged("Autocommit has been disabled");
-
     Iterable<TestRow> expectedValues = TestRow.getExpectedValues(0, EXPECTED_ROW_COUNT);
     PAssert.that(rows).containsInAnyOrder(expectedValues);