TransportClient 内存溢出问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

TransportClient 内存溢出问题

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