spotless

Author: scwhittle

examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/utils/SchemasUtils.java

@@ -140,7 +140,8 @@ public static String getGcsFileAsString(String filePath) {
       result = FileSystems.match(filePath);
       checkArgument(
           result.status() == MatchResult.Status.OK && !result.metadata().isEmpty(),
-          "Failed to match any files with the pattern: %s", filePath);
+          "Failed to match any files with the pattern: %s",
+          filePath);
 
       List<ResourceId> rId =
           result.metadata().stream()

runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java

@@ -65,7 +65,8 @@ class SplittableProcessElementsEvaluatorFactory<
               public DoFnLifecycleManager load(final AppliedPTransform<?, ?, ?> application) {
                 checkArgument(
                     ProcessElements.class.isInstance(application.getTransform()),
-                    "No know extraction of the fn from %s", application);
+                    "No know extraction of the fn from %s",
+                    application);
                 final ProcessElements<
                         InputT, OutputT, RestrictionT, PositionT, WatermarkEstimatorStateT>
                     transform =

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java

@@ -3472,26 +3472,22 @@ && getStorageApiTriggeringFrequency(bqOptions) != null) {
           }
         }
       } else { // PCollection is bounded
-        String error =
-            String.format(
-                " is only applicable to an unbounded PCollection, but the input PCollection is %s.",
-                input.isBounded());
         checkArgument(
             getTriggeringFrequency() == null,
-            "Triggering frequency is only applicable to an unbounded PCollection");
+            "Triggering frequency is only applicable to an unbounded PCollection.");
         checkArgument(
-            !getAutoSharding(), "Auto-sharding is only applicable to an unbounded PCollection");
+            !getAutoSharding(), "Auto-sharding is only applicable to an unbounded PCollection.");
         checkArgument(
             getNumFileShards() == 0,
-            "Number of file shards is only applicable to an unbounded PCollectoin");
+            "Number of file shards is only applicable to an unbounded PCollection.");
 
         if (getStorageApiTriggeringFrequency(bqOptions) != null) {
           LOG.warn(
-              "Setting the triggering frequency is only applicable to an unbounded PCollection");
+              "Setting the triggering frequency is only applicable to an unbounded PCollection.");
         }
         if (getStorageApiNumStreams(bqOptions) != 0) {
           LOG.warn(
-              "Setting the number of Storage API streams is only applicable to an unbounded PCollection");
+              "Setting the number of Storage API streams is only applicable to an unbounded PCollection.");
         }
       }
 

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOWriteTest.java

@@ -2717,8 +2717,7 @@ public void testWriteValidateFailsWithBatchAutoSharding() {
     p.enableAbandonedNodeEnforcement(false);
 
     thrown.expect(IllegalArgumentException.class);
-    thrown.expectMessage(
-        "Auto-sharding is only applicable to an unbounded PCollection, but the input PCollection is BOUNDED.");
+    thrown.expectMessage("Auto-sharding is only applicable to an unbounded PCollection.");
     p.apply(Create.empty(INPUT_RECORD_CODER))
         .apply(
             BigQueryIO.<InputRecord>write()