You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2018/01/17 17:57:42 UTC
[beam] 04/04: Add initialization of active plans map.
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 <wc...@google.com>
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
"commits@beam.apache.org" <co...@beam.apache.org>.