Re: Support for multiple slots per task manager in Flink 1.5

2018-12-05 Thread 罗齐
Hi Pawel, Flink 1.5 supports multiple sets per TM. “Not fully supported yet” refers to an issue [1] when requesting TM from SlotManager, which will allocate more TM than actual (but idle TMs will be released later). So I suggest you to check further in your timeout logs to identify other issue

Support for multiple slots per task manager in Flink 1.5

2018-12-05 Thread Pawel Bartoszek
Hi, According to the Flink 1.5 release docs multiple slots per task manager are "not fully supported yet". Can you provide more information about what are the risks of running more than one slot per tm? We are running Flink on EMR on YARN. Previously we run 4 task task managers with 8 slot each n