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测试没有问题。