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/15 18:41:08 UTC
git commit: SAMZA-384;
speed up taskinstance send method by removing logging
Repository: incubator-samza
Updated Branches:
refs/heads/master 1e2cfe22e -> 5cfb13ebd
SAMZA-384; speed up taskinstance send method by removing logging
Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/5cfb13eb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/5cfb13eb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/5cfb13eb
Branch: refs/heads/master
Commit: 5cfb13ebdd779bbd59b240e3f9a5fd854715a6ab
Parents: 1e2cfe2
Author: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Authored: Fri Aug 15 09:41:02 2014 -0700
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Committed: Fri Aug 15 09:41:02 2014 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/samza/container/TaskInstance.scala | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/5cfb13eb/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 9484ddb..3b59fe3 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,8 +164,6 @@ class TaskInstance(
collector.reset
} else {
- trace("Skipping send for taskName %s because no messages were collected." format taskName)
-
metrics.sendsSkipped.inc
}
}