[ 
https://issues.apache.org/jira/browse/FLINK-15491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009034#comment-17009034
 ] 

Yun Tang edited comment on FLINK-15491 at 1/6/20 5:32 PM:
----------------------------------------------------------

This is because the zk path is only created by appending two string 
[together|https://github.com/apache/flink/blob/229d02147ee4d57deb05c28a5626f44aca7fcba5/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRunningJobsRegistry.java#L121].

{code:java}
        private String createZkPath(JobID jobID) {
                return runningJobPath + jobID.toString();
        }
{code}

But from what I can see, even we forget to add a slash in the end, that would 
not cause any real harmful result but only a strange path.



was (Author: yunta):
This is because the zk path is only created by append two string 
[together|https://github.com/apache/flink/blob/229d02147ee4d57deb05c28a5626f44aca7fcba5/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRunningJobsRegistry.java#L121].

{code:java}
        private String createZkPath(JobID jobID) {
                return runningJobPath + jobID.toString();
        }
{code}

But from what I can see, even we forget to add a slash in the end, that would 
not cause any real harmful result but only a strange path.


> Fix incorrect path while missing trailing slash of 
> high-availability.zookeeper.path.running-registry parameter.
> ---------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-15491
>                 URL: https://issues.apache.org/jira/browse/FLINK-15491
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Configuration
>    Affects Versions: 1.9.0
>            Reporter: Qingxin Wu
>            Priority: Minor
>         Attachments: 03a8857d50e911f9d09c68df0.png
>
>
> By default, the value of configuration 
> *high-availability.zookeeper.path.running-registry* must end with a slash. If 
> we set this parameter as following:
> {code:java}
> high-availability.zookeeper.path.running-registry: /running_job_registry{code}
> an incorrect path will be created, as shown in the following picture
> !03a8857d50e911f9d09c68df0.png!
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to