Hi all,
我在使用filter scala表达方式时，提示需要Expression类型，但是实际是String类型，但是这种写法在源码文档里是推荐的。
我的代码：
sensorTab
// 使用Expression方式，例如 tab.select($"key", $"value".avg + " The average" as
"average")
.select($"id", $"temperature")
// 使用Expression方式
// .filter($("id").isEqual("sensor_1"))
// 使用这种方式，类型不
打扰了，解决了，原因是因为启动时没有配置savepoint路径。
> 2022年4月30日 12:09，Arthur Li 写道：
>
> 大家好，
>
>
> 我在学习Flink checkpoint时，做了一个示例没有得到期望结果，麻烦帮忙看看是哪里设置有问题。谢谢
> 1. 启动checkpoint
> 2. 设置statebackend为FsStateBackend
> 3. 从socketTextStream读取数据，统计单词个数
>(“hello”, 5), (“world”, 1)
> 4. 通过触发异常，来模拟终止程序
> 5. 重新启动程序，那么启动之后
