Switch && for || to fix bug in apache#23889 resolution (apache#24017)

akvelon · Nov 11, 2022 · 496d181 · 496d181
1 parent 7712968
commit 496d181
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/go/pkg/beam/core/runtime/graphx/schema/schema.go b/sdks/go/pkg/beam/core/runtime/graphx/schema/schema.go
@@ -122,7 +122,7 @@ func (r *Registry) reconcileRegistrations() (deferedErr error) {
 		// We could have either a pointer or non pointer here,
 		// so we strip pointerness and then check both.
 		vT := reflectx.SkipPtr(ut)
-		if check(vT) && check(reflect.PtrTo(vT)) {
+		if check(vT) || check(reflect.PtrTo(vT)) {
 			continue
 		}
 		if err := r.registerType(ut, map[reflect.Type]struct{}{}); err != nil {