flink1.12的windowAll函数执行没有任何输出

public class WindowAllFunction {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment();
        //或者StreamExecutionEnvironment.getExecutionEnvironment()获取执行环境
        // 定义一个集合
        List<Subject> subject = new ArrayList<Subject>();
        subject.add(new Subject("1", "张三", "语文", 100, Timestamp.valueOf("2020-07-01 11:01:01.235").getTime()));
        subject.add(new Subject("1", "赵顺", "语文", 62, Timestamp.valueOf("2020-07-01 11:01:02.751").getTime()));
        subject.add(new Subject("2", "李四", "数学", 78, Timestamp.valueOf("2020-07-01 11:02:01.258").getTime()));
        subject.add(new Subject("3", "王五", "语文", 99, Timestamp.valueOf("2020-07-01 11:02:04.358").getTime()));
        subject.add(new Subject("4", "赵六", "英语", 81, Timestamp.valueOf("2020-07-01 11:02:09.247").getTime()));
        subject.add(new Subject("5", "钱七", "数学", 59, Timestamp.valueOf("2020-07-01 11:01:10.168").getTime()));
        subject.add(new Subject("6", "马二", "语文", 97, Timestamp.valueOf("2020-07-01 11:01:12.784").getTime()));
        subject.add(new Subject("1", "李伟", "数学", 118, Timestamp.valueOf("2020-07-01 11:01:12.784").getTime()));
        subject.add(new Subject("4", "赵六", "英语", 90, Timestamp.valueOf("2020-07-01 11:02:09.247").getTime()));
        DataStream<Subject> datastream = env.fromCollection(subject);
        datastream.windowAll(TumblingProcessingTimeWindows.of(Time.seconds(2)))
                .process(new ProcessAllWindowFunction<Subject, String, TimeWindow>() {
                    @Override
                    public void process(Context ctx, Iterable<Subject> elements, Collector<String> out) throws Exception {
                        for (Subject value : elements) {
                            System.out.println(value.toString());
                            out.collect("processElement:" + value.getName());
                        }
                    }
                }).print();
//        datastream.print();
        env.execute("windowAll-test");
    }
}

你好，我是有问必答小助手。为了技术专家团更好地为您解答问题，烦请您补充下（1）问题背景详情，（2）您想解决的具体问题，（3）问题相关代码图片或者报错信息。便于技术专家团更好地理解问题，并给出解决方案。

您可以点击问题下方的【编辑】，进行补充修改问题。

你countWindowAll没有输出 这个问题解决了吗