不知道大家有没有遇到这个问题,流环境中链接Mysql数据库,利用DDL定义两个数据源表 source1, source2. sql = "SELECT ID, NAME, IP, PHONE FROM source1 JOIN source2 ON source1.ID = source2.ID WHERE ID = '123456' AND DATE BETWEEN '20160701' AND '20170307'" # 获取Query结果 query_table = env.sql_query(sql) query_table.to_pandas() 相同的处理过程,python和java的处理速度差很多,请问什么原因导致的呢? 由于python只是封装了一下flink的接口,所以会是GIL的影响么? 蹲一个大佬的解答?也欢迎遇到同样问题的小伙伴讨论,thx !
- flink1.12 执行sql_query(),同样的数据源表,pyflink执行时间9min,java执... xiaoyue
- Re: flink1.12 执行sql_query(),同样的数据源表,pyflink执行时间9m... Xingbo Huang
- Re:Re: flink1.12 执行sql_query(),同样的数据源表,pyflin... xiaoyue
- Re:Re: flink1.12 执行sql_query(),同样的数据源表,pyflin... xiaoyue
- Re:Re: flink1.12 执行sql_query(),同样的数据源表,pyflin... xiaoyue
- Re: Re: flink1.12 执行sql_query(),同样的数据源表,p... Xingbo Huang
- Re: Re: flink1.12 执行sql_query(),同样的数据... xiao...@ysstech.com
- Re: Re: flink1.12 执行sql_query(),... Xingbo Huang
- Re: Re: flink1.12 执行sql_quer... xiao...@ysstech.com
- Re: Re: flink1.12 执行sql_... Xingbo Huang