public static StreamExecutionEnvironment getExecutionEnvironment() {
        return getExecutionEnvironment(new Configuration());
    }
@Test
    void testBufferTimeoutEnabled() {
        Configuration config = new Configuration();
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        config.set(ExecutionOptions.BUFFER_TIMEOUT_ENABLED, true);
        testBufferTimeout(config, env);
    }