This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 0dc2ad2 Merge pull request #9632: [BEAM-7962] Drop support for Flink
1.5 and 1.6
add c4f4109 [BEAM-8157] Introduce encode_nested method on Python SDK Coder
add 61b8fa0 [BEAM-8157] Ensure key encoding for state requests is
consistent across SDKs
add fce6380 Merge pull request #9484: [BEAM-8157] Ensure key encoding for
state requests is consistent across SDKs
No new revisions were added by this update.
Summary of changes:
.../FlinkStreamingPortablePipelineTranslator.java | 6 -----
.../streaming/ExecutableStageDoFnOperator.java | 8 ++-----
.../wrappers/streaming/FlinkKeyUtils.java | 11 ++++++---
.../streaming/state/FlinkStateInternals.java | 12 ++--------
.../wrappers/streaming/DoFnOperatorTest.java | 12 +++++-----
.../wrappers/streaming/FlinkKeyUtilsTest.java | 26 +++++++++++++++-------
.../beam/fn/harness/state/FnApiStateAccessor.java | 6 ++++-
sdks/python/apache_beam/coders/coders.py | 8 +++++++
.../apache_beam/runners/worker/bundle_processor.py | 6 +++--
9 files changed, 53 insertions(+), 42 deletions(-)
