[
https://issues.apache.org/jira/browse/FLINK-15491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009756#comment-17009756
]
Qingxin Wu edited comment on FLINK-15491 at 1/7/20 11:39 PM:
-------------------------------------------------------------
Hi [~yunta] , thanks for your comment. Maybe we could fix this strange path by
removing the trialing slash of *runningJobPath ,* and creating zk path like
this:
{code:java}
private String createZkPath(JobID jobID) {
return runningJobPath + String.format("/%s", jobID.toString());
}{code}
was (Author: wuqingxinnn):
Hi [~yunta] , thanks for your review. Maybe we could fix this strange path by
removing the trialing slash of *runningJobPath ,* and creating zk path like
this:
{code:java}
private String createZkPath(JobID jobID) {
return runningJobPath + String.format("/%s", jobID.toString());
}{code}
> 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)
