实时计算 Flink版产品使用合集之如果在 MySQL 表中为某个字段设置了默认值，并且在插入数据时指定了该字段为 NULL，那么 MySQL 是否会使用默认值来填充这个字段

问题一：flinkcdc读取pg的数据 flink用什么类型去接受float的类型的数据呢？

flinkcdc读取pg的数据 flink用什么类型去接受float的类型的数据呢？

参考回答：

看cdc的字段类型匹配关系https://ververica.github.io/flink-cdc-connectors/master/content/connectors/postgres-cdc.html

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/570711

问题二：Flink CDC中flinksql写入到pg数据库嘛？

Flink CDC中flinksql写入到pg数据库嘛？

参考回答：

写pg可以，写greenplum不行，通过jdbc连接器是可以的，建议用官方提供的jdbc- connector

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/570710

问题三：Flink CDC插件也添加了，为什么还是不支持s3文件系统呢？

Flink CDC插件也添加了，为什么还是不支持s3文件系统呢？

参考回答：

Flink CDC目前的版本暂时还不支持S3文件系统。虽然Flink内置了S3文件系统 (flink-s3-fs-presto and flink-s3-fs-hadoop)，这种内置支持主要是为了提高AWS S3 bucket的可扩展性，通过在关键字开头附近添加随机字符实现熵注入。但是，这并不等同于Flink CDC可以直接支持S3作为数据源或接收器。对于S3的支持，可能需要等待Flink社区在未来的更新中进行添加和优化。

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/572262

问题四：Flink CDC中mysql 字段设置了默认值 ,会返回字段默认值 而不是null？

Flink CDC中mysql 字段设置了默认值 ,然后插入数据时 指定该字段为null 会返回字段默认值 而不是null？

参考回答：

这个之前也有其他人反馈过，我是重写了SchemaBuilder，默认值直接指定为null

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/570707

问题五：Flink CDC这个问题有解决的办法吗？莫名其妙的？

Flink CDC这个问题有解决的办法吗？莫名其妙的？

这个文章说5.6的问题？https://bugs.mysql.com/bug.php?id=84752%EF%BC%8

参考回答：

这个问题可能是由于MySQL的二进制日志格式与Flink CDC不兼容导致的。你可以尝试以下方法解决这个问题：

1. 升级MySQL到5.7或更高版本，因为Flink CDC目前支持MySQL 5.6和5.7。
   
2. 如果升级MySQL不可行，你可以尝试使用其他兼容的数据库系统，如PostgreSQL、Oracle等。
   
3. 如果你仍然想使用MySQL，可以考虑使用第三方工具（如Maxwell）来处理二进制日志，然后将数据导入到Flink CDC中。

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/570706