各位好:

请教一下,用FlinkKafkaConsumer API的话,如何支持SQL的方式,和维表关联。(之前用Kafka 
API&StreamTableDescriptor API是可以的)
 "select  a.id,b.name from kafka_table a "
        + "join dim_table FOR SYSTEM_TIME AS OF a.proctime as b on a.id = 
b.user_id";

thanks & Regards

回复