Когда я использую окно сеанса с интервалом в 1 час и после обработки миллиона сообщений, я получаю сообщение об ошибке в журналах, вероятно, только для некоторых строк:
TypeError: Cannot convert GlobalWindow to apache_beam.utils.windowed_value._IntervalWindowBase
Код:
grouped_tis = tracking_informations | beam.WindowInto(window.Sessions(session_window_gap)) | beam.GroupByKey() | beam.ParDo(MergeTI()) | "TI model -> json" >> beam.Map(jsons.dump)
Полный стек:
https://pastebin.com/pqA5pMay