Details
-
Improvement
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
2.9.0, 2.10.0, 2.11.0, 2.12.0
-
None
Description
DATAFLOW_GRAPH_FILE_NAME
String DATAFLOW_GRAPH_FILE_NAME = "dataflow_graph.pb"
's file extension is set to .pb however it is indeed a .json. The content is generated as
options
.getStager()
.stageToFile(
DataflowPipelineTranslator.jobToString(newJob).getBytes(UTF_8),
DATAFLOW_GRAPH_FILE_NAME);
While the actual proto
String PIPELINE_FILE_NAME = "pipeline.pb"
is generated as
options.getStager().stageToFile(serializedProtoPipeline, PIPELINE_FILE_NAME);
Attachments
Issue Links
- links to
