好像不需要改源码
'connector.version' = ‘1.4.3’ 也可以往2.x版本里写
| |
Sun.Zhu
|
|
17626017...@163.com
|
签名由网易邮箱大师定制
On 06/15/2020 19:22，Zhou Zach wrote：
改了源码，可以了
在 2020-06-15 16:17:46，"Leonard Xu" 写道：
Hi
在 2020年6月15日，15:36，Zhou Zach 写道：
'connector.version' expects '1.4.3', but is '2.1.0'
改了源码，可以了
在 2020-06-15 16:17:46，"Leonard Xu" 写道：
>Hi
>
>
>> 在 2020年6月15日，15:36，Zhou Zach 写道：
>>
>> 'connector.version' expects '1.4.3', but is '2.1.0'
>
>Hbase connector只支持1.4.3的版本，其他不支持，但之前看有社区用户用1.4.3的connector写入高版本的case，你可以试下。
>
>祝好
>Leonard Xu
Hi
> 在 2020年6月15日，15:36，Zhou Zach 写道：
>
> 'connector.version' expects '1.4.3', but is '2.1.0'
Hbase connector只支持1.4.3的版本，其他不支持，但之前看有社区用户用1.4.3的connector写入高版本的case，你可以试下。
祝好
Leonard Xu
flink version: 1.10.0
hbase version: 2.1.0
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/Users/Zach/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.4.1/log4j-slf4j-impl-2.4.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding
