Update SpannerWriteSchemaTransformProvider.java

apache · Sep 4, 2024 · 8f9178e · 8f9178e
1 parent 66ff2de
commit 8f9178e
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteSchemaTransformProvider.java b/...src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteSchemaTransformProvider.java
@@ -251,6 +251,7 @@ public PCollectionRowTuple expand(@NonNull PCollectionRowTuple input) {
   public abstract static class SpannerWriteSchemaTransformConfiguration implements Serializable {
 
     @SchemaFieldDescription("Specifies the GCP project.")
+    @Nullable
     public abstract String getProjectId();
 
     @SchemaFieldDescription("Specifies the Cloud Spanner instance.")
@@ -289,10 +290,6 @@ public abstract static class Builder {
     public void validate() {
       String invalidConfigMessage = "Invalid Spanner Write configuration: ";
 
-      checkArgument(
-          !Strings.isNullOrEmpty(this.getProjectId()),
-          invalidConfigMessage + "Project ID for a Spanner Write must be specified.");
-
       checkArgument(
           !Strings.isNullOrEmpty(this.getInstanceId()),
           invalidConfigMessage + "Instance ID for a Spanner Write must be specified.");