Re: Question regarding rescale api

2018-12-10 Thread Till Rohrmann
are the committer of rescale api, any help about this question? > > Best, > Mingliang > > ------ > *发件人:* 祁明良 > *发送时间:* 2018年12月9日 18:20 > *收件人:* user@flink.apache.org > *主题:* Question regarding rescale api > > Hi All, > > I see the rescale api a

Re: Question regarding rescale api

2018-12-10 Thread Aljoscha Krettek
日 18:20 > 收件人: user@flink.apache.org > 主题: Question regarding rescale api > > Hi All, > > I see the rescale api allow us to somehow redistribute element locally, but > is it possible to make the upstream operator distributed evenly on task > managers? > For example I have

Question regarding rescale api

2018-12-09 Thread 祁明良
Hi All, I see the rescale api allow us to somehow redistribute element locally, but is it possible to make the upstream operator distributed evenly on task managers? For example I have 10 task managers each with 10 slots. The application reads data from Kafka topic with 20 partitions, then resca