xinQing

Results 18 comments of xinQing

数据库添加了mysql、oracle的驱动,大数据只加了hive的。对于其他组件,需要将kettle的相关依赖添加到maven管理。

版本不一致

达梦还不支持呢,目前只是简单的对 https://github.com/ververica/flink-cdc-connectors 库做了一个配置化的封装,还未深度底层做其他数据库的适配。

目前Local模式,是将flink的依赖全部打包到这个项目中,直接java -jar启动就用了flink的环境。 checkpoint这个地址就是本地的一个路径,自己定即可。 暂时还没测试集群,如果是集群,checkpoint就是hdfs的路径了。

解决了吗,大概准备多少数据,训练多少次能有效果。目前尝试训练一些热词,无效果