|
|
|
@ -147,7 +147,7 @@ public class IotDevicePowerOnAndOffDataJob { |
|
|
|
|
|
|
|
ValueStateDescriptor<IotDevicePowerOnAndOffDataEvent> powerOnAndOffDataEventValue = new ValueStateDescriptor<>("powerOnAndOffDataEventValue", |
|
|
|
TypeInformation.of(IotDevicePowerOnAndOffDataEvent.class)); |
|
|
|
// 设置状态值的过期时间,为了解决机器关机没有消息的情况 |
|
|
|
// 设置状态值的过期时间,为了解决手动修改数据没有同步的问题 |
|
|
|
powerOnAndOffDataEventValue.enableTimeToLive(ttlConfig); |
|
|
|
|
|
|
|
// 必须在 open 生命周期初始化 |
|
|
|
|