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 <[email protected]> Authored: Fri Aug 15 15:37:23 2014 -0700 Committer: Chris Riccomini <[email protected]> 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 } }
