我正在考虑在长时间运行的应用程序中使用apacheflink，使用cogroup操作符对小批量数据执行连接。是否可以重用executionenvironment并对其重复调用collect（）来实现这一点？如果可能的话，executionenvironment从不同的线程调用是安全的，还是必须维护threadlocal？
谢谢！