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%)