flink怎么停止一个数据流。比如说：env.addsource(s1);env.addsource(s2);env.execute();环境运行后我如何在不停止程序进行修改的情况下，停止s1数据流。
s1对应的数据源端不推送数据就好了啊