You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2022/05/17 09:06:09 UTC
[beam] branch master updated: Merge pull request #17678 from [BEAM-14460] [Playground] WIP. Fix error during getting the graph for java SDK.
This is an automated email from the ASF dual-hosted git repository.
pabloem 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 e65b4a31407 Merge pull request #17678 from [BEAM-14460] [Playground] WIP. Fix error during getting the graph for java SDK.
e65b4a31407 is described below
commit e65b4a314074f4b7a0d442763ce8e2b0bfb9f574
Author: Vladislav Chunikhin <10...@users.noreply.github.com>
AuthorDate: Tue May 17 12:05:58 2022 +0300
Merge pull request #17678 from [BEAM-14460] [Playground] WIP. Fix error during getting the graph for java SDK.
---
playground/backend/internal/preparers/java_preparers.go | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/playground/backend/internal/preparers/java_preparers.go b/playground/backend/internal/preparers/java_preparers.go
index 5556e631506..37ae10b7865 100644
--- a/playground/backend/internal/preparers/java_preparers.go
+++ b/playground/backend/internal/preparers/java_preparers.go
@@ -34,7 +34,6 @@ const (
newLinePattern = "\n"
javaPublicClassNamePattern = "public class (.*?) [{|implements(.*)]"
pipelineNamePattern = `Pipeline\s([A-z|0-9_]*)\s=\sPipeline\.create`
- findImportsPattern = `import.*\;`
graphSavePattern = "String dotString = org.apache.beam.runners.core.construction.renderer.PipelineDotRenderer.toDotString(%s);\n" +
" try (java.io.PrintWriter out = new java.io.PrintWriter(\"Graph.dot\")) {\n " +
" out.println(dotString);\n " +
@@ -107,7 +106,7 @@ func (builder *JavaPreparersBuilder) WithGraphHandler() *JavaPreparersBuilder {
func addCodeToSaveGraph(args ...interface{}) error {
filePath := args[0].(string)
pipelineObjectName, _ := findPipelineObjectName(filePath)
- graphSaveCode := fmt.Sprintf(graphSavePattern, pipelineObjectName, utils.GraphFileName)
+ graphSaveCode := fmt.Sprintf(graphSavePattern, pipelineObjectName, pipelineObjectName)
if pipelineObjectName != utils.EmptyLine {
err := replace(filePath, fmt.Sprintf("%s.run", pipelineObjectName), graphSaveCode)