You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2014/08/16 00:37:33 UTC
git commit: Revert "SAMZA-384;
speed up taskinstance send method by removing logging"
Repository: incubator-samza
Updated Branches:
refs/heads/master 5cfb13ebd -> 82aa01fa6
Revert "SAMZA-384; speed up taskinstance send method by removing logging"
This reverts commit 5cfb13ebdd779bbd59b240e3f9a5fd854715a6ab.
Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/82aa01fa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/82aa01fa
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/82aa01fa
Branch: refs/heads/master
Commit: 82aa01fa6a38a1831828279d0f21ed5ea499d1a0
Parents: 5cfb13e
Author: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Authored: Fri Aug 15 15:37:23 2014 -0700
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Committed: Fri Aug 15 15:37:23 2014 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/samza/container/TaskInstance.scala | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/82aa01fa/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala
----------------------------------------------------------------------
diff --git a/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala b/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala
index 3b59fe3..9484ddb 100644
--- a/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala
+++ b/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala
@@ -164,6 +164,8 @@ class TaskInstance(
collector.reset
} else {
+ trace("Skipping send for taskName %s because no messages were collected." format taskName)
+
metrics.sendsSkipped.inc
}
}