code style

TongchengOpenSource · May 14, 2024 · ab7a0eb · ab7a0eb
1 parent 29c2b1c
commit ab7a0eb
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 14 deletions.
diff --git a/...2e/connector-starrocks-e2e/src/test/resources/starrocks-to-assert-with-multipletable.conf b/...2e/connector-starrocks-e2e/src/test/resources/starrocks-to-assert-with-multipletable.conf
@@ -74,6 +74,7 @@ source {
     ]
     max_retries = 3
     scan.params.scanner_thread_pool_thread_num = "3"
+    result_table_name = "starrocks"
   }
 }
 
@@ -83,7 +84,7 @@ transform {
 sink {
   Assert {
     rules {
-      table-names = ["e2e_table_source", "e2e_table_source_3"]
+      table-names = ["e2e_table_source"]
     }
   }
 }
diff --git a/...test/java/org/apache/seatunnel/e2e/common/container/spark/AbstractTestSparkContainer.java b/...test/java/org/apache/seatunnel/e2e/common/container/spark/AbstractTestSparkContainer.java
@@ -111,7 +111,6 @@ public Container.ExecResult executeJob(String confFile)
     public Container.ExecResult executeJob(String confFile, List<String> variables)
             throws IOException, InterruptedException {
         log.info("test in container: {}", identifier());
-        log.info("sr-confFile: {}", confFile);
         return executeJob(master, confFile, variables);
     }
 

diff --git a/...eatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/util/ContainerUtil.java b/...eatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/util/ContainerUtil.java
@@ -91,8 +91,6 @@ public static void copyConnectorJarToContainer(
         connectorNames.addAll(getConnectors(jobConfig, connectors, "sink"));
         File module = new File(PROJECT_ROOT_PATH + File.separator + connectorsRootPath);
 
-        log.info("sr-module: {} \n", module);
-        log.info("sr-module-PATH: {} \n", module.getAbsolutePath());
         List<File> connectorFiles = getConnectorFiles(module, connectorNames, connectorPrefix);
         connectorFiles.forEach(
                 jar ->
@@ -227,11 +225,7 @@ public static List<File> getConnectorFiles(
             File currentModule, Set<String> connectorNames, String connectorPrefix) {
         List<File> connectorFiles = new ArrayList<>();
 
-        log.error("sr-currentModule: {}. \n ", currentModule);
         for (File file : Objects.requireNonNull(currentModule.listFiles())) {
-            log.error("sr-currentModule-file-path: {}. \n ", file.getAbsolutePath());
-            log.error("sr-currentModule-file-name: {}. \n ", file.getName());
-            log.error("sr-currentModule-file: {}. \n ", file.toString());
             getConnectorFiles(file, connectorNames, connectorPrefix, connectorFiles);
         }
         return connectorFiles;
@@ -243,8 +237,8 @@ private static void getConnectorFiles(
             String connectorPrefix,
             List<File> connectors) {
 
-        log.error("getConnectorFiles-connectorNames.size(): {}. \n ", connectorNames.size());
-        log.error("getConnectorFiles-connectors.size(): {}. \n ", connectors.size());
+        log.info("getConnectorFiles-connectorNames.size(): {}. \n ", connectorNames.size());
+        log.info("getConnectorFiles-connectors.size(): {}. \n ", connectors.size());
         if (currentModule.isFile() || connectorNames.size() == connectors.size()) {
             return;
         }
@@ -253,10 +247,11 @@ private static void getConnectorFiles(
                     "getConnectorFiles-currentModule.getName()(): {}. \n ",
                     currentModule.getName());
             File targetPath = new File(currentModule.getAbsolutePath() + File.separator + "target");
-            log.error("getConnectorFiles-targetPath: {}. \n ", targetPath);
-            for (File file : Objects.requireNonNull(targetPath.listFiles())) {
-                log.error("getConnectorFiles-file: {}. \n ", file);
-                log.error("getConnectorFiles-file.getName(): {}. \n ", file.getName());
+            log.info("getConnectorFiles-targetPath: {}. \n ", targetPath);
+            File[] files = targetPath.listFiles();
+            for (File file : Objects.requireNonNull(files)) {
+                log.info("getConnectorFiles-file: {}. \n ", file);
+                log.info("getConnectorFiles-file.getName(): {}. \n ", file.getName());
                 if (file.getName().startsWith(currentModule.getName())
                         && !file.getName().endsWith("javadoc.jar")
                         && !file.getName().endsWith("tests.jar")) {