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)