异常问题 about flink-connector-redis

[jeff-zou]

无法连接上，连接信息可以发来看一不

[zhaoSir-bin]

当前这个问题已经解决，由于scala版本不一致导致，我这边使用的是flink2.11，重新编译后解决了，
还有一个问题是使用flinksql 将hive数据导入到redis 时，任务结束后做数据校验发现数据不一致，redis数据偏少，不完整，重复执行还是偏少，相差数据量较大
hive为非分区表，数据了在300万 只导入200万左右
https://github.com/jeff-zou/flink-connector-redis/releases/tag/1.2.5

[jeff-zou]

应该是主键冲突吧

[zhaoSir-bin]

不是主键冲突，使用hive写入redis时，当flink 加载完source数据后，下游使用的异步写入，这时候写入还未完成，但上游source已经开始触发结束 redis还未完全写入但整个任务已经shut down了
我使用旧版本的connector 是不会出现该情况的是全量写入的

[jeff-zou]

恩，这是个问题，这几天我研究一下，增加支持批处理。

[jeff-zou]

<dependency> <groupId>io.github.jeff-zou</groupId> <artifactId>flink-connector-redis</artifactId> <version>1.3.0</version> <classifier>jar-with-dependencies</classifier> </dependency>

问题已经修复，请使用这个版本