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
I create a JIRA issue here, https://issues.apache.org/jira/browse/FLINK-18782
And thanks for your advice to avoid 「top-level projection/rename」^_^
At 2020-07-30 16:58:45, "Dawid Wysakowicz" wrote:
Hi,
I am afraid you are facing an issue that was not checked for/was not
considered. I t
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
Hi, Community:
I met some field name errors when try to convert in Table and DataStream.
flink version: 1.9.1
First, init a datastream and convert to table 'source', register a
tablefunction named 'foo'
val sourceStream = env.socketTextStream("127.0.0.1", 8010)
.map(line => line.toInt)
tab
