This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from a5fbc8ed163 [BEAM-14347] Add generic registration for accumulators
(#17579)
add c654733b45e [BEAM-12918] Add PostCommit_Java_Tpcds_Spark job
add 5c21fbccec5 Merge pull request #15679 from
aromanenko-dev/BEAM-12918-tpcds-jenkins
add 0df0a34b6e6 [BEAM-14448] add datastore test
add 98044dd526f Merge pull request #17592 from [BEAM-14448] add datastore
exception handling test
add f3c06e39b1b [BEAM-14423] Add test cases for
BigtableIO.BigtableWriterFn fails due to writeRecord
add 21d52f260bb Merge pull request #17593 from [BEAM-14423] Add test cases
for BigtableIO.BigtableWriterFn fails due to writeRecord
add c6322765daf [BEAM-14229] Fix SyntheticUnboundedSource duplication from
checkpoint issue (#17600)
add abf488ee880 Revert "Merge pull request #17517 from [BEAM-14383]
Improve "FailedRows" errors returned by beam.io.WriteToBigQuery"
add 2f1117b00da Merge pull request #17601 from [BEAM-14447] Revert "Merge
pull request #17517 from [BEAM-14383] Improve "FailedRo…
add 5674f181412 [BEAM-14347] Rename registration package to register
(#17603)
add df67c817184 [BEAM-11104] Add self-checkpointing integration test
(#17590)
No new revisions were added by this update.
Summary of changes:
.github/codecov.yml | 4 +-
.../jenkins/job_PostCommit_Java_Tpcds_Spark.groovy | 188 +++++++++++++++++++++
CHANGES.md | 1 -
sdks/go/pkg/beam/{registration => register}/doc.go | 8 +-
.../pkg/beam/{registration => register}/emitter.go | 8 +-
.../example_register_test.go} | 16 +-
.../go/pkg/beam/{registration => register}/iter.go | 6 +-
.../registration.go => register/register.go} | 4 +-
.../registration.tmpl => register/register.tmpl} | 4 +-
.../register_test.go} | 2 +-
sdks/go/pkg/beam/testing/ptest/ptest.go | 8 +
sdks/go/test/integration/integration.go | 15 ++
.../test/integration/primitives/checkpointing.go | 94 +++++++++++
...{window_panes_test.go => checkpointing_test.go} | 5 +-
.../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 90 +++++++++-
.../beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 16 ++
.../io/synthetic/SyntheticRecordsCheckpoint.java | 25 +--
.../sdk/io/synthetic/SyntheticUnboundedSource.java | 27 ++-
.../io/synthetic/SyntheticUnboundedSourceTest.java | 6 +-
.../beam/sdk/tpcds/TpcdsParametersReader.java | 3 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 8 +-
.../apache_beam/io/gcp/bigquery_write_it_test.py | 91 ----------
22 files changed, 466 insertions(+), 163 deletions(-)
create mode 100644 .test-infra/jenkins/job_PostCommit_Java_Tpcds_Spark.groovy
rename sdks/go/pkg/beam/{registration => register}/doc.go (77%)
rename sdks/go/pkg/beam/{registration => register}/emitter.go (95%)
rename sdks/go/pkg/beam/{registration/example_registration_test.go =>
register/example_register_test.go} (83%)
rename sdks/go/pkg/beam/{registration => register}/iter.go (97%)
rename sdks/go/pkg/beam/{registration/registration.go => register/register.go}
(99%)
rename sdks/go/pkg/beam/{registration/registration.tmpl =>
register/register.tmpl} (99%)
rename sdks/go/pkg/beam/{registration/registration_test.go =>
register/register_test.go} (99%)
create mode 100644 sdks/go/test/integration/primitives/checkpointing.go
copy sdks/go/test/integration/primitives/{window_panes_test.go =>
checkpointing_test.go} (95%)
