storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/3] storm git commit: STORM-810: PartitionManager should commit latest offset before close
Date Wed, 01 Jul 2015 13:42:31 GMT
Repository: storm
Updated Branches:
  refs/heads/master 4a66ab97f -> 30df970e2


STORM-810: PartitionManager should commit latest offset before close


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

Branch: refs/heads/master
Commit: 0380a42f7ddaf48ce17eabb67ec18a27cd258f69
Parents: ea0fe12
Author: xiajun <xiajun@xiaomi.com>
Authored: Wed May 6 16:19:44 2015 +0800
Committer: xiajun <xiajun@xiaomi.com>
Committed: Wed May 6 16:19:44 2015 +0800

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


http://git-wip-us.apache.org/repos/asf/storm/blob/0380a42f/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 00ab981..a7ed879 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
@@ -269,6 +269,7 @@ public class PartitionManager {
     }
 
     public void close() {
+        commit();
         _connections.unregister(_partition.host, _partition.partition);
     }
 


Mime
View raw message