storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [19/23] git commit: STORM-352: fix logic for writing offsets to ZooKeeper
Date Thu, 19 Jun 2014 21:06:30 GMT
STORM-352: fix logic for writing offsets to ZooKeeper


Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/57851bb6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/57851bb6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/57851bb6

Branch: refs/heads/security
Commit: 57851bb6be4caec950541bcb1f01529224e52af4
Parents: d448e34
Author: P. Taylor Goetz <ptgoetz@gmail.com>
Authored: Fri Jun 13 14:01:32 2014 -0400
Committer: P. Taylor Goetz <ptgoetz@gmail.com>
Committed: Fri Jun 13 14:13:50 2014 -0400

----------------------------------------------------------------------
 external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/57851bb6/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
index d868e50..2c32a2c 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
@@ -214,7 +214,7 @@ public class PartitionManager {
 
     public void commit() {
         long lastCompletedOffset = lastCompletedOffset();
-        if (lastCompletedOffset != lastCompletedOffset) {
+        if (_committedTo != lastCompletedOffset) {
             LOG.debug("Writing last completed offset (" + lastCompletedOffset + ") to ZK
for " + _partition + " for topology: " + _topologyInstanceId);
             Map<Object, Object> data = (Map<Object, Object>) ImmutableMap.builder()
                     .put("topology", ImmutableMap.of("id", _topologyInstanceId,


Mime
View raw message