Flink CDC Cli 在哪个地方设置 这个啊？

在Flink CDC中，bigint.unsigned.handling是用于处理无符号大整型（BIGINT UNSIGNED）的选项。该选项用于指定如何处理MySQL中的无符号大整型数据，因为在Java中没有相应的无符号类型。

要在Flink CDC中设置bigint.unsigned.handling选项，可以通过以下方式进行配置：

1. 使用Table API：在使用Flink CDC的Table API时，可以在创建表时通过withFormatOptions方法设置选项。示例代码如下：

   StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
   StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
   
   // 创建源表并设置选项
   tableEnv.executeSql("CREATE TABLE source_table (...) WITH (..., 'connector' = 'mysql-cdc', 'hostname' = 'localhost', 'port' = '3306', 'username' = 'root', 'password' = 'password', 'database-name' = 'mydb', 'table-name' = 'mytable', 'bigint.unsigned.handling.mode' = 'long')");
   

   在上面的代码中，通过'bigint.unsigned.handling.mode' = 'long'来设置选项。

2. 使用DataStream API：在使用Flink CDC的DataStream API时，可以在CdcSource函数中通过.options()方法设置选项。示例代码如下：

   StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
   
   // 创建源流并设置选项
   CdcSource<Row> source = CdcSource.<Row>builder()
       .hostname("localhost")
       .port(3306)
       .username("root")
       .password("password")
       .databaseName("mydb")
       .tableName("mytable")
       .deserializer(new RowDebeziumDeserializeSchema())
       .option("bigint.unsigned.handling.mode", "long")
       .build();
   
   DataStream<Row> stream = env.addSource(source);
   

   在上面的代码中，通过.option("bigint.unsigned.handling.mode", "long")来设置选项。

如果按照上述方式配置后仍然无法生效，可能是由于以下原因之一：

• 版本兼容性：确保你使用的Flink CDC版本支持bigint.unsigned.handling选项。不同版本的Flink CDC可能有不同的选项和功能。
• 配置覆盖：检查是否有其他配置文件或参数覆盖了你的设置。有时全局配置文件或其他配置可能会影响特定选项的行为。
• 语法错误：仔细检查选项名称和值的语法，确保它们与文档和示例代码中的一致。

如果你尝试了以上方法仍然无法解决问题，建议查阅Flink CDC的官方文档或向相关社区寻求帮助，以获取更具体的指导和支持。