JsonDebeziumDeserializationSchema生成的json，mysql的timestamp类型，在flinksql format debezium-json中解析失败，格式不一致，这个要怎么改？有配置吗？
file:///C:/Users/Admin/AppData/Roaming/DingTalk/227792554_v2/resource_cache/d7/d7e8c705124bb938958a4e0afcda77fc.png
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
{
"version": "1.0",
"connector": "mysql",
"name": "inventory-connector",
"config": {
"hostname": "localhost",
"port": "3306",
"username": "root",
"password": "password",
"database": "inventory",
"table.whitelist": "products",
"timestamp.format.standard": "ISO-8601",
"include.schema.changes": "false",
"deserialization.format": "debezium-json"
}
}
可以通过配置JSON Schema来解决这个问题。
{"name": "create_time", "type": "string",
"logicalType": "timestamp-millis",
"doc": "MySQL timestamp converted to FlinkSQL timestamp-millis type",
"transform": {"expr": "from_unixtime(to_unix_timestamp(substring($,1,19), 'yyyy-MM-dd HH:mm:ss'))*1000"}},
评论
全部评论 (0)
DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎，为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。
评论
全部评论 (0)