Skip to content

Commit 4683cdc

Browse files
committed
[INLONG-9866][Sort] Workflow test, no need merge.
1 parent 613465d commit 4683cdc

File tree

1 file changed

+13
-0
lines changed
  • inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests

1 file changed

+13
-0
lines changed

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

+13
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
import org.apache.inlong.sort.tests.utils.FlinkContainerTestEnv;
2121
import org.apache.inlong.sort.tests.utils.RedisContainer;
22+
import org.apache.inlong.sort.tests.utils.StarRocksContainer;
2223
import org.apache.inlong.sort.tests.utils.TestUtils;
2324

2425
import org.junit.AfterClass;
@@ -37,6 +38,8 @@
3738
import java.time.Duration;
3839
import java.util.concurrent.TimeUnit;
3940

41+
import static org.apache.inlong.sort.tests.utils.StarRocksManager.*;
42+
import static org.apache.inlong.sort.tests.utils.StarRocksManager.STAR_ROCKS_LOG;
4043
import static org.junit.Assert.assertEquals;
4144
import static org.testcontainers.shaded.org.awaitility.Awaitility.await;
4245

@@ -52,11 +55,21 @@ public class RedisToRedisTest extends FlinkContainerTestEnv {
5255
try {
5356
sqlFile = Paths.get(RedisToRedisTest.class.getResource("/flinkSql/redis_test.sql").toURI())
5457
.toString();
58+
buildStarRocksImage();
5559
} catch (URISyntaxException e) {
5660
throw new RuntimeException(e);
5761
}
5862
}
5963

64+
@ClassRule
65+
public static StarRocksContainer STAR_ROCKS =
66+
(StarRocksContainer) new StarRocksContainer(getNewStarRocksImageName())
67+
.withExposedPorts(9030, 8030, 8040)
68+
.withNetwork(NETWORK)
69+
.withAccessToHost(true)
70+
.withNetworkAliases(INTER_CONTAINER_STAR_ROCKS_ALIAS)
71+
.withLogConsumer(new Slf4jLogConsumer(STAR_ROCKS_LOG));
72+
6073
@ClassRule
6174
public static final RedisContainer REDIS_CONTAINER_SOURCE = new RedisContainer(
6275
DockerImageName.parse("redis:6.2.14"))

0 commit comments

Comments
 (0)