diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRunningJobsRegistry.java b/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRunningJobsRegistry.java
index 1a84b374d95fe..d51c22805decc 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRunningJobsRegistry.java
+++ b/flink-runtime/src/main/java/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));