|
Settings settings = Settings.builder()
.put("cluster.name", "es")
.put("thread_pool.generic.core", 5)
.put("thread_pool.generic.max", 10)
.put("processors", 5)
.build();
写了一个spring-java没有溢出,但是flink时候溢出了,我需要将network buffer配置大点吗。
因为低版本,只能用TransportClient,换了高版本API测试没有问题。
|