incubator-uniffle
incubator-uniffle copied to clipboard
[Improvement] There should be a bounded and blocked queue when sendShuffleData in client side
In RssShuffleManager
,the workQueue
of threadPoolExecutor
is unbounded now. If sendShuffleData
not fast enough, it will cost a lot of memory
Will it bring any other problems?
Will it bring any other problems?
It may cause OOM
We have a class WriteBufferManager
. The class will control the memory that we can use. It is strange to cause OOM. I doubt whether it is caused by the issue that pr #67 want to fix.
May be it is, i am not sure. I once found out an application failed due to requestExecutorMemory
fail. Should we limit memory usage when sending data.
May be it is, i am not sure. I once found out an application failed due to
requestExecutorMemory
fail. Should we limit memory usage when sending data.
I think we don't need, because we have WriteBufferManager
. If our WriteBufferManager
works well, OOM shouldn't occur. If our WriteBufferManager
has bug, we should fix it.