flink添加表的comment信息无效

Thu, 21 Apr 2022 02:08:09 -0700 



Java代码如下:
@Test
public void test(){
StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
DataStream<String> dataStream = env.fromElements("Alice", "Bob", "John");
Schema.Builder builder = Schema.newBuilder();
builder.column("f0",DataTypes.of(String.class)).withComment("this is a 
comment");
Table table = tableEnv.fromDataStream(dataStream, 
builder.build()).as("user_name");
table.printSchema();
}
Flink 版本:1.14.0
运行结果:
(
  `user_name` STRING
)


理论上，结果不应该是:
(
  `user_name ` STRING COMMENT 'this is a comment’
)
这样的吗，请问为什么丢失了comment信息























    











					回复