fix test

loustler · Jun 19, 2024 · 9f6148d · 9f6148d
1 parent 74d89f6
commit 9f6148d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/...or-mongodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/v2/mongodb/MongodbIT.java b/...or-mongodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/v2/mongodb/MongodbIT.java
@@ -225,8 +225,8 @@ public void testTransactionSinkAndUpsert(TestContainer container)
     @TestTemplate
     public void testMongodbDoubleValue(TestContainer container)
             throws IOException, InterruptedException {
-        Container.ExecResult insertResult = container.executeJob("/mongodb_double_value.conf");
-        Assertions.assertEquals(0, insertResult.getExitCode(), insertResult.getStderr());
+        Container.ExecResult assertSinkResult = container.executeJob("/mongodb_double_value.conf");
+        Assertions.assertEquals(0, assertSinkResult.getExitCode(), assertSinkResult.getStderr());
 
         Assertions.assertIterableEquals(
                 TEST_DOUBLE_DATASET.stream()
@@ -235,7 +235,6 @@ public void testMongodbDoubleValue(TestContainer container)
                 readMongodbData(MONGODB_DOUBLE_TABLE_RESULT).stream()
                         .peek(e -> e.remove("_id"))
                         .collect(Collectors.toList()));
-        clearDate(MONGODB_DOUBLE_TABLE);
         clearDate(MONGODB_DOUBLE_TABLE_RESULT);
     }
 }
diff --git a/...unnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_double_value.conf b/...unnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_double_value.conf
@@ -18,8 +18,6 @@
 env {
   parallelism = 1
   job.mode = "BATCH"
-  # Never retries in test
-  job.retry.times = 0
   #spark config
   spark.app.name = "SeaTunnel"
   spark.executor.instances = 1