win10 pyflink1.12 本机env.sql_query()执行 表关联sql, 时间过长
Hi, 1. 关于sql_query的话本质都是跑的也是java代码,你这边在没有使用的Python udaf跑更慢的原因是你用了to_pandas这个sink,to_pandas的一般是用来本地调试用的,在性能上是不行的。 2. 关于用了udaf的30分钟的问题,我在社区邮件也回复你了,我猜测是你pandas udaf的实现上不够高效导致的。 http://apache-flink.147419.n8.nabble.com/flink1-12-sql-query-pyflink-9min-java-3s-td10994.html
赞0
踩0