hive读取复杂数据类型写入mysql报错

[housezhang]

请教个问题 hive读取复杂类型，mysql支持，有什么方法把数据当初字符串去存储到 mysql中:
org.apache.flink.table.api.ValidationException: Field types of query
result and registered TableSink
default_catalog.default_database.0_es_hive_094679318_tmp do not match.

Query schema: [id: INT, name: VARCHAR(2147483647), hobby: ARRAY<INT>,
add: MAP<VARCHAR(2147483647), VARCHAR(2147483647)>]
Sink schema: [id: INT, name: VARCHAR(2147483647), hobby:
VARCHAR(2147483647), add: VARCHAR(2147483647)]
        at org.apache.flink.table.planner.sinks.TableSinkUtils$.validateSchemaAndApplyImplicitCast(TableSinkUtils.scala:100)