我正在尝试编写一个junit测试，它有两个资源和操作符，第一个操作符用于将数据持久化为状态，然后第二个操作符将检索状态out。
我发现有线的东西是第二个运算符总是在第一个运算符之前运行，第一个运算符将数据持久化为状态。
所以，我的问题是如何在同一个flink作业程序中控制任务的执行顺序？