You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lc...@apache.org on 2020/02/04 19:41:03 UTC

[beam] branch master updated (39c4a9f -> af3ad39)

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 39c4a9f  Merge pull request #10563: [BEAM-7310] Add support of Confluent Schema Registry for KafkaIO
     add af3ad39  [BEAM-4150] Remove fallback case for coder not specified within RemoteGrpcPort. (#10755)

No new revisions were added by this update.

Summary of changes:
 .../worker/graph/RegisterNodeFunction.java         | 26 +++++++++---
 sdks/go/pkg/beam/core/runtime/exec/translate.go    | 49 +++++++---------------
 .../beam/fn/harness/BeamFnDataReadRunner.java      | 27 ++----------
 .../beam/fn/harness/BeamFnDataWriteRunner.java     | 34 +++------------
 .../beam/fn/harness/BeamFnDataReadRunnerTest.java  |  1 -
 .../beam/fn/harness/BeamFnDataWriteRunnerTest.java |  1 -
 .../apache_beam/runners/worker/bundle_processor.py | 18 +-------
 7 files changed, 45 insertions(+), 111 deletions(-)