Dynamically allocating right-sized task resources

2019-08-04 Thread Chad Dombrova
Hi all, First time poster, so go easy on me :) What is Flink's story for accommodating task workloads with vastly disparate resource requirements: e.g. some require very little CPU and RAM, while others require quite a lot. Our current strategy is to bundle resource-intensive tasks and send them

Re: Dynamically allocating right-sized task resources

2019-08-10 Thread Chad Dombrova
Thanks for the great feedback. Just as Xintong said, fine grained resource management has not been > introduced to flink. And i think it is the elegant solution for > your scenario. Task managers with different resource specification will be > allocated and started by Yarn/k8s resource manager acc

How many task managers can Flink efficiently scale to?

2019-08-10 Thread Chad Dombrova
Hi, I'm still on my task management investigation, and I'm curious to know how many task managers people are reliably using with Flink. We're currently using AWS | Thinkbox Deadline, and we're able to easily utilize over 300 workers, and I've heard from other customers who use several thousand, so

Re: How many task managers can Flink efficiently scale to?

2019-08-14 Thread Chad Dombrova
o 于2019年8月11日周日 下午6:17写道: > >> Hi Chad, >> >> In our cases, 1~2k TMs with up to ~10k TM slots are used in one job. In >> general, the CPU/memory of Job Manager should be increased with more TMs. >> >> Regards, >> Qi >> >> > On Aug 11, 2019

Re: [ANNOUNCE] Apache Flink Python API(PyFlink) 1.9.2 released

2020-02-20 Thread Chad Dombrova
Hi, Very cool. I’m curious about the relationship between this feature and Apache Beam. What parts of Beam are used and for what? Does this have any impact on existing Beam users like myself who use the Beam python API on top of Flink? Can someone give me a brief overview or point me at the righ

Re: [ANNOUNCE] Apache Flink Python API(PyFlink) 1.9.2 released

2020-02-22 Thread Chad Dombrova
%3A+Flink+Python+User-Defined+Stateless+Function+for+Table > [2] > https://enjoyment.cool/2020/02/19/Deep-dive-how-to-support-Python-UDF-in-Apache-Flink-1-10/ > > Chad Dombrova 于2020年2月21日周五 上午12:16写道: > >> Hi, >> Very cool. I’m curious about the relationship between thi