bahir-flink

1、idea克隆代码

2、保留flink-connector-redis

3、修改flink-connector-redis版本

4、maven编译

5、项目中pom引用

        <dependency>
            <groupId>org.apache.bahirgroupId>
            <artifactId>flink-connector-redis_2.12artifactId>
            <version>1.2-SNAPSHOTversion>
        dependency>

1
2
3
4
5
6