I am writing a few integration tests for a flink job where each job creates a StreamExecutionEnvironment. At the end of each test, I close the streaming environment