Re: flink 1.9 状态后端为FsStateBackend,修改checkpoint时出现警告

2020-03-27 文章 Congxian Qiu
Hi 从报错来看,你用 StateProcessAPI,StateProcessAPI 的某些 function(这里是 getMetricGroup) 不提供支持,因此会有这个提示,如果你没有显示调用这个 function 的话,那可能是个 bug Best, Congxian guanyq 于2020年3月25日周三 下午3:24写道: > > > > > > >

flink 1.9 状态后端为FsStateBackend,修改checkpoint时出现警告

2020-03-25 文章 guanyq
package com.guanyq.study.libraries.stateProcessorApi.FsStateBackend; import org.apache.flink.api.common.functions.FlatMapFunction; import org.apache.flink.api.common.state.ListState; import org.apache.flink.api.common.state.ListStateDescriptor; import