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 <u...@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(-)