Re: How to dynamically modify the schema information of a table

2022-04-28 Thread yu'an huang
Thank you for your reporting. I created a ticket in JIRA. You can track this problem in this link: https://issues.apache.org/jira/browse/FLINK-27449 . > On 22 Apr 2022, at 10:44 AM, 草莓 wrote: > > The following is the Java code > > @Test >

How to dynamically modify the schema information of a table

2022-04-21 Thread 草莓
The following is the Java code @Test public void test(){ StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env); DataStream dataStream = env.fromElements("Alice", "Bob", "John"); Schema.Builder b