两个Flink Redis sink依赖与groupId ' org.apache有什么区别?"Bahir&q

Question

我正在学习Flink。我尝试添加一个Redis sink。在官方Flink文档中，它链接到Apache Bahir文档，该文档使用

<dependency>
<groupId>org.apache.bahir</groupId>
<artifactId>flink-connector-redis_2.11</artifactId>
<version>1.1-SNAPSHOT</version>
</dependency>

然而，我在Maven上发现了另一个flink-connector-redis:

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-redis_2.11</artifactId>
<version>1.1.5</version>
</dependency>

你可以看到groupId是不同的。

我在他们的网站上找到了关于Apache Bahir的信息。

Apache Bahir提供了多个分布式分析的扩展平台，通过流媒体的多样性来扩大他们的影响力连接器和SQL数据源。

目前，Bahir为Apache Spark和Apache提供扩展Flink .

这两个依赖关系的区别是什么?建议先用哪一种?谢谢!

Answer 1

flink-connector-redis先在org.apache.flink下。然后将其移到org.apache.bahir下，并计划从那里进行维护。它是相同的代码库，但bahir快照确实在bug修复和增强方面有一些改进。