Registering RawType with LegacyTypeInfo via Flink CREATE TABLE DDL

Posted by Yuval Itzchakov on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Registering-RawType-with-LegacyTypeInfo-via-Flink-CREATE-TABLE-DDL-tp40289.html

Hi,

I have a UDF which returns a type of MAP<STRING, LEGACY('RAW', 'ANY<io.circe.Json>')>. When I try to register this type with Flink via the CREATE TABLE DDL, I encounter an exception:

- SQL parse failed. Encountered "(" at line 2, column 256.
Was expecting one of:
    "NOT" ...
    "NULL" ...
    ">" ...
    "MULTISET" ...
    "ARRAY" ...
    "." ...

Which looks like the planner doesn't like the round brackets on the LEGACY type. What is the correct way to register the table with this type with Flink?

--