Hello Flink friends, I have a retract stream in the format of 'DataStream<CRow>' that I want to register into my table environment, and also expose processing time column in the table.
For a regular datastream, I have being doing 'tableEnvironment.createTemporaryView(path, dataStream, 'field1,field2, ..,__processing_time_column.proctime')'. with no issue. But for this retract stream, I was getting an error "org.apache.flink.table.api.ValidationException: Too many fields referenced from an atomic type." Digging a little bit deeper, in TypeInfoUtils#extractFieldInformation<https://github.com/hequn8128/flink/blob/master/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/typeutils/FieldInfoUtils.java#L250>, it doesn't handle CRowTypeInfo as a known case. Looking at the behavior of Since it's a standard CompositeType, instead of only handling 'if (inputType instanceof PojoTypeInfo)', can we just add CRowTypeInfo here too? Is there any risk that I'm not aware of? Thank you!
