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 <[email protected]> Authored: Thu May 12 10:56:44 2016 -0700 Committer: Yi Pan (Data Infrastructure) <[email protected]> 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) } }
