@Before
    public void setup() {
        waitUntilJobRunning(Duration.ofSeconds(30));
        initializePostgresTable();
        initializeStarRocksTable(STAR_ROCKS);
    }
End-to-end tests for sort-connector-postgres-cdc-v1.15 uber jar.
Test flink sql Postgres cdc to StarRocks
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Postgres2StarRocksTest.java