Clemens Valiente
09/25/2023, 6:14 AMfinal case class TreatmentAttribute(
treatmentAttribute: com.grab.grabdefence.acorn.proto.JavaMap[_root_.scala.Predef.String, _root_.scala.Predef.String] = com.grab.grabdefence.acorn.proto.JavaMap.empty
)
in a DataStream and want to convert it to a Table with tableEnv.fromDataStream
com.grab.grabdefence.acorn.proto.JavaMap
extends java.util.HashMap
and should therefor be bridged to a Flink SQL Map Type according to https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/types/#constructured-data-types.
However that does not happen: it is a RAW type.
`treatmentAttributes` RAW('com.grab.grabdefence.acorn.proto.JavaMap', '...'),
why does it not get bridged to MAP as documented?