Re: Re:Flink 并行度问题

2021-01-23 文章 Jacob
我明白了。。。感谢!!(最近很容易陷入这些低级的错误认知中)。越想越觉得这个问题很傻 23 - Thanks! Jacob -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: Re:Flink 并行度问题

2021-01-23 文章 赵一旦
on yarn是另一回事情,yarn自身有自身对资源的衡量方式,就是vcore。 你设置你的作业25并行,默认yarn可能就是按照1个并发对应1个vcore,就这么个意思。肯定有参数可以调整的,你可以让1个并发对应10个vcore都没问题。 就是一种衡量方式而已。 赵一旦 于2021年1月23日周六 下午8:20写道: > 按照你的理解,别说服务器了,你自己的笔记本电脑都别工作了。你电脑才几核,开机后进程数量就超过CPU数了,这些进程难道不工作了? > > 多线程、多线程,不是说N核的就只有N个线程呀。 > >

Re: Re:Flink 并行度问题

2021-01-23 文章 赵一旦
按照你的理解,别说服务器了,你自己的笔记本电脑都别工作了。你电脑才几核,开机后进程数量就超过CPU数了,这些进程难道不工作了? 多线程、多线程,不是说N核的就只有N个线程呀。 你standalone,每个机器想设置多少个slot都没问题,和你的机器CPU没关系懂了嘛。“没关系”。 Jacob <17691150...@163.com> 于2021年1月23日周六 下午4:35写道: > 谢谢回复~ > > 在我的理解中,并行度数量不应该超过CPU的数量的。 > > > > - > Thanks! > Jacob > -- > Sent from:

Re: Re:Flink 并行度问题

2021-01-23 文章 Jacob
谢谢回复~ 在我的理解中,并行度数量不应该超过CPU的数量的。 - Thanks! Jacob -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re:Flink 并行度问题

2021-01-22 文章 Ye Chen
@jacob hi, TaskManager 的一个 Slot 代表一个可用线程,该线程具有固定的内存,并且 Slot 只对内存隔离,没有对 CPU 隔离。 而slot 和并行度的关系是:Slot 是指 TaskManager 最大能并发执行的能力,parallelism 是指 TaskManager 实际使用的并发能力。 个人见解,并行度的设置一般无需考虑CPU。 在 2021-01-22 16:18:32,"Jacob" <17691150...@163.com> 写道: >使用Flink以来,一直有一个问题困扰着。 > > >Flink