百岁

Results 93 comments of 百岁

嗯,这个问题是和 https://github.com/qlangtech/tis/issues/108 一样的

1. 网上找了一个实例,看起来还算简单 https://blog.csdn.net/xianpanjia4616/article/details/88762069?utm_term=flink%E5%AE%9E%E7%8E%B0mysqlsink&utm_medium=distribute.pc_aggpage_search_result.none-task-blog-2~all~sobaiduweb~default-2-88762069&spm=3001.4430, 或者可以参考 flinkx的一个实现 https://github.com/flinkx/flinkx/blob/2772041ad84fe3c1a34dccc30c0dca4899c78f18/flinkx-core/src/main/java/com/flink/flinkx/streaming/api/functions/sink/DtOutputFormatSinkFunction.java#L58 [MysqlWriter.java](https://github.com/flinkx/flinkx/blob/master/flinkx-mysql/flinkx-mysql-writer/src/main/java/com/flink/flinkx/mysql/writer/MysqlWriter.java) 3. flink 版本需要升级

https://github.com/DTStack/chunjun/blob/v1.12.2/flinkx-connectors/flinkx-connector-mysql/src/main/java/com/dtstack/flinkx/connector/mysql/sink/MysqlSinkFactory.java

如果一个字段在mysql中是 date类型,那期望映射到hive中是 datetime,还是timestamp?

明白了,需要把hiveWriter的autoCreateDDL功能打开,可以让用户自定义hive create ddl 的脚本

当出现该种情况之后,会弹出一个对话框可以让用户重现设置flinkhost

例如: ![8D846365-29E1-4302-8301-A968754F3E42](https://user-images.githubusercontent.com/21274618/163764056-2e85bd92-6a9b-4aef-ae60-69a27fe882e9.png) ``` shell "format": "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||strict_date_optional_time||epoch_millis" · ``` 配上这个就全量和增量都好使了,就是存储的数据格式不一致了

定时功能还没有开发,需要的话自己在操作系统上加一个crontab 然后掉用tis的rest api即可

嗯,这个功能不复杂,只不过因为是非核心功能一直拖着没有做 这个功能会加的