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

lostluck 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 707456b  Fix nil pointer exception in `graphx.Marshal` (#13178)
707456b is described below

commit 707456bdabb7957c2ffc60fd8038c1d39e802d3b
Author: Simone Primarosa <[email protected]>
AuthorDate: Fri Oct 23 20:09:43 2020 +0100

    Fix nil pointer exception in `graphx.Marshal` (#13178)
---
 sdks/go/pkg/beam/core/runtime/graphx/translate.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/sdks/go/pkg/beam/core/runtime/graphx/translate.go 
b/sdks/go/pkg/beam/core/runtime/graphx/translate.go
index 70d39a3..a52dd43 100644
--- a/sdks/go/pkg/beam/core/runtime/graphx/translate.go
+++ b/sdks/go/pkg/beam/core/runtime/graphx/translate.go
@@ -120,6 +120,10 @@ type Options struct {
 
 // Marshal converts a graph to a model pipeline.
 func Marshal(edges []*graph.MultiEdge, opt *Options) (*pipepb.Pipeline, error) 
{
+       if len(edges) == 0 {
+               return nil, errors.New("empty graph")
+       }
+       
        tree := NewScopeTree(edges)
 
        m := newMarshaller(opt)

Reply via email to