实时计算 Flink版产品使用合集之将数据写入Elasticsearch时，若Elasticsearch中的字段类型为date，对应的SQL类型应该是什么

问题一：Flink CDC哪位能发下新版本postgresql flinkcdc连接器？

Flink CDC哪位能发下新版本postgresql flinkcdc连接器？

参考回答：

Apache Flink 有两个 PostgresCDC Connector：

• FlinkCDC-Kafka-SQL：一个 Flink SQL 插件，用于从 Postgres 数据库拉取数据并将其发送到 Kafka。
• FlinkCDC-Connector：一个外部连接器，可以与其他系统集成。
  这两个项目均未与 Flink 社区整合。要获取最新的 PostgreSQL CDC 连接器，请参阅以下链接：
• FlinkCDC-Kafka-SQL：https://nightlies.apache.org/flink/flink-cdc-connectors/master/docs/connectors/cdc/postgresql/
• FlinkCDC-Connector：https://nightlies.apache.org/flink/flink-cdc-connectors/master/docs/connectors/postgresql/

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

问题二：flink 啥时候能支持tidb连接器，有这个计划吗？

flink 啥时候能支持tidb连接器，有这个计划吗？

参考回答：

暂时没有计划，社区有连接器你可以自定义connector先用。

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

问题三：Flink CDC1.13.2和flinkcdc2.0，读取mysql的cdc，有人遇到这个问题吗？

Flink CDC1.13.2和flinkcdc2.0，读取mysql的cdc，有人遇到这个问题吗？

https://github.com/ververica/flink-cdc-connectors/discussions/719

参考回答：

看着像是你自己自定义序列化的问题，先测试.deserializer(new JsonDebeziumDeserializationSchema())

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

问题四：使用cdc同步oracle 12c cdc数据库，根据文档要求创建账号 公用用户名或角色名无效？

使用cdc同步oracle 12c cdc数据库，根据文档要求创建账号 提示ORA-65096: 公用用户名或角色名无效？

参考回答：

sysdba

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

问题五：finksql sink到ES 这里es的date类型 我们对应的sql是什么类型的呀？

finksql sink到ES 这里es的date类型 我们对应的sql是什么类型的呀？

参考回答：

string和date都可以，映射表string，ES date(不加format)，此时写入映射表的时候要手动加'T''Z'

映射表date，ES date就得在mapping设置format参数了，然后还可以映射表timestamp(0/3/6)，ES keyword，三种方式 ES显示的格式是有差别的

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