You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lo...@apache.org on 2021/01/19 22:17:19 UTC
[beam] 01/01: [BEAM-9615] Disable schema registration.
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 <lo...@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