两个流的加入不起作用

Question

我正在尝试使用 Apache Flink 流 API 加入两个流，但没有加入任何内容，阅读文档后我不知道我做错了什么

    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
    DataStream<MyPojo2> source = env.fromCollection(Lists.newArrayList(new MyPojo2(1, "Ola"), new MyPojo2(2, "Ola")))
            .assignTimestampsAndWatermarks(new IngestionTimeExtractor<MyPojo2>());
    DataStream<MyPojo2> source2 = env.fromCollection(Lists.newArrayList(new MyPojo2(1, "Ela"), new MyPojo2(2, "Ela")))
            .assignTimestampsAndWatermarks(new IngestionTimeExtractor<MyPojo2>());
    DataStream<Tuple2<String, String>> joined = source.join(source2).where(keySelector).equalTo(keySelector).
            window(GlobalWindows.create()).apply(joinFunction);
    joined.print();
    env.execute("Window");

关键功能简单myPojo.getFirst()

Answer 1

除非指定自定义Trigger，否则GlobalWindows窗口永远不会触发。在您的示例中，如果您使用类似 TumblingEventTimeWindows.of(Time.seconds(5)) 的内容，您应该会看到结果。