Водяные знаки в параллельной среде Flink? - PullRequest
Новая
       6

Водяные знаки в параллельной среде Flink?

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

У меня есть сложный оконный оператор, который выглядит примерно так: 

stream = fromSomeKafkaSourceWithKPartitions...

stream
  .assignTimestampsAndWatermarks(...)
  .keyBy(...)
  .window(SlidingEventTime(...)
  .process(...)
  .assignTimestampsAndWatermarks(...)
  .windowAll(...)
  .process(...)

Я вижу в интерфейсе Flink, что водяные знаки не заканчиваются, если я задаю параллелизм = 50 , ноЯ вижу low-watermarks, когда я устанавливаю параллелизм = 1 .Я предполагаю, что есть какая-то проблема с разделением?Есть ли совет, как это исправить?Мне звонить rebalance()?

...