flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 张传琨 <zck573693...@gmail.com>
Subject TransportClient 内存溢出问题
Date Fri, 24 Apr 2020 11:20:13 GMT
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测试没有问题。
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message