Окно обработки времени события Apache Flink не вызывается - PullRequest
0 голосов
/ 22 февраля 2019

Работа с окнами происходит в бесконечном цикле или что-то в этом роде, я печатаю поток данных после обработки, но похоже, что он вообще не достигает этой точки.

Ниже приведен мой псевдокод.

Datastream env = StreamExecutionEnvironment.getExecutionEnvironment()    
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)

Datastream stream = env.addSource() .map(mapping to java object) 
    .filter(filter for specific type of events) 
    .assignTimestampsAndWatermarks(
         new BoundedOutOfOrdernessTimestampExtractor(Time.seconds(2)){})

Datastream processedStream = stream .keyBy(...)  
    .window(TumblingEventTimeWindows.of(Time.seconds(10))) .reduce()

processedStream.print()

Я добавил журнал для печати в функции уменьшения.Журналы печатаются из функции уменьшения.но поток не печатается.

И исходные данные потоковой передачи являются данными истории, т.е.данные за 2 месяца.в случае потоковой передачи данных истории необходимо установить что-то еще?

Любые входные данные будут очень полезны ..

1 Ответ

0 голосов
/ 23 февраля 2019

Вы можете использовать веб-интерфейс Flink для проверки водяных знаков, чтобы увидеть, достаточно ли продвинут текущий водяной знак, чтобы вызвать окно.Для получения дополнительной информации о водяных знаках см. сайт обучения flink .

...