xinQing
xinQing
任务变量是传递到kjb中,让里面使用。任务组没啥用,单纯分个组,管理下
数据库添加了mysql、oracle的驱动,大数据只加了hive的。对于其他组件,需要将kettle的相关依赖添加到maven管理。
跑不起来
版本不一致
达梦还不支持呢,目前只是简单的对 https://github.com/ververica/flink-cdc-connectors 库做了一个配置化的封装,还未深度底层做其他数据库的适配。
目前Local模式,是将flink的依赖全部打包到这个项目中,直接java -jar启动就用了flink的环境。 checkpoint这个地址就是本地的一个路径,自己定即可。 暂时还没测试集群,如果是集群,checkpoint就是hdfs的路径了。
解决了吗,大概准备多少数据,训练多少次能有效果。目前尝试训练一些热词,无效果