[incubator-heron] branch master updated: add rate limit change log in stream manager (#2822)

[unknown <""...@apache.org>]

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

(unknown) 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 c5caf72  add rate limit change log in stream manager (#2822)
c5caf72 is described below

commit c5caf723f37c36f3bfa8e8efcfade006102a08ba
Author: Ning Wang <nw...@twitter.com>
AuthorDate: Thu Mar 29 23:27:07 2018 -0700

    add rate limit change log in stream manager (#2822)
---
 heron/stmgr/src/cpp/manager/instance-server.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/heron/stmgr/src/cpp/manager/instance-server.cpp b/heron/stmgr/src/cpp/manager/instance-server.cpp
index 1fc0c47..7288749 100644
--- a/heron/stmgr/src/cpp/manager/instance-server.cpp
+++ b/heron/stmgr/src/cpp/manager/instance-server.cpp
@@ -448,8 +448,10 @@ void InstanceServer::SetRateLimit(const proto::system::PhysicalPlan& _pplan,
   // There should be parallelism hint and the per instance rate limit should be at least
   // one byte per second
   if (parallelism > 0 && read_bsp > parallelism && burst_read_bsp > parallelism) {
+    LOG(INFO) << "Set rate limit in " << _component << " to " << read_bsp << "/" << burst_read_bsp;
     _conn->setRateLimit(read_bsp / parallelism, burst_read_bsp / parallelism);
   } else {
+    LOG(INFO) << "Disable rate limit in " << _component;
     _conn->disableRateLimit();
   }
 }

-- 
To stop receiving notification emails like this one, please contact
(unknown)@apache.org.