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 <riteshgho...@gmail.com>
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
 }

Reply via email to