@Test
    public void testToFileSystem() {
        EnvironmentSettings settings = EnvironmentSettings
                .newInstance()
                .inStreamingMode()
                .build();
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);
        env.enableCheckpointing(10000);
        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, settings);
        Node mysqlExtractNode = buildMySQLExtractNode("1");
        Node fileSystemNode = buildFileSystemNode("2");
        // mysql-->HDFS OR LOCAL FILE
        StreamInfo streamInfoToHDFS = new StreamInfo("1L", Arrays.asList(mysqlExtractNode, fileSystemNode),
                Collections.singletonList(buildNodeRelation(Collections.singletonList(mysqlExtractNode),
                        Collections.singletonList(fileSystemNode))));
        GroupInfo groupInfoToHDFS = new GroupInfo("1", Collections.singletonList(streamInfoToHDFS));
        FlinkSqlParser parser = FlinkSqlParser.getInstance(tableEnv, groupInfoToHDFS);
        parser.parse();
    }
Test flink sql mysql cdc to file system

@throws Exception The exception may throws when execute the case
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/FlinkSqlParserTest.java