Skip to content

Commit 0736cc6

Browse files
committed
Restore upload_graph hasExperiment guard to prevent duplicate log message
1 parent fc89170 commit 0736cc6

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

  • runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow

runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1526,7 +1526,8 @@ public DataflowPipelineJob run(Pipeline pipeline) {
15261526
// enable upload_graph when the graph is too large
15271527
byte[] jobGraphBytes = DataflowPipelineTranslator.jobToString(newJob).getBytes(UTF_8);
15281528
int jobGraphByteSize = jobGraphBytes.length;
1529-
if (jobGraphByteSize >= CREATE_JOB_REQUEST_LIMIT_BYTES && !useUnifiedWorker(options)) {
1529+
if (jobGraphByteSize >= CREATE_JOB_REQUEST_LIMIT_BYTES && !useUnifiedWorker(options)
1530+
&& !hasExperiment(options, "upload_graph")) {
15301531
ExperimentalOptions.addExperiment(options, "upload_graph");
15311532
LOG.info(
15321533
"The job graph size ({} in bytes) is larger than {}. Automatically add "

0 commit comments

Comments
 (0)