Fix UnsupportedOperationException because of ImmutableCollection.add (a…

…pache#29570)
akvelon · Nov 30, 2023 · 6c7606e · 6c7606e
1 parent 93fb204
commit 6c7606e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...le-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java b/...le-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
@@ -1339,9 +1339,9 @@ public DataflowPipelineJob run(Pipeline pipeline) {
     int jobGraphByteSize = jobGraphBytes.length;
     if (jobGraphByteSize >= CREATE_JOB_REQUEST_LIMIT_BYTES
         && !hasExperiment(options, "upload_graph")) {
-      List<String> experiments = firstNonNull(options.getExperiments(), new ArrayList<>());
-      experiments.add("upload_graph");
-      options.setExperiments(ImmutableList.copyOf(experiments));
+      List<String> experiments = firstNonNull(options.getExperiments(), Collections.emptyList());
+      options.setExperiments(
+          ImmutableList.<String>builder().addAll(experiments).add("upload_graph").build());
       LOG.info(
           "The job graph size ({} in bytes) is larger than {}. Automatically add "
               + "the upload_graph option to experiments.",