⚠ This page is served via a proxy. Original site: https://github.com
This service does not collect credentials or authentication data.
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions runners/google-cloud-dataflow-java/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -102,8 +102,6 @@ dependencies {
permitUnusedDeclared library.java.flogger_system_backend
implementation library.java.google_api_client
// Ensures SequencedMessage availability for Spotless
implementation library.java.proto_google_cloud_pubsublite_v1
permitUnusedDeclared library.java.proto_google_cloud_pubsublite_v1
implementation library.java.google_api_services_dataflow
implementation library.java.google_api_services_storage
permitUnusedDeclared library.java.google_api_services_storage // BEAM-11761
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,6 @@
import org.apache.beam.sdk.io.gcp.pubsub.PubsubMessageWithAttributesCoder;
import org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSink;
import org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource;
import org.apache.beam.sdk.io.gcp.pubsublite.internal.SubscribeTransform;
import org.apache.beam.sdk.io.kafka.KafkaIO;
import org.apache.beam.sdk.options.ExperimentalOptions;
import org.apache.beam.sdk.options.PipelineOptions;
Expand Down Expand Up @@ -665,8 +664,6 @@ private List<PTransformOverride> getOverrides(boolean streaming) {
// and only needed when KafkaIO is used in the pipeline.
}

overridesBuilder.add(SubscribeTransform.V1_READ_OVERRIDE);

if (!hasExperiment(options, "enable_file_dynamic_sharding")) {
overridesBuilder.add(
PTransformOverride.of(
Expand Down
4 changes: 0 additions & 4 deletions sdks/java/extensions/sql/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -103,12 +103,8 @@ dependencies {
implementation library.java.proto_google_cloud_bigtable_v2
implementation library.java.google_api_services_bigquery
permitUnusedDeclared library.java.google_api_services_bigquery
implementation library.java.proto_google_cloud_pubsublite_v1
implementation library.java.google_cloud_pubsublite
implementation project(":sdks:java:io:mongodb")
implementation library.java.avro
implementation library.java.protobuf_java
implementation library.java.protobuf_java_util
provided project(":sdks:java:io:parquet")
provided library.java.jackson_dataformat_xml
permitUnusedDeclared library.java.jackson_dataformat_xml
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

Loading
Loading