????????json schema??????????????????

[Jun Zhang]

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


Types.LIST(Types.STRING)






------------------ ???????? ------------------
??????: ?? ?? <sean...@live.com&gt;
????????: 2019??9??19?? 16:39
??????: user-zh@flink.apache.org <user-zh@flink.apache.org&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;????