flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 杨力 <bill.le...@gmail.com>
Subject User-defined aggregation function and parallelism
Date Mon, 16 Apr 2018 03:21:58 GMT
I am running flink SQL in streaming mode and implemented a UDAGG, which is
used in keyed HOP windows. But I found that the throughput decreases
dramatically when the function is used. Does UDAGG run in parallell? Or
does it run only in one thread?


View raw message