Hazelcast mapreduce 执行器过载
Hazelcast mapreduce executor overload
我正在设置一个新集群，但我从 hazelcast mapreduce 执行程序中收到错误消息：
java.util.concurrent.RejectedExecutionException: Executor[mapreduce::hz::default] is overloaded
使用spring，我正在按如下方式配置jobtracker：
<hz:jobtracker name="default" max-thread-size="8" queue-size="0"/>
根据文档，0 是未绑定的默认队列大小。
想法？我只同时发送大约 100 个作业
手册对此有误。
小于或等于零的值表示队列大小是 partitionCount 的两倍。
int queueSize = jobTrackerConfig.getQueueSize();
if (queueSize <= 0) {
queueSize = ps.getPartitionCount() * 2;
}
Code snippet on github
使用对您的用例来说足够大的整数。
我正在设置一个新集群，但我从 hazelcast mapreduce 执行程序中收到错误消息：
java.util.concurrent.RejectedExecutionException: Executor[mapreduce::hz::default] is overloaded
使用spring，我正在按如下方式配置jobtracker：
<hz:jobtracker name="default" max-thread-size="8" queue-size="0"/>
根据文档，0 是未绑定的默认队列大小。
想法？我只同时发送大约 100 个作业
手册对此有误。 小于或等于零的值表示队列大小是 partitionCount 的两倍。
int queueSize = jobTrackerConfig.getQueueSize();
if (queueSize <= 0) {
queueSize = ps.getPartitionCount() * 2;
}
Code snippet on github
使用对您的用例来说足够大的整数。