Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs

2022-03-11 Thread Yufei Liu
Hi Jacky, I think it’s a very useful feature, can get flame graph easily and avoid run script personally. But I think can package async-profiler library into flink, and use JNI execute the profiling, doesn’t depend on local environment. We did this way in out internal version, and provide api to

Insufficient number of network buffers after restarting

2020-12-24 Thread Yufei Liu
Hey, I’ve found that job will throw “java.io.IOException: Insufficient number of network buffers: required 51, but only 1 available” after job retstart, and I’ve observed TM use much more network buffers than before. My internal branch is under 1.10.0 can easily reproduce, but I use 1.12.0

[DISCUSS] Rework Behavior of "within" In CEP Library

2019-08-30 Thread Yufei Liu
Hi all, I‘ve got several troubles when I use library CEP. 1. The funtion "within" in PatternAPI is kind of misleading. I can set within time in each part of pattern, but only the smallest one is functional. Pattern.begin("begin").where(...)