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 49d828a [BEAM-13001] fixes nil reference error in
Extractor.ExtractFrom (#15865)
49d828a is described below
commit 49d828a9915a858ddc9dd87049ec477601db0ed5
Author: Ritesh Ghorse <[email protected]>
AuthorDate: Tue Nov 2 12:11:42 2021 -0400
[BEAM-13001] fixes nil reference error in Extractor.ExtractFrom (#15865)
---
sdks/go/pkg/beam/core/metrics/store.go | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/sdks/go/pkg/beam/core/metrics/store.go
b/sdks/go/pkg/beam/core/metrics/store.go
index 79c5ab8..7e2240a 100644
--- a/sdks/go/pkg/beam/core/metrics/store.go
+++ b/sdks/go/pkg/beam/core/metrics/store.go
@@ -127,8 +127,10 @@ func (e Extractor) ExtractFrom(store *Store) error {
}
}
}
- for l, um := range store.stateRegistry {
- e.MsecsInt64(l, um)
+ if e.MsecsInt64 != nil {
+ for l, es := range store.stateRegistry {
+ e.MsecsInt64(l, es)
+ }
}
return nil
}