doris-3.1.2 flink doris connector JVM被打满

Viewed 2

下面是我的flink sql:

WITH (
      'connector' = 'doris',
      'fenodes' = 'fe01:8030',
      'table.identifier' = 'ads.ads_my_table',
      'username' = 'xxxx',
      'password' = 'xxxx',
      'sink.label-prefix' = 'insert_batch_xxx',
      'sink.enable.batch-mode' = 'true',
      'sink.buffer-flush.max-rows' = '500000',
      'sink.buffer-flush.interval' = '10000'
);

我的fe规模是:5节点-16c-32G。讲道理应该是不会出现JVM被打满然后崩溃的现象。
但是我发现我只要一启动flink sql写入doris,这些fe节点就会崩溃。在doris manager中fe jvm是持续增长的状态。

0 Answers