flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chanamper <chanam...@163.com>
Subject Flink 1.10 Local Aggregate问题
Date Mon, 30 Mar 2020 04:24:38 GMT
Dear All,
        请教一下,Flink 1.10版本中Java Api如何实现Local Aggregate的功能呢?数据存在较大的倾斜,想在keyby前进行一次local
aggregate, 看了下在https://cwiki.apache.org/confluence/display/FLINK/FLIP-44%3A+Support+Local+Aggregation+in+Flink有计划实现localKeyBy()方法,
flink 1.10 java api中还没发现对应的localKeyBy方法。请问下,目前Java API对这种数据倾斜有啥好的处理思路吗?另外FLIP-44可能预计啥时候能够使用呢?

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message