????: ????????json schema??????????????????

Thu, 19 Sep 2019 19:22:40 -0700 

??????????Types.LIST(Types.STRING)??????????????flink-planner??????????blink-planner????????????Types.OBJECT_ARRAY(Types.STRING)??????????
Type LEGACY(List<String>) of table field 'ARRAY_FIELD' does not match with type 
List<String> of the field 'ARRAY_FIELD' of the TableSource return type.
??????blink-planner????????????????????????????????????

??????????????????????flink 
sql????????????????????????????????????????????????????????select 
array_field[1] from test ?????????????? Type is not supported: ANY??

________________________________
[email protected]

???????? Jun Zhang<mailto:[email protected]>
?????????? 2019-09-19 18:55
???????? user-zh<mailto:[email protected]>; 
[email protected]<mailto:[email protected]>
?????? ????????json schema??????????????????
??????????????


Types.LIST(Types.STRING)






------------------ ???????? ------------------
??????: ?? ?? <[email protected]&gt;
????????: 2019??9??19?? 16:39
??????: [email protected] <[email protected]&gt;
????: ????????json schema??????????????????



??????????flink-1.9????????????????????????????json??????????{??field1:?? 
??aaa??, ??field2??: [??bbb, ??ccc??]} ??????????????


????schema??????????????field("field2", 
Types.OBJECT_ARRAY(Types.STRING))??????????EnvironmentSetting??????flink-planner??blink-planner??????????


??flink-planner????????????????????????????????????????StringArraySerializer.copy????????????String[]??????????????Object[]??
Caused by: java.lang.ClassCastException: [Ljava.lang.Object; cannot be cast to 
[Ljava.lang.String;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.api.common.typeutils.base.array.StringArraySerializer.copy(StringArraySerializer.java:35)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.api.java.typeutils.runtime.RowSerializer.copy(RowSerializer.java:93)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.api.java.typeutils.runtime.RowSerializer.copy(RowSerializer.java:44)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:635)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ... 13 more

??blink-planner????????????????????????????????
Exception in thread "main" org.apache.flink.table.api.ValidationException: Type 
LEGACY(BasicArrayTypeInfo<String&gt;) of table field 'field2' does not match 
with type BasicArrayTypeInfo<String&gt; of the field ' field2' of the 
TableSource return type.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.table.planner.sources.TableSourceUtil$$anonfun$4.apply(TableSourceUtil.scala:121)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.table.planner.sources.TableSourceUtil$$anonfun$4.apply(TableSourceUtil.scala:92)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at 
scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186)

??????????????????????????????????????????????????????????????????

?????? Windows 10 ??????<https://go.microsoft.com/fwlink/?LinkId=550986&gt;????

回复