You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ud...@apache.org on 2021/10/01 18:34:40 UTC
[beam] branch release-2.33.0 updated (1816cf4 -> d916c1f)
This is an automated email from the ASF dual-hosted git repository.
udim pushed a change to branch release-2.33.0
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1816cf4 Merge pull request #15622 from clairemcginty/claire/cherrypick-beam-12628
add bb5ecd1 Revert "Cherrypick #15418 and #15515"
new d916c1f Merge pull request #15629 from apache/revert-15608-dpcollins-cherry-pick
The 1 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:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubMessages.java | 42 ++--
...dUuidsTransform.java => CloudPubsubChecks.java} | 44 ++--
.../io/gcp/pubsublite/CloudPubsubTransforms.java | 104 --------
.../pubsublite/ManagedBacklogReaderFactory.java | 33 ---
.../ManagedBacklogReaderFactoryImpl.java | 68 -----
.../sdk/io/gcp/pubsublite/OffsetByteRange.java | 38 ---
.../io/gcp/pubsublite/OffsetByteRangeCoder.java | 63 -----
.../io/gcp/pubsublite/OffsetByteRangeTracker.java | 66 ++---
.../io/gcp/pubsublite/PerServerPublisherCache.java | 4 -
.../pubsublite/PerSubscriptionPartitionSdf.java | 57 ++---
.../beam/sdk/io/gcp/pubsublite/PublisherCache.java | 62 ++---
.../beam/sdk/io/gcp/pubsublite/Publishers.java | 72 ++----
.../beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java | 2 +-
.../beam/sdk/io/gcp/pubsublite/PubsubLiteSink.java | 10 +-
.../sdk/io/gcp/pubsublite/SubscribeTransform.java | 44 ++--
.../sdk/io/gcp/pubsublite/SubscriberOptions.java | 26 +-
.../SubscriptionPartitionProcessorFactory.java | 3 +-
.../SubscriptionPartitionProcessorImpl.java | 23 +-
.../gcp/pubsublite/TopicBacklogReaderSettings.java | 6 +-
.../sdk/io/gcp/pubsublite/TrackerWithProgress.java | 24 --
.../gcp/pubsublite/OffsetByteRangeTrackerTest.java | 34 +--
.../PerSubscriptionPartitionSdfTest.java | 70 +-----
.../beam/sdk/io/gcp/pubsublite/ReadWriteIT.java | 280 ---------------------
.../SubscriptionPartitionProcessorImplTest.java | 49 ++--
25 files changed, 269 insertions(+), 957 deletions(-)
copy sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{AddUuidsTransform.java => CloudPubsubChecks.java} (50%)
delete mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/CloudPubsubTransforms.java
delete mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/ManagedBacklogReaderFactory.java
delete mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/ManagedBacklogReaderFactoryImpl.java
delete mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/OffsetByteRange.java
delete mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/OffsetByteRangeCoder.java
delete mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/TrackerWithProgress.java
delete mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/ReadWriteIT.java
[beam] 01/01: Merge pull request #15629 from
apache/revert-15608-dpcollins-cherry-pick
Posted by ud...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
udim pushed a commit to branch release-2.33.0
in repository https://gitbox.apache.org/repos/asf/beam.git
commit d916c1f55e57a61b54135d0922ad8660735bd287
Merge: 1816cf4 bb5ecd1
Author: Udi Meiri <ud...@users.noreply.github.com>
AuthorDate: Fri Oct 1 11:33:47 2021 -0700
Merge pull request #15629 from apache/revert-15608-dpcollins-cherry-pick
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubMessages.java | 42 ++--
.../sdk/io/gcp/pubsublite/CloudPubsubChecks.java | 51 ++++
.../io/gcp/pubsublite/CloudPubsubTransforms.java | 104 --------
.../pubsublite/ManagedBacklogReaderFactory.java | 33 ---
.../ManagedBacklogReaderFactoryImpl.java | 68 -----
.../sdk/io/gcp/pubsublite/OffsetByteRange.java | 38 ---
.../io/gcp/pubsublite/OffsetByteRangeCoder.java | 63 -----
.../io/gcp/pubsublite/OffsetByteRangeTracker.java | 66 ++---
.../io/gcp/pubsublite/PerServerPublisherCache.java | 4 -
.../pubsublite/PerSubscriptionPartitionSdf.java | 57 ++---
.../beam/sdk/io/gcp/pubsublite/PublisherCache.java | 62 ++---
.../beam/sdk/io/gcp/pubsublite/Publishers.java | 72 ++----
.../beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java | 2 +-
.../beam/sdk/io/gcp/pubsublite/PubsubLiteSink.java | 10 +-
.../sdk/io/gcp/pubsublite/SubscribeTransform.java | 44 ++--
.../sdk/io/gcp/pubsublite/SubscriberOptions.java | 26 +-
.../SubscriptionPartitionProcessorFactory.java | 3 +-
.../SubscriptionPartitionProcessorImpl.java | 23 +-
.../gcp/pubsublite/TopicBacklogReaderSettings.java | 6 +-
.../sdk/io/gcp/pubsublite/TrackerWithProgress.java | 24 --
.../gcp/pubsublite/OffsetByteRangeTrackerTest.java | 34 +--
.../PerSubscriptionPartitionSdfTest.java | 70 +-----
.../beam/sdk/io/gcp/pubsublite/ReadWriteIT.java | 280 ---------------------
.../SubscriptionPartitionProcessorImplTest.java | 49 ++--
25 files changed, 297 insertions(+), 936 deletions(-)