@Test
    public void testMongodbUpdateAndDelete() throws Exception {
        submitSQLJob(sqlFile, jdbcJar, mongodbJar, mysqlJdbcJar);
        waitUntilJobRunning(Duration.ofSeconds(10));

        // generate input
        MongoClient mongoClient = MongoClients.create(MONGODB_CONTAINER.getConnectionString());
        MongoDatabase database = mongoClient.getDatabase("test");
        MongoCollection<Document> collection = database.getCollection("test_input1");

        Document document1 = new Document("_id", 1)
                .append("name", "jacket")
                .append("description", "water resistent white wind breaker");
        Document document2 = new Document("_id", 2)
                .append("name", "scooter")
                .append("description", "Big 2-wheel scooter ");
        List<Document> documents = new ArrayList<Document>();
        documents.add(document1);
        documents.add(document2);
        collection.insertMany(documents);
        collection.updateOne(eq("_id", 2), combine(set("name", "tom")));
        collection.deleteOne(eq("_id", 1));

        JdbcProxy proxy =
                new JdbcProxy(STAR_ROCKS.getJdbcUrl(), STAR_ROCKS.getUsername(),
                        STAR_ROCKS.getPassword(),
                        STAR_ROCKS.getDriverClassName());
        List<String> expectResult =
                Arrays.asList("2,tom,Big 2-wheel scooter ");
        proxy.checkResultWithTimeout(
                expectResult,
                "test_output1",
                3,
                60000L);
    }
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/Mongodb2StarRocksTest.java