回复：MapState 无法更新问题

Tue, 09 Mar 2021 21:37:46 -0800 

可以贴个完整的代码吗





------------------ 原始邮件 ------------------
发件人: chaos <jinh...@163.com&gt;
发送时间: 2021年3月10日 12:51
收件人: user-zh <user-zh@flink.apache.org&gt;
主题: 回复：MapState 无法更新问题



你好，我在使用广播流的时候定义了一个MapState,并在逻辑处理中往其中放数据，但是我始终没法成功更新其值，忘解惑。 

定义：
private val carEfenceState: MapState[String, Boolean] = new
MapStateDescriptor[String, Boolean](&quot;carEfenceState&quot;, classOf[String],
classOf[Boolean])

存值：
carEfenceState.put(mapKey, true)

取值：
carEfenceState.get(mapKey)

取到的值始终为 false.

Thanks in advance！



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复