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

Posted to commits@beam.apache.org by ja...@apache.org on 2022/11/16 14:15:44 UTC

[beam] 01/01: Merge pull request #24192: Re-use serializable pipeline options when already available.

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

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

commit e83a996d4374d467d95bcfad7166905622ec615c
Merge: 2fc56ec663e ffdee0b6edb
Author: Jan Lukavský <je...@seznam.cz>
AuthorDate: Wed Nov 16 15:15:31 2022 +0100

    Merge pull request #24192: Re-use serializable pipeline options when already available.

 .../flink/translation/types/CoderTypeInformation.java   |  6 +++++-
 .../wrappers/streaming/KvToByteBufferKeySelector.java   |  2 +-
 .../wrappers/streaming/SdfByteBufferKeySelector.java    |  2 +-
 .../wrappers/streaming/WorkItemKeySelector.java         |  2 +-
 .../wrappers/streaming/io/UnboundedSourceWrapper.java   |  3 +--
 .../streaming/state/FlinkBroadcastStateInternals.java   | 17 ++++++++---------
 6 files changed, 17 insertions(+), 15 deletions(-)