beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lostl...@apache.org
Subject [beam] 01/01: [Go-SDK] Check correct cache for wrapped structs.
Date Wed, 02 Oct 2019 16:49:56 GMT
This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a commit to branch lostluck-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 56fb071e4b212e9150e27c66e2e937b8c9e865de
Author: Robert Burke <lostluck@users.noreply.github.com>
AuthorDate: Wed Oct 2 09:49:20 2019 -0700

    [Go-SDK] Check correct cache for wrapped structs.
---
 sdks/go/pkg/beam/core/util/reflectx/structs.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/go/pkg/beam/core/util/reflectx/structs.go b/sdks/go/pkg/beam/core/util/reflectx/structs.go
index 4c38cf5..84f9be9 100644
--- a/sdks/go/pkg/beam/core/util/reflectx/structs.go
+++ b/sdks/go/pkg/beam/core/util/reflectx/structs.go
@@ -44,7 +44,7 @@ func RegisterStructWrapper(t reflect.Type, wrapper func(interface{}) map[string]
 	}
 
 	key := t.String()
-	if _, exists := funcs[key]; exists {
+	if _, exists := structFuncs[key]; exists {
 		log.Warnf(context.Background(), "StructWrapper for %v already registered. Overwriting.",
key)
 	}
 	structFuncs[key] = wrapper


Mime
View raw message