[
https://issues.apache.org/jira/browse/FLINK-13370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891776#comment-16891776
]
Matt Lloyd commented on FLINK-13370:
------------------------------------
Thanks [~Tison]
I was under the impression that if my interface returned an instance of
org.apache.curator.framework.CuratorFramework then it would just slot in, but I
guess that as Flink is shading curator, it's actually expecting a different
class and so won't work.
Guess I'll have to try and get our Zookeeper instance working with sasl
> Allow Custom CuratorFramework
> -----------------------------
>
> Key: FLINK-13370
> URL: https://issues.apache.org/jira/browse/FLINK-13370
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Coordination
> Reporter: Matt Lloyd
> Priority: Major
>
> Due to how the CuratorFrameworkFactory is implemented in Flink, I am unable
> to use it with my existing Zookeeper clusters which rely on custom
> authentication.
> To allow for this situation, I propose making the following changes to allow
> users to pass in custom factory methods (in a similar vein to FLINK-8660).
> * Create {{FlinkCuratorFactory}} interface
> * Move the current [CuratorFramework factory
> method|[https://github.com/apache/flink/blob/11a8234b50586d476371c64f9d751e8e65fdad0a/flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java#L73]]
> into a Factory class that implements the {{FlinkCuratorFactory}} interface
> * Add new config {{zookeeper.curator.factory}} that defaults to the current
> implementation or takes the FQN of a user defined factory
> * Replace the existing [CuratorFramework factory
> method|[https://github.com/apache/flink/blob/11a8234b50586d476371c64f9d751e8e65fdad0a/flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java#L73]]
> to uses the {{zookeeper.curator.factory}} config to call the appropriate
> factory.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
