This is an automated email from the ASF dual-hosted git repository.

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

commit 5cd3130529a392d6fcc7d0572a7d64e67e893c03
Author: Robert Burke <lostl...@users.noreply.github.com>
AuthorDate: Tue Jan 19 14:16:24 2021 -0800

    [BEAM-9615] Disable schema registration.
---
 sdks/go/pkg/beam/forward.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/sdks/go/pkg/beam/forward.go b/sdks/go/pkg/beam/forward.go
index 483bf3a..82779ce 100644
--- a/sdks/go/pkg/beam/forward.go
+++ b/sdks/go/pkg/beam/forward.go
@@ -44,7 +44,9 @@ import (
 // facing copy for this important concept.
 func RegisterType(t reflect.Type) {
        runtime.RegisterType(t)
-       schema.RegisterType(t)
+       if EnableSchemas {
+               schema.RegisterType(t)
+       }
 }
 
 // RegisterFunction allows function registration. It is beneficial for 
performance

Reply via email to