[jira] [Created] (FLINK-13370) Allow Custom CuratorFramework

[Shang Yuanchun (Jira)]

Matt Lloyd created FLINK-13370:
----------------------------------

             Summary: 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


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)