You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/09/13 05:34:56 UTC
[beam] branch nightly-refs/heads/master updated (1526ca8c4cc -> d9405959199)
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 1526ca8c4cc Improvements to SchemaTransform implementations for BQ and Kafka (#23045)
add b1f23fd066b [TPC-DS] Use common queries argument for Jenkins jobs (#23139)
add 5515f7a35d7 pubsublite: Reduce commit logspam (#22762)
add 2113ffcac3f Added documentation in ACTIONS.md file (#23159)
add f7073818a9e Bump dataflow java fnapi container version to beam-master-20220830 (#23183)
add f31b277c0ec [Issue#23071] Fix AfterProcessingTime for Python to behave like Java (#23100)
add d9405959199 Don't depend on java 11 docker container for go test (#23197)
No new revisions were added by this update.
Summary of changes:
.github/ACTIONS.md | 73 +++++++++++++++++--
.test-infra/jenkins/TpcdsDatabaseProperties.groovy | 2 +
.../job_PostCommit_Java_Tpcds_Dataflow.groovy | 5 +-
.../jenkins/job_PostCommit_Java_Tpcds_Flink.groovy | 5 +-
.../jenkins/job_PostCommit_Java_Tpcds_Spark.groovy | 9 +--
runners/google-cloud-dataflow-java/build.gradle | 2 +-
sdks/go/test/build.gradle | 4 --
.../pubsublite/internal/CheckpointMarkImpl.java | 7 +-
.../gcp/pubsublite/internal/CloserReference.java | 68 ++++++++++++++++++
.../pubsublite/internal/UnboundedReaderImpl.java | 6 +-
.../pubsublite/internal/UnboundedSourceImpl.java | 2 +-
.../internal/CheckpointMarkImplTest.java | 2 +-
.../internal/UnboundedReaderImplTest.java | 5 +-
sdks/python/apache_beam/transforms/trigger.py | 11 ++-
sdks/python/apache_beam/transforms/trigger_test.py | 83 ++++++++++++++++++++++
15 files changed, 253 insertions(+), 31 deletions(-)
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/CloserReference.java