You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ni...@apache.org on 2016/05/12 17:57:20 UTC
samza git commit: SAMZA-852: better logging when failed to create a
system
Repository: samza
Updated Branches:
refs/heads/master 78a85047c -> a460a82e3
SAMZA-852: better logging when failed to create a system
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/a460a82e
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/a460a82e
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/a460a82e
Branch: refs/heads/master
Commit: a460a82e366404498bac676a6b41acc27d458992
Parents: 78a8504
Author: Jacob Maes <ja...@gmail.com>
Authored: Thu May 12 10:56:44 2016 -0700
Committer: Yi Pan (Data Infrastructure) <ni...@gmail.com>
Committed: Thu May 12 10:56:44 2016 -0700
----------------------------------------------------------------------
.../main/scala/org/apache/samza/container/SamzaContainer.scala | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/a460a82e/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
----------------------------------------------------------------------
diff --git a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
index 5462208..cf3c4c0 100644
--- a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
+++ b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
@@ -187,8 +187,7 @@ object SamzaContainer extends Logging {
(systemName, systemFactory.getConsumer(systemName, config, samzaContainerMetrics.registry))
} catch {
case e: Exception =>
- info("Failed to create a consumer for %s, so skipping." format systemName)
- debug("Exception detail:", e)
+ error("Failed to create a consumer for %s, so skipping." format(systemName), e)
(systemName, null)
}
})
@@ -204,8 +203,7 @@ object SamzaContainer extends Logging {
(systemName, systemFactory.getProducer(systemName, config, samzaContainerMetrics.registry))
} catch {
case e: Exception =>
- info("Failed to create a producer for %s, so skipping." format systemName)
- debug("Exception detail:", e)
+ error("Failed to create a producer for %s, so skipping." format(systemName), e)
(systemName, null)
}
}