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 2020/10/17 02:44:24 UTC
[beam] tag nightly-master updated (15fd04d -> 3591151)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 15fd04d (commit)
to 3591151 (commit)
from 15fd04d Merge pull request #13114: [BEAM-11066] Fix java dataflow runner override factories ordering with streaming beam_fn_api
add 3755a15 Improving performance of file deletion in ReadFromBQ
add 7cd61b5 Merge pull request #13125 from [BEAM-11069] Improving performance of file deletion in ReadFromBQ
add f0ac3a2 Re-sickbay unsupported metrics on Dataflow
add 1e59484 Merge pull request #13127 from kennknowles/gauge-metrics-dataflow
add 3591151 [BEAM-10114] Upgrade version of pubsublite to 0.4.1. (#12957)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
runners/google-cloud-dataflow-java/build.gradle | 2 +
.../io/gcp/pubsublite/BufferingPullSubscriber.java | 116 -------------
.../beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java | 12 +-
.../gcp/pubsublite/PubsubLiteUnboundedReader.java | 3 +-
.../gcp/pubsublite/PubsubLiteUnboundedSource.java | 19 ++-
...scriber.java => TranslatingPullSubscriber.java} | 28 +++-
.../pubsublite/BufferingPullSubscriberTest.java | 183 ---------------------
.../sdk/io/gcp/pubsublite/PubsubLiteSinkTest.java | 10 +-
.../pubsublite/PubsubLiteUnboundedReaderTest.java | 5 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 14 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 45 ++---
12 files changed, 89 insertions(+), 350 deletions(-)
delete mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/BufferingPullSubscriber.java
rename sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{PullSubscriber.java => TranslatingPullSubscriber.java} (51%)
delete mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/BufferingPullSubscriberTest.java