Skip to content

Commit 16b7b98

Browse files
authored
[BEAM-12757]: Remove call for Json Dag in Portable PipelineRunner as it's not supported yet (#15332)
1 parent c5b6a9a commit 16b7b98

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -86,13 +86,9 @@ public PortablePipelineResult runPortablePipeline(RunnerApi.Pipeline pipeline, J
8686
final String dotGraph = PipelineDotRenderer.toDotString(pipeline);
8787
LOG.info("Portable pipeline to run DOT graph:\n{}", dotGraph);
8888

89-
final String jsonGraph = PipelineJsonRenderer.toJsonString(pipeline);
90-
LOG.info("Portable pipeline to run JSON graph:\n{}", jsonGraph);
91-
9289
final ConfigBuilder configBuilder = new ConfigBuilder(options);
9390
SamzaPortablePipelineTranslator.createConfig(pipeline, configBuilder, options);
9491
configBuilder.put(BEAM_DOT_GRAPH, dotGraph);
95-
configBuilder.put(BEAM_JSON_GRAPH, jsonGraph);
9692

9793
final Config config = configBuilder.build();
9894
options.setConfigOverride(config);

0 commit comments

Comments
 (0)