You must rebuild Flink while overriding zookeeper.version property to
match your MapR setup.
For example: mvn clean package -Dzookeeper.version=3.4.5-mapr-1604
Note that you will also have to configure the MapR repository in your
local setup as described here
<https://maven.apache.org/guides/mini/guide-multiple-repositories.html>.
On 05/02/2020 15:12, Maxim Parkachov wrote:
Hi everyone,
I have already written about issue with Flink 1.9 on secure MapR
cluster and high availability. The issue was resolved with custom
compiled Flink with vendor mapr repositories enabled. The history
could be found
https://www.mail-archive.com/user@flink.apache.org/msg28235.html
Unfortunately, in current 1.10 RC vendor repositories were removed and
I'm failing to get working configuration. Current situation with 1.10
RC and secure MapR cluster:
1. Without HA, Flink uses class path provided zookeeper jar (mapr
specific) and everything works fine.
2. With HA enabled, Flink uses shaded zookeeper
(org.apache.flink.shaded.zookeeper.org.apache.zookeeper.ClientCnxn)
which doesn't have MapR specific changes and fails to authenticate.
I would really appreciate any help in resolving this issue.I'm ready
to provide any required details.
Regards,
Maxim.
