我有 checkpointing 设置在我的flink作业中，它有2个滑动窗口（这些arent连接）和1个滚动窗口连接。我的想法是，我真的不需要为未来拯救国家 join 把自己当成拯救国家的救星 2 滑动车窗本身就足够了。这个 Join 最后是一个20-30gb的状态，导致作业延迟和崩溃，检查点永远不会保存。
我怎样才能做到这一点？
我在尝试这样的事情：

public class CustomJoin implements JoinFunction<A, A, A>, ListCheckPointed<A> {

@Override
public A join(A a, A b){
 // Some irrelevant join logic
}

@Override
    public List<A> snapshotState(long l, long l1) throws Exception {
      return new ArrayList<>();
    }

    @Override
    public void restoreState(List<A> list) throws Exception {

    }
}

这实际上避免了为join存储状态吗？它被称为：

stream
.assignTimestampsAndWatermarks(...)
.join(secondStream.assingTimestampsAndWatermarks(...))
.where(KeySelector...)
.equalTo(KeySelector...)
.window(TumblingEventTimeWindows.of(Time.minutes(1L))
.trigger(EventTimeTrigger.create())
.apply(new CustomJoin());

这在实践中有效吗？避免存储状态的最佳方法是什么？