@Nullable
    public String getPipelineConfigure(String statement) {
        Pattern patternYaml = Pattern.compile("(?is)^EXECUTE\\s+PIPELINE\\s+WITHYAML\\s+\\((.+)\\)");
        Matcher matcherYaml = patternYaml.matcher(statement);
        if (matcherYaml.find()) {
            return matcherYaml.group(1);
        }
        return "";
    }
@Test
    void getPipelineConfigure() {
        FlinkCDCPipelineOperation operation = new FlinkCDCPipelineOperation();
        String configure = "EXECUTE PIPELINE withYaml (a.b=1\n a.b.c=2)";
        String result = operation.getPipelineConfigure(configure);
        assertEquals("a.b=1\n a.b.c=2", result);
    }