beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xi...@apache.org
Subject [beam] branch master updated: [BEAM-12757]: Remove call for Json Dag in Portable PipelineRunner as it's not supported yet (#15332)
Date Fri, 13 Aug 2021 22:10:35 GMT
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 <pchhokra@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);

Mime
View raw message