我正在使用Hazelcast来实现我的executor服务。我不需要从executor返回结果,我只是继续通过它在一段时间内运行良好,之后内存就满了。我使用了一个线程转储工具,我可以看到
at com.hazelcast.executor.RunnableAdapter.call(RunnableAdapter.java:49)at java.util.concurrent.FutureTask.run(FutureTas
org.apache.spark.mllib.classification.LogisticRegressionWithLBFGSalgorithm.run(training_set)
首先,我遇到了很多executorlost failure和java out out memory的问题,然后我用更多的分区对training_set进行了重新分区,内存不足的问题也解决了,但仍然出现executor lost failure