You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by an...@apache.org on 2019/05/08 00:33:36 UTC
[beam] branch master updated: [SQL][Fix] Fix DataCatalog MAP type
This is an automated email from the ASF dual-hosted git repository.
anton 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 9cd0d56 [SQL][Fix] Fix DataCatalog MAP type
new 52481a8 Merge pull request #8524 from akedin/fix-datacatalog-type-map
9cd0d56 is described below
commit 9cd0d56e7da547bdee278c896f8869670e8989c4
Author: akedin <ke...@google.com>
AuthorDate: Tue May 7 16:01:07 2019 -0700
[SQL][Fix] Fix DataCatalog MAP type
---
.../beam/sdk/extensions/sql/meta/provider/datacatalog/SchemaUtils.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/SchemaUtils.java b/sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/SchemaUtils.java
index 80a5ece..69288a8 100644
--- a/sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/SchemaUtils.java
+++ b/sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/SchemaUtils.java
@@ -44,7 +44,7 @@ class SchemaUtils {
.put("STRING", FieldType.STRING)
.put("TIME", FieldType.logicalType(new CalciteUtils.TimeType()))
.put("TIMESTAMP", FieldType.DATETIME)
- .put("MAP<STRING, STRING>", FieldType.map(FieldType.STRING, FieldType.STRING))
+ .put("MAP<STRING,STRING>", FieldType.map(FieldType.STRING, FieldType.STRING))
.build();
/** Convert DataCatalog schema to Beam schema. */