You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by hu...@apache.org on 2018/07/07 05:49:20 UTC
[incubator-heron] branch master updated: Add log in Bolt/Spout
instances after persisting state (#2954)
This is an automated email from the ASF dual-hosted git repository.
huijun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
The following commit(s) were added to refs/heads/master by this push:
new e161575 Add log in Bolt/Spout instances after persisting state (#2954)
e161575 is described below
commit e16157569b6d844be94b6301cac4626a45fde3c0
Author: Ning Wang <nw...@twitter.com>
AuthorDate: Fri Jul 6 22:49:17 2018 -0700
Add log in Bolt/Spout instances after persisting state (#2954)
---
heron/instance/src/java/org/apache/heron/instance/bolt/BoltInstance.java | 1 +
.../instance/src/java/org/apache/heron/instance/spout/SpoutInstance.java | 1 +
2 files changed, 2 insertions(+)
diff --git a/heron/instance/src/java/org/apache/heron/instance/bolt/BoltInstance.java b/heron/instance/src/java/org/apache/heron/instance/bolt/BoltInstance.java
index 6286e15..cd49dac 100644
--- a/heron/instance/src/java/org/apache/heron/instance/bolt/BoltInstance.java
+++ b/heron/instance/src/java/org/apache/heron/instance/bolt/BoltInstance.java
@@ -157,6 +157,7 @@ public class BoltInstance implements IInstance {
} finally {
collector.lock.unlock();
}
+ LOG.info("State persisted for checkpoint: " + checkpointId);
}
@SuppressWarnings("unchecked")
diff --git a/heron/instance/src/java/org/apache/heron/instance/spout/SpoutInstance.java b/heron/instance/src/java/org/apache/heron/instance/spout/SpoutInstance.java
index 65d80ef..f7c077a 100644
--- a/heron/instance/src/java/org/apache/heron/instance/spout/SpoutInstance.java
+++ b/heron/instance/src/java/org/apache/heron/instance/spout/SpoutInstance.java
@@ -165,6 +165,7 @@ public class SpoutInstance implements IInstance {
} finally {
collector.lock.unlock();
}
+ LOG.info("State persisted for checkpoint: " + checkpointId);
}
@SuppressWarnings("unchecked")