[beam] branch master updated: [BEAM-7179] Correct file extension (#8434)

[lc...@apache.org]

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

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 77294ed  [BEAM-7179] Correct file extension (#8434)
77294ed is described below

commit 77294edc013db4aa1d00897e5cc749dcc32d5167
Author: Aaron Li <Aa...@users.noreply.github.com>
AuthorDate: Wed May 1 16:23:33 2019 -0700

    [BEAM-7179] Correct file extension (#8434)
    
    DATAFLOW_GRAPH_FILE_NAME 's extension is set to .pb however it is indeed a .json. The content is generated as
    
    ```
    DataflowPipelineTranslator.jobToString(newJob).getBytes(UTF_8)
    ```
---
 .../src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
index 1280edd..d1c3edf 100644
--- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
+++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
@@ -197,7 +197,7 @@ public class DataflowRunner extends PipelineRunner<DataflowPipelineJob> {
   @VisibleForTesting static final int GCS_UPLOAD_BUFFER_SIZE_BYTES_DEFAULT = 1024 * 1024;
 
   @VisibleForTesting static final String PIPELINE_FILE_NAME = "pipeline.pb";
-  @VisibleForTesting static final String DATAFLOW_GRAPH_FILE_NAME = "dataflow_graph.pb";
+  @VisibleForTesting static final String DATAFLOW_GRAPH_FILE_NAME = "dataflow_graph.json";
 
   private static final ObjectMapper MAPPER = new ObjectMapper();