Re: flink sql client 报错java.net.NoRouteToHostException: 没有到主机的路由

2020-12-05 文章 奚焘
找到原因了,host文件里localhost的ip不对 -- Sent from: http://apache-flink.147419.n8.nabble.com/

????????????

2020-12-05 文章 ??????
??          flink 1.10.1 flinksql cep??  ??ab??  ??  ?? ?? ??        ??cep sql  a??b   PATTERN (A->B) ?? a c* b ?? a c

flink使用RocksDB增量checkpoints,程序运行一段时间报出:超出物理内存

2020-12-05 文章 bradyMk
大家好~ 最近刚刚尝试使用flink 1.9.1 的RocksDB做增量checkpoints; 在程序种设置: val backend = new RocksDBStateBackend("hdfs://xx/", true) backend.setPredefinedOptions(PredefinedOptions.SPINNING_DISK_OPTIMIZED_HIGH_MEM) 并用MapState保存中间状态;(中间状态大概10个G); 我启动程序时,给taskmanager设置了3G内存:“-ytm 3072m \”,但是我的程序每跑一段时间都会报出超出物