暂无个人介绍
暂时未有相关通用技术能力~
阿里云技能认证
详细说明2023年06月
2023年05月
2023年02月
该版本session集群存在此问题,只能更换成yarn application模式,具体修复版本未知。
我又作了另外的测试,来证实从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是支持的吧?