[INLONG-9866][Sort] Workflow test, no need merge.

Author: XiaoYou201

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Kafka2StarRocksTesta.java

@@ -56,7 +56,6 @@
 
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.INTER_CONTAINER_STAR_ROCKS_ALIAS;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.STAR_ROCKS_LOG;
-import static org.apache.inlong.sort.tests.utils.StarRocksManager.buildStarRocksImage;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.getNewStarRocksImageName;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.initializeStarRocksTable;
 
@@ -83,7 +82,6 @@ public class Kafka2StarRocksTesta extends FlinkContainerTestEnv {
             URI kafkaSqlFile =
                     Objects.requireNonNull(Kafka2StarRocksTesta.class.getResource("/flinkSql/kafka_test.sql")).toURI();
             sqlFile = Paths.get(kafkaSqlFile).toString();
-            buildStarRocksImage();
         } catch (URISyntaxException e) {
             throw new RuntimeException(e);
         }

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Mongodb2StarRocksTesta.java

@@ -82,9 +82,8 @@ public class Mongodb2StarRocksTesta extends FlinkContainerTestEnv {
 
     static {
         try {
-            sqlFile = Paths.get(Postgres2StarRocksTesta.class.getResource("/flinkSql/mongodb_test.sql").toURI())
+            sqlFile = Paths.get(Postgres2StarRocksTest.class.getResource("/flinkSql/mongodb_test.sql").toURI())
                     .toString();
-            buildStarRocksImage();
         } catch (URISyntaxException e) {
             throw new RuntimeException(e);
         }

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Mysql2StarRocksTesta.java

@@ -44,7 +44,6 @@
 
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.INTER_CONTAINER_STAR_ROCKS_ALIAS;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.STAR_ROCKS_LOG;
-import static org.apache.inlong.sort.tests.utils.StarRocksManager.buildStarRocksImage;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.getNewStarRocksImageName;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.initializeStarRocksTable;
 
@@ -65,7 +64,6 @@ public class Mysql2StarRocksTesta extends FlinkContainerTestEnv {
         try {
             sqlFile =
                     Paths.get(Mysql2StarRocksTesta.class.getResource("/flinkSql/mysql_test.sql").toURI()).toString();
-            buildStarRocksImage();
         } catch (URISyntaxException e) {
             throw new RuntimeException(e);
         }

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Postgres2StarRocksTesta.java inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Postgres2StarRocksTest.java

@@ -45,16 +45,15 @@
 
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.INTER_CONTAINER_STAR_ROCKS_ALIAS;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.STAR_ROCKS_LOG;
-import static org.apache.inlong.sort.tests.utils.StarRocksManager.buildStarRocksImage;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.getNewStarRocksImageName;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.initializeStarRocksTable;
 /**
  * End-to-end tests for sort-connector-postgres-cdc-v1.15 uber jar.
  * Test flink sql Postgres cdc to StarRocks
  */
-public class Postgres2StarRocksTesta extends FlinkContainerTestEnv {
+public class Postgres2StarRocksTest extends FlinkContainerTestEnv {
 
-    private static final Logger LOG = LoggerFactory.getLogger(Postgres2StarRocksTesta.class);
+    private static final Logger LOG = LoggerFactory.getLogger(Postgres2StarRocksTest.class);
 
     private static final Path postgresJar = TestUtils.getResource("sort-connector-postgres-cdc.jar");
     private static final Path jdbcJar = TestUtils.getResource("sort-connector-starrocks.jar");
@@ -63,9 +62,8 @@ public class Postgres2StarRocksTesta extends FlinkContainerTestEnv {
 
     static {
         try {
-            sqlFile = Paths.get(Postgres2StarRocksTesta.class.getResource("/flinkSql/postgres_test.sql").toURI())
+            sqlFile = Paths.get(Postgres2StarRocksTest.class.getResource("/flinkSql/postgres_test.sql").toURI())
                     .toString();
-            buildStarRocksImage();
         } catch (URISyntaxException e) {
             throw new RuntimeException(e);
         }

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/RedisToRedisTest.java

@@ -55,21 +55,11 @@ public class RedisToRedisTest extends FlinkContainerTestEnv {
         try {
             sqlFile = Paths.get(RedisToRedisTest.class.getResource("/flinkSql/redis_test.sql").toURI())
                     .toString();
-            buildStarRocksImage();
         } catch (URISyntaxException e) {
             throw new RuntimeException(e);
         }
     }
 
-    @ClassRule
-    public static StarRocksContainer STAR_ROCKS =
-            (StarRocksContainer) new StarRocksContainer(getNewStarRocksImageName())
-                    .withExposedPorts(9030, 8030, 8040)
-                    .withNetwork(NETWORK)
-                    .withAccessToHost(true)
-                    .withNetworkAliases(INTER_CONTAINER_STAR_ROCKS_ALIAS)
-                    .withLogConsumer(new Slf4jLogConsumer(STAR_ROCKS_LOG));
-
     @ClassRule
     public static final RedisContainer REDIS_CONTAINER_SOURCE = new RedisContainer(
             DockerImageName.parse("redis:6.2.14"))

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Sqlserver2StarRocksTesta.java

@@ -45,7 +45,6 @@
 
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.INTER_CONTAINER_STAR_ROCKS_ALIAS;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.STAR_ROCKS_LOG;
-import static org.apache.inlong.sort.tests.utils.StarRocksManager.buildStarRocksImage;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.getNewStarRocksImageName;
 import static org.apache.inlong.sort.tests.utils.StarRocksManager.initializeStarRocksTable;
 
@@ -64,7 +63,6 @@ public class Sqlserver2StarRocksTesta extends FlinkContainerTestEnv {
         try {
             sqlFile = Paths.get(Sqlserver2StarRocksTesta.class.getResource("/flinkSql/sqlserver_test.sql").toURI())
                     .toString();
-            buildStarRocksImage();
         } catch (URISyntaxException e) {
             throw new RuntimeException(e);
         }

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/utils/StarRocksManager.java

@@ -39,6 +39,23 @@ public class StarRocksManager {
     private static final String NEW_STARROCKS_TAG = "latest";
     private static final String STAR_ROCKS_IMAGE_NAME = "starrocks/allin1-ubi:3.0.4";
     public static final Logger STAR_ROCKS_LOG = LoggerFactory.getLogger(StarRocksContainer.class);
+
+    static {
+        GenericContainer oldStarRocks = new GenericContainer(STAR_ROCKS_IMAGE_NAME);
+        Startables.deepStart(Stream.of(oldStarRocks)).join();
+        oldStarRocks.copyFileToContainer(MountableFile.forClasspathResource("/docker/starrocks/start_fe_be.sh"),
+                "/data/deploy/");
+        try {
+            oldStarRocks.execInContainer("chmod", "+x", "/data/deploy/start_fe_be.sh");
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        oldStarRocks.getDockerClient()
+                .commitCmd(oldStarRocks.getContainerId())
+                .withRepository(NEW_STARROCKS_REPOSITORY)
+                .withTag(NEW_STARROCKS_TAG).exec();
+        oldStarRocks.stop();
+    }
     public static void buildStarRocksImage() {
         GenericContainer oldStarRocks = new GenericContainer(STAR_ROCKS_IMAGE_NAME);
         Startables.deepStart(Stream.of(oldStarRocks)).join();