你好,我在使用广播流的时候定义了一个MapState,并在逻辑处理中往其中放数据,但是我始终没法成功更新其值,忘解惑。
定义: private val carEfenceState: MapState[String, Boolean] = new MapStateDescriptor[String, Boolean]("carEfenceState", classOf[String], classOf[Boolean]) 存值: carEfenceState.put(mapKey, true) 取值: carEfenceState.get(mapKey) 取到的值始终为 false. Thanks in advance! -- Sent from: http://apache-flink.147419.n8.nabble.com/