[FLINK-17548] Table API Schema "from" not working

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 1.10.0
• Component/s: Table SQL / API
• Labels: stale-major
• Assignee: Unassigned
• Reporter: Rafael Wicht
• Created: 06/May/20 20:13
• Updated: 29/Apr/21 16:14
• Resolved: 29/Apr/21 16:14

Description

The method 'from' of org.apache.flink.table.descriptors.Schema do not work for me.

Maybe I miss something.

Code:

.withFormat(new Json()
     .failOnMissingField(false))
.withSchema(new Schema()
     .field("user_server", DataTypes.STRING()).from("user"))

Result

The field 'user_server' has the value 'null'.

Error:

No Error.

Workaround:

This code works!

.withFormat(new Json()
     .failOnMissingField(false))
.withSchema(new Schema()
     .field("user", DataTypes.STRING())

 

From the