This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch go-sdk in repository https://gitbox.apache.org/repos/asf/beam.git
commit c5a3ce00eeb96ba4e357080d6bd27708273da295 Author: Bill Neubauer <[email protected]> AuthorDate: Wed Jan 17 09:43:24 2018 -0800 Add initialization of active plans map. --- sdks/go/pkg/beam/core/runtime/harness/harness.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/sdks/go/pkg/beam/core/runtime/harness/harness.go b/sdks/go/pkg/beam/core/runtime/harness/harness.go index 8822c62..1dd0d2e 100644 --- a/sdks/go/pkg/beam/core/runtime/harness/harness.go +++ b/sdks/go/pkg/beam/core/runtime/harness/harness.go @@ -85,8 +85,9 @@ func Main(ctx context.Context, loggingEndpoint, controlEndpoint string) error { }() ctrl := &control{ - plans: make(map[string]*exec.Plan), - data: &DataManager{}, + plans: make(map[string]*exec.Plan), + active: make(map[string]*exec.Plan), + data: &DataManager{}, } var cpuProfBuf bytes.Buffer -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
