flink-connector-kafka_2.12-1.11.0.jar pylink链接kafka资源jar包f
2022-04-14 20:06:09
93KB
1
flink连接kafka的jar包，版本号是1.13.6，scala版本号是2.11
flink-connector-kafka_2.11-1.13.6.jar
2022-04-06 14:08:04
351KB
1
FlinkSQL+STREAM 1.12连接 pulsar 2.8 的连接器
2022-04-06 02:53:56
49.34MB
1
flink-connector-hive_2.12-1.12.0.jar
2022-04-06 02:53:55
6.03MB
1
官网没有提供下载编译好的 connector ，需要自己编译，我将编译好的上传，供大家下载。
flink 版本1.13.5；
2.12
1.13.5
0.13.0
5.0.0
3.8.1
3.3.0
3.2.1
2022-04-06 02:53:15
7.68MB
1
Flink CDC Connectors 2.2源码修改，适配Flink 1.14.2（MySQL）
2022-04-06 02:53:14
33.54MB
1
flink 以connector形式连接clickhouse，资源稀缺，阿里云已经找不到了
id Int,
age Int,
sex Int,
create_date Date
) WITH (
'connector' = 'clickhouse',
'url' = 'jdbc:clickhouse://10.1.3.176:8123/test',
'table-name' = 'tb_user',
'username' = '',
'password' = '',
'format' = 'json'
)
2022-03-24 16:16:21
6.5MB
1
Doris版本0.15，flink版本1.13，scala版本2.12
2022-01-06 11:01:22
7.41MB
1
基于https://github.com/apache/bahir-flink.git当前的版本应该是flink1.12.2，kudu是1.13.0。
按照我自己的环境将flink升级到1.14.0也就是目前最新的版本，kudu降到1.10.0。
由于flink api的改动，所以修改了一丢丢源码，同时最后编译打包时跳过了deprecation警告，得到目前的包。
【环境：cdh6.3.2（kudu1.10.0）+flink1.14.0+scala2.11.12】简单测了一下可以使用，如遇问题欢迎骚扰~
2021-12-07 18:01:31
86KB
1
flink sql 连接clickhouse,需要修改flink -jdbc-connector 包,我已经编译完成,需要的自行下载
2021-11-04 13:09:10
195KB
1