This is an automated email from the ASF dual-hosted git repository.
goenka pushed a change to branch release-2.13.0
in repository https://gitbox.apache.org/repos/asf/beam.git.
from aaccebc Merge pull request #8571: [BEAM-7239] Do not close DataSource
on Teardown on JdbcIO
new ab927c4 Merge pull request #8472: [BEAM-7126] Remove redundant key
encoding for state backend
new a4418c2 [BEAM-7271] adding UTF8 String coder to Java SDK ModelCoder
new 0d386ec Merge pull request #8575 from mxm/release-2.13.0
The 21407 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../FlinkStreamingPortablePipelineTranslator.java | 6 +++
.../streaming/ExecutableStageDoFnOperator.java | 18 ++++---
.../wrappers/streaming/FlinkKeyUtils.java | 7 +--
.../streaming/ExecutableStageDoFnOperatorTest.java | 55 +++++++++++++++++++---
.../worker/graph/LengthPrefixUnknownCoders.java | 3 +-
.../graph/LengthPrefixUnknownCodersTest.java | 13 ++---
.../runners/dataflow/dataflow_runner.py | 6 +--
7 files changed, 74 insertions(+), 34 deletions(-)
