Ignite TcpCommunicationSpi: можно ли установить slowClientQueueLimit в то же значение, что и messageQueueLimit в соответствии с документами?

Question

Я не совсем уверен в значении или взаимодействии между slowClientQueueLimit и messageQueueLimit.

В соответствии с документацией, они в идеале должны быть установлены на одно и то же значение, https://ignite.apache.org/releases/2.4.0/javadoc/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.html#setSlowClientQueueLimit-int-

Однако, когда я устанавливаю, что вижу это в журналах, это незначительная ошибка в проверке или я должен изменить это?

[WARN ] 2018-06-27 22:32:18.429 [main] org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi - Slow client queue limit is set to a value greater than message queue limit (slow client queue limit will have no effect) [msgQueueLimit=1024, slowClientQueueLimit=1024]

Спасибо

Answer 1

Из кода предупреждение верное, а javadoc нет. slowClientQueueLimit должно быть меньше msgQueueLimit, потому что, когда сообщение готовится к отправке, сначала проверяются пределы обратного давления, и только затем slowClientQueueLimit. Если эти два числа равны, поток отправителя будет заблокирован обратным давлением, прежде чем он сможет перейти к медленной проверке клиента. Что означает, что клиент не будет удален.

Установите slowClientQueueLimit на msgQueueLimit - 1 или меньше, и я предложу сообществу исправить документы.