pyflink sql固定窗口流输出转pandas未见输出
我又作了另外的测试,来证实从pandas转换为table是正常的,直接从表里读出进行批处理,在这块 table = t_env.from_pandas(df,schema=schema) s_env.create_temporary_view('table_name',table) t_env.sql_query('select * from table_name').excute().print() 能正常打印输出,证明schema是正常的。那么我从kafka流读出,用固定窗口的形式,在这打印输出,为什么会没有值出来呢?固定窗口流转pandas是支持的吧?
赞1
踩1