开启微批处理
execution.checkpointing.interval: 180sstate.backend: com.alibaba.flink.statebackend.GeminiStateBackendFactorytable.exec.state.ttl: 129600000table.exec.mini-batch.enabled: truetable.exec.mini-batch.allow-latency: 5stable.exec.mini-batch.size:100000 table.optimizer.distinct-agg.split.enabled: trueenv.java.opts.taskmanager: -Xms4096m -XX:+UseParNewGC -XX:+UseCMSInitiatingOccupancyonly -XX:CMSInitiatingOccupancyFraction=70 -verbose:gc -XX:+HeapDumponOutOfMemoryError -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection -XX:CMSMaxAbortablePrecleanTime=1000 -XX:+CMSClassUnloadingEnabled -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:SurvivorRatio=5 -XX:ParallelGCThreads=4
高性能Flink SQL优化技巧 - 实时计算Flink版 - 阿里云