You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 张传琨 <zc...@gmail.com> on 2020/04/24 11:20:13 UTC

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