Aaron Li created BEAM-7179:
------------------------------
Summary: Wrong file extension for DATAFLOW_GRAPH_FILE_NAME
Key: BEAM-7179
URL: https://issues.apache.org/jira/browse/BEAM-7179
Project: Beam
Issue Type: Improvement
Components: beam-model
Reporter: Aaron Li
DATAFLOW_GRAPH_FILE_NAME
{code:java}
String DATAFLOW_GRAPH_FILE_NAME = "dataflow_graph.pb"
{code}
's file extension is set to .pb however it is indeed a .json. The content is
generated as
{code:java}
options
.getStager()
.stageToFile(
DataflowPipelineTranslator.jobToString(newJob).getBytes(UTF_8),
DATAFLOW_GRAPH_FILE_NAME);
{code}
While the actual proto
{code:java}
String PIPELINE_FILE_NAME = "pipeline.pb"
{code}
is generated as
{code:java}
options.getStager().stageToFile(serializedProtoPipeline, PIPELINE_FILE_NAME);
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
