You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by go...@apache.org on 2019/05/10 20:14:49 UTC
[beam] branch master updated: Downgrade missing coder error logs to
info logs.
This is an automated email from the ASF dual-hosted git repository.
goenka pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 2650c52 Downgrade missing coder error logs to info logs.
new 117a2d6 Merge pull request #8533 from aaltay/errtinf
2650c52 is described below
commit 2650c5282833ce146df23ee488c7099a96676106
Author: Ahmet Altay <al...@google.com>
AuthorDate: Wed May 8 15:05:22 2019 -0700
Downgrade missing coder error logs to info logs.
---
sdks/python/apache_beam/runners/worker/bundle_processor.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/sdks/python/apache_beam/runners/worker/bundle_processor.py b/sdks/python/apache_beam/runners/worker/bundle_processor.py
index 24ac478..b04dabf 100644
--- a/sdks/python/apache_beam/runners/worker/bundle_processor.py
+++ b/sdks/python/apache_beam/runners/worker/bundle_processor.py
@@ -870,7 +870,7 @@ def create(factory, transform_id, transform_proto, grpc_port, consumers):
if grpc_port.coder_id:
output_coder = factory.get_coder(grpc_port.coder_id)
else:
- logging.error(
+ logging.info(
'Missing required coder_id on grpc_port for %s; '
'using deprecated fallback.',
transform_id)
@@ -895,7 +895,7 @@ def create(factory, transform_id, transform_proto, grpc_port, consumers):
if grpc_port.coder_id:
output_coder = factory.get_coder(grpc_port.coder_id)
else:
- logging.error(
+ logging.info(
'Missing required coder_id on grpc_port for %s; '
'using deprecated fallback.',
transform_id)