Hi,
For now, you can explicitly set the RowTypeInfo to retain the field names.
This works in master branch:
*val t1Stream = t1.toAppendStream[Row](t1.getSchema.toRowType)*
// t1 stream schema: Row(a: Integer, b: Integer)
println(s"t1 stream schema: ${t1Stream.getType()}")
tEnv.reg
Hi,
I am afraid you are facing an issue that was not checked for/was not
considered. I think your use case is absolutely valid and should be
supported.
The problem you are facing as far as I can tell from an initial
investigation is that the top-level projection/rename is not being
applied. Inter
