fix flink case

JNSimba · Jul 3, 2024 · 1ebd468 · 1ebd468
1 parent cc14cd5
commit 1ebd468
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/regression-test/suites/flink_connector_p0/flink_connector_syncdb.groovy b/regression-test/suites/flink_connector_p0/flink_connector_syncdb.groovy
@@ -58,10 +58,19 @@ PROPERTIES (
 
     logger.info("start delete local flink-doris-syncdb.jar....")
     def delete_local_flink_jar = "rm -rf flink-doris-syncdb.jar".execute()
-    logger.info("start download flink-doris-syncdb.jar ....")
+    logger.info("start download regression/flink-doris-syncdb.jar ....")
     logger.info("getS3Url: ${getS3Url()}")
-    def download_flink_jar = "curl ${getS3Url()}/regression/flink-doris-syncdb.jar  --output flink-doris-syncdb.jar".execute().getText()
-    logger.info("finish download flink-doris-syncdb.jar ...")
+    def download_flink_jar = "wget --quiet --continue --tries=5 ${getS3Url()}/regression/flink-doris-syncdb.jar".execute().getText()
+
+    def file = new File('flink-doris-syncdb.jar')
+    if (file.exists()) {
+        def fileSize = file.length()
+        logger.info("finish download flink-doris-syncdb.jar, size " + fileSize)
+    } else {
+        logger.info("flink-doris-syncdb.jar download failed")
+        throw new Exception("File flink-doris-syncdb.jar download failed.")
+    }
+
     def run_cmd = "java -cp flink-doris-syncdb.jar org.apache.doris.DatabaseFullSync $context.config.feHttpAddress regression_test_flink_connector_p0 $context.config.feHttpUser"
     logger.info("run_cmd : $run_cmd")
     def run_flink_jar = run_cmd.execute().getText()