@Test
    public void testRedisSourceAndSink() throws Exception {
        submitSQLJob(sqlFile, redisJar);
        waitUntilJobRunning(Duration.ofSeconds(30));
        await().atMost(20, TimeUnit.SECONDS).untilAsserted(() -> {
            assertEquals("value_1_1", jedisSink.get("1_1"));
            assertEquals("value_2_2", jedisSink.get("2_2"));
        });
        await().atMost(20, TimeUnit.SECONDS).untilAsserted(() -> {
            assertEquals("value_1", jedisSink.hget("3_3", "1"));
            assertEquals("value_2", jedisSink.hget("3_3", "2"));
        });
        await().atMost(20, TimeUnit.SECONDS).untilAsserted(() -> {
            assertEquals("10.0", jedisSink.hget("rank_score_test", "1"));
            assertEquals("20.0", jedisSink.hget("rank_score_test", "2"));
            assertEquals("30.0", jedisSink.hget("rank_score_test", "3"));
        });
        await().atMost(20, TimeUnit.SECONDS).untilAsserted(() -> {
            assertEquals("2", jedisSink.hget("rank_test", "1"));
            assertEquals("1", jedisSink.hget("rank_test", "2"));
            assertEquals("0", jedisSink.hget("rank_test", "3"));
        });
    }
Test flink sql postgresql cdc to StarRocks

@throws Exception The exception may throws when execute the case
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/RedisToRedisTest.java