[hotfix][zookeeper] Log changes to SchedulingState

spotify · Jan 22, 2020 · 1b6a074 · 1b6a074
1 parent fbc1ef7
commit 1b6a074
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...ava/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRunningJobsRegistry.java b/...ava/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRunningJobsRegistry.java
@@ -25,6 +25,8 @@
 
 import org.apache.curator.framework.CuratorFramework;
 import org.apache.zookeeper.data.Stat;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.nio.charset.Charset;
@@ -37,6 +39,8 @@
  */
 public class ZooKeeperRunningJobsRegistry implements RunningJobsRegistry {
 
+ private static final Logger LOG = LoggerFactory.getLogger(ZooKeeperRunningJobsRegistry.class);
+
  private static final Charset ENCODING = Charset.forName("utf-8");
 
  /** The ZooKeeper client to use. */
@@ -122,6 +126,7 @@ private String createZkPath(JobID jobID) {
  }
 
  private void writeEnumToZooKeeper(JobID jobID, JobSchedulingStatus status) throws Exception {
+ LOG.debug("Setting scheduling state for job {} to {}.", jobID, status);
  final String zkPath = createZkPath(jobID);
  this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());
  this.client.setData().forPath(zkPath, status.name().getBytes(ENCODING));