你好，请教下我数据库里面是decimal类型，用的默认的JsonDebeziumDeserializ

您好，根据您描述的情况，数据库中使用的是decimal类型字段，在通过默认的JsonDebeziumDeserializationSchema反序列化后，如果发现数值类型被显示为一堆字符串，这可能是由于Debezium在处理数值类型时的默认行为所致。为了避免这种情况，您需要在Flink CDC配置中对Decimal类型进行特殊处理来确保它们能正确地被解析为期望的数值格式。

解决步骤如下：

1. 修改连接器属性： 您需要在构建MySqlSource时，通过debeziumProperties设置特定的属性来控制如何处理decimal类型。添加以下配置可以将bigint unsigned和decimal类型分别处理为Java的long和double类型：

   Properties properties = new Properties();
   properties.setProperty("bigint.unsigned.handling.mode", "long");
   properties.setProperty("decimal.handling.mode", "double");
   
   MySqlSource.<String>builder()
      .hostname(config.getHostname())
      ...
      .debeziumProperties(properties);
   

   这样配置后，Decimal类型的值在反序列化时会被转换为Double类型，从而避免了以复杂对象形式展示的问题。

2. 注意事项：

   • 转换为double可能会有精度损失，特别是对于非常大或非常精确的数值。请根据您的业务需求权衡是否接受这种精度上的潜在损失。
   • 如果您需要更高的精度且能接受计算性能上的牺牲，考虑使用适合高精度计算的数据类型（如BigDecimal）并在Flink作业中做相应的处理逻辑调整。

通过上述配置调整，您可以解决decimal类型数据在反序列化后显示为非预期字符串格式的问题。