[beam] branch master updated: [BEAM-12757]: Remove call for Json Dag in Portable PipelineRunner as it's not supported yet (#15332)

[xinyu]

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

xinyu 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 16b7b98  [BEAM-12757]: Remove call for Json Dag in Portable 
PipelineRunner as it's not supported yet (#15332)
16b7b98 is described below

commit 16b7b98f7d26ac1dfb341ec756bb38c8b783cd3d
Author: Pawas Chhokra <pchho...@linkedin.com>
AuthorDate: Fri Aug 13 15:09:22 2021 -0700

    [BEAM-12757]: Remove call for Json Dag in Portable PipelineRunner as it's 
not supported yet (#15332)
---
 .../src/main/java/org/apache/beam/runners/samza/SamzaRunner.java      | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java 
b/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java
index 910f1aa..669c0c1 100644
--- a/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java
+++ b/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java
@@ -86,13 +86,9 @@ public class SamzaRunner extends 
PipelineRunner<SamzaPipelineResult> {
     final String dotGraph = PipelineDotRenderer.toDotString(pipeline);
     LOG.info("Portable pipeline to run DOT graph:\n{}", dotGraph);
 
-    final String jsonGraph = PipelineJsonRenderer.toJsonString(pipeline);
-    LOG.info("Portable pipeline to run JSON graph:\n{}", jsonGraph);
-
     final ConfigBuilder configBuilder = new ConfigBuilder(options);
     SamzaPortablePipelineTranslator.createConfig(pipeline, configBuilder, 
options);
     configBuilder.put(BEAM_DOT_GRAPH, dotGraph);
-    configBuilder.put(BEAM_JSON_GRAPH, jsonGraph);
 
     final Config config = configBuilder.build();
     options.setConfigOverride(config);