下面是我的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是持续增长的状态。