[beam] branch master updated: [SQL][Fix] Fix DataCatalog MAP type

[anton]

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. */