org.apache.flink.runtime.jobmanager

Class ZooKeeperJobGraphStoreWatcher

java.lang.Object

org.apache.flink.runtime.jobmanager.ZooKeeperJobGraphStoreWatcher

All Implemented Interfaces:

JobGraphStoreWatcher

public class ZooKeeperJobGraphStoreWatcher
extends Object
implements JobGraphStoreWatcher

JobGraphStoreWatcher implementation for ZooKeeper.

Each job graph creates ZNode:

 +----O /flink/jobgraphs/<job-id> 1 [persistent]
 .
 .
 .
 +----O /flink/jobgraphs/<job-id> N [persistent]
 

The root path is watched to detect concurrent modifications in corner situations where multiple instances operate concurrently. The job manager acts as a JobGraphStore.JobGraphListener to react to such situations.

Constructor Summary

Constructors

Constructor and Description
ZooKeeperJobGraphStoreWatcher(org.apache.flink.shaded.curator5.org.apache.curator.framework.recipes.cache.PathChildrenCache pathCache)

Method Summary

Modifier and Type	Method and Description
void	start(JobGraphStore.JobGraphListener jobGraphListener) Start the watcher on JobGraphStore.
void	stop() Stop the watcher on JobGraphStore.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZooKeeperJobGraphStoreWatcher

public ZooKeeperJobGraphStoreWatcher(org.apache.flink.shaded.curator5.org.apache.curator.framework.recipes.cache.PathChildrenCache pathCache)

Method Detail

start

public void start(JobGraphStore.JobGraphListener jobGraphListener)
           throws Exception

Description copied from interface: JobGraphStoreWatcher

Start the watcher on JobGraphStore.

Specified by:

start in interface JobGraphStoreWatcher

Parameters:

jobGraphListener - use jobGraphListener to notify the DefaultJobGraphStore

Throws:

Exception - when start internal services

stop

public void stop()
          throws Exception

Description copied from interface: JobGraphStoreWatcher

Stop the watcher on JobGraphStore.

Specified by:

stop in interface JobGraphStoreWatcher

Throws:

Exception - when stop internal services