Updated Branches: refs/heads/master 48b946c0d -> 86492c430
SAMZA-135; fix memory leak in LevelDbKeyValueStore.putAll. Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/86492c43 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/86492c43 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/86492c43 Branch: refs/heads/master Commit: 86492c430967d53d1f519129a997a3bbf5222a2f Parents: 48b946c Author: Chris Riccomini <[email protected]> Authored: Fri Jan 24 09:17:14 2014 -0800 Committer: Chris Riccomini <[email protected]> Committed: Fri Jan 24 09:17:14 2014 -0800 ---------------------------------------------------------------------- .../scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/86492c43/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala ---------------------------------------------------------------------- diff --git a/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala b/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala index d37acf9..4c14aa2 100644 --- a/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala +++ b/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala @@ -90,6 +90,7 @@ class LevelDbKeyValueStore( } } db.write(batch) + batch.close metrics.puts.inc(wrote) metrics.deletes.inc(deletes) }
