Flink CDC这里传json，双引号会被去掉，怎么办?

在Flink CDC中，如果JSON数据中的双引号被去掉了，可以在将参数传递给ParameterTool之前，对参数进行预处理，将双引号添加回去。以下是一个示例：

import org.apache.flink.api.common.JobExecutionResult;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class FlinkCDCExample {
    public static void main(String[] args) throws Exception {
        // 对参数进行处理，将双引号添加回去
        StringBuilder processedArgs = new StringBuilder();
        for (String arg : args) {
            processedArgs.append("\"").append(arg).append("\" ");
        }
        args = processedArgs.toString().trim().split("\\s+");

        // 创建Flink环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 从参数中获取配置信息
        ParameterTool parameterTool = ParameterTool.fromArgs(args);

        // 使用parameterTool进行其他操作...

        // 执行任务并等待结果
        JobExecutionResult result = env.execute("Flink CDC Example");
    }
}

这样，在将参数传递给ParameterTool之前，会先对参数进行处理，确保双引号不会被去掉。

base64编码一下 ，此回答整理自钉群“Flink CDC 社区”