You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by nw...@apache.org on 2019/01/26 04:38:13 UTC

[incubator-heron] branch master updated: Fix memory leak in stmgr when measuring tuple data size (#3175)

This is an automated email from the ASF dual-hosted git repository.

nwang 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 d6afa82  Fix memory leak in stmgr when measuring tuple data size (#3175)
d6afa82 is described below

commit d6afa82676ec064ee581bba80d9f3a7a17c060c8
Author: Ning Wang <nw...@twitter.com>
AuthorDate: Fri Jan 25 20:38:08 2019 -0800

    Fix memory leak in stmgr when measuring tuple data size (#3175)
---
 heron/stmgr/src/cpp/manager/stmgr-server.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/heron/stmgr/src/cpp/manager/stmgr-server.cpp b/heron/stmgr/src/cpp/manager/stmgr-server.cpp
index 889dfba..a6ac8bd 100644
--- a/heron/stmgr/src/cpp/manager/stmgr-server.cpp
+++ b/heron/stmgr/src/cpp/manager/stmgr-server.cpp
@@ -175,6 +175,7 @@ void StMgrServer::HandleTupleStreamMessage(Connection* _conn,
       ack_tuples_from_stmgrs_metrics_->incr_by(tuple_set->control().acks_size());
       fail_tuples_from_stmgrs_metrics_->incr_by(tuple_set->control().fails_size());
     }
+    __global_protobuf_pool_release__(tuple_set);
 
     stmgr_->HandleStreamManagerData(iter->second, _message);
   }