You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2022/03/29 11:43:06 UTC
[beam] branch master updated (aa9b2aa -> 48557d0)
This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from aa9b2aa Merge pull request #17195 [BEAM-14163] Fix typo in single core per container logic.
new 050e12a feat: remove the metadata table after the pipeline finishes
new 1cc6884 test: add test for metadata table dropping
new 3513b38 Merge branch 'master' of github.com:hengfengli/beam into remove-metadata-table
new 8d9880f test: disable SpannerIO.readChangeStream test
new 48557d0 Merge pull request #17182 from [BEAM-14185]: remove the metadata table after the pipeline finishes for Spanner Change Streams Connector
The 35099 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:
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 21 ++++++++---
.../dofn/CleanUpReadChangeStreamDoFn.java} | 20 ++++++----
.../changestreams/it/IntegrationTestEnv.java | 18 ++++++---
.../changestreams/it/SpannerChangeStreamIT.java | 44 +++++++++++++++++++---
...nnerChangeStreamOrderedWithinKeyGloballyIT.java | 2 +
.../it/SpannerChangeStreamOrderedWithinKeyIT.java | 2 +
6 files changed, 81 insertions(+), 26 deletions(-)
copy sdks/java/{extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamSqlOutputToConsoleFn.java => io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dofn/CleanUpReadChangeStreamDoFn.java} (59%)