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 33ea9388fb9 Use now + 2mins as the end timestamp for change stream
read API if the (#34967)
add 5532af8438f Update JupyterLab Sidepanel yarn.lock file (#35195)
add b09e5ef4bcd Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks
(#35366)
add b74c4960216 estimate request size in BQ streaming inserts when
with_auto_sharding is true (#35212)
add 0d6c94a8727 Fix PubsubIOLT (#35372)
add 8c832e93423 Fix the issue of sliding window firing early. (#35385)
add 2feb407ea0e Fix suppressed Spotbugs issues
add 4c1c2daa17d Fix suppressed Spotbugs issues (#35394)
add 01411e71197 Bump google.golang.org/api from 0.237.0 to 0.238.0 in
/sdks (#35368)
add f2d0dc8aecc Improve LogElements to show pane_info and timestamps in
seconds. (#35387)
add dc213a998c3 Add change stream new record models and tests. (#35258)
No new revisions were added by this update.
Summary of changes:
.../datatokenization/utils/SchemasUtils.java | 8 +-
.../subprocess/SubProcessPipelineOptions.java | 2 +-
.../configuration/SubProcessConfiguration.java | 12 +-
.../examples/kotlin/cookbook/TriggerExample.kt | 3 +-
.../org/apache/beam/it/gcp/pubsub/PubsubIOLT.java | 9 +-
sdks/go.mod | 4 +-
sdks/go.sum | 8 +-
.../prism/internal/engine/elementmanager.go | 29 +-
...rtitionsRecord.java => PartitionEndRecord.java} | 80 +-
...itionsRecord.java => PartitionEventRecord.java} | 79 +-
...itionsRecord.java => PartitionStartRecord.java} | 61 +-
...RecordTest.java => PartitionEndRecordTest.java} | 18 +-
...cordTest.java => PartitionEventRecordTest.java} | 18 +-
...cordTest.java => PartitionStartRecordTest.java} | 18 +-
.../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 5 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOUtils.java | 7 +-
.../beam/sdk/io/synthetic/SyntheticStep.java | 6 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 73 +-
sdks/python/apache_beam/io/gcp/bigquery_test.py | 141 +
.../apache-beam-jupyterlab-sidepanel/.yarnrc.yml | 4 +-
.../apache-beam-jupyterlab-sidepanel/package.json | 1 +
.../apache-beam-jupyterlab-sidepanel/yarn.lock | 17809 +++++++++++--------
.../portability/fn_api_runner/fn_runner_test.py | 24 +
sdks/python/apache_beam/transforms/util.py | 42 +-
sdks/python/apache_beam/transforms/util_test.py | 46 +-
25 files changed, 10457 insertions(+), 8050 deletions(-)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{ChildPartitionsRecord.java
=> PartitionEndRecord.java} (51%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{ChildPartitionsRecord.java
=> PartitionEventRecord.java} (52%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{ChildPartitionsRecord.java
=> PartitionStartRecord.java} (62%)
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{HeartbeatRecordTest.java
=> PartitionEndRecordTest.java} (73%)
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{HeartbeatRecordTest.java
=> PartitionEventRecordTest.java} (72%)
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{ChildPartitionsRecordTest.java
=> PartitionStartRecordTest.java} (72%)
copy .test-infra/metrics/sync/jenkins/requirements.txt =>
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/.yarnrc.yml
(96%)
