Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.9.0
-
None
Description
Schema:
.withSchema(new Schema() .field("ip", Types.STRING()) .field("ts", Types.STRING()) .field("procTime", Types.SQL_TIMESTAMP).proctime() .field("environment", schemaEnvironment) .field("advs", ObjectArrayTypeInfo.getInfoFor(new Array[Row](0).getClass, Types.ROW(Array("count","sid", "eventid","params"), Array[TypeInformation[_]](Types.STRING(),Types.STRING(), Types.STRING(),Types.ROW(Array("adid","adtype","ecpm"),Array[TypeInformation[_]] (Types.STRING(),Types.STRING(),Types.STRING())))))) )
when execute this sql:
val sql = """ |SELECT |ip, |ts, |params.ad, |params.adtype, |eventid, |procTime |FROM aggs_test |CROSS JOIN UNNEST(advs) AS t (`count`,sid, eventid,params) |""".stripMargin
I got a warning,and the console keeps brushing this warning,no normal printout
09:38:38,694 WARN org.apache.flink.metrics.MetricGroup - The operator name correlate: table(explode($cor0.advs)), select: ip, ts, procTime, advs, sid, eventid, params exceeded the 80 characters length limit and was truncated.
But after I change it to this way, although I occasionally brush this Warn, it can be output normally。I change the 'params' type from Types.ROW to Types.STRING。
.field("advs", ObjectArrayTypeInfo.getInfoFor(new Array[Row](0).getClass, Types.ROW(Array("count", "sid", "eventid", "params"), Array[TypeInformation[_]](Types.STRING(), Types.STRING(), Types.STRING(), Types.STRING()))))