(beam) branch release-2.54.0 updated: Remove constraint introduced in #30059 (#30186) (#30189)

[lostluck]

This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a commit to branch release-2.54.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.54.0 by this push:
     new 7517e0e377e Remove constraint introduced in #30059 (#30186) (#30189)
7517e0e377e is described below

commit 7517e0e377ef1482daa02f85e514990586cf1ada
Author: Yi Hu <ya...@google.com>
AuthorDate: Mon Feb 5 14:34:22 2024 -0500

    Remove constraint introduced in #30059 (#30186) (#30189)
---
 .../trigger_files/beam_PostCommit_Python_Xlang_Gcp_Dataflow.json   | 0
 .../providers/BigQueryStorageWriteApiSchemaTransformProvider.java  | 7 -------
 2 files changed, 7 deletions(-)

diff --git 
a/.github/trigger_files/beam_PostCommit_Python_Xlang_Gcp_Dataflow.json 
b/.github/trigger_files/beam_PostCommit_Python_Xlang_Gcp_Dataflow.json
deleted file mode 100644
index e69de29bb2d..00000000000
diff --git 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java
 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java
index d0951cdad1a..ca0d0a2784b 100644
--- 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java
+++ 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java
@@ -383,13 +383,6 @@ public class BigQueryStorageWriteApiSchemaTransformProvider
         Boolean autoSharding = configuration.getAutoSharding();
         int numStreams = configuration.getNumStreams() == null ? 0 : 
configuration.getNumStreams();
 
-        // TODO(https://github.com/apache/beam/issues/30058): remove once 
Dataflow supports multiple
-        // DoFn's per fused step.
-        if (numStreams < 1) {
-          throw new IllegalStateException(
-              "numStreams must be set to a positive integer when input data is 
unbounded.");
-        }
-
         boolean useAtLeastOnceSemantics =
             configuration.getUseAtLeastOnceSemantics() != null
                 && configuration.getUseAtLeastOnceSemantics();