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 <xia...@xiaomi.com> Authored: Wed May 6 16:19:44 2015 +0800 Committer: xiajun <xia...@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); }
