Hi,

If you're not using Beam SQL's HOP windowing functions, you're not affected.


*The problem*

Calcite defines
<https://calcite.apache.org/docs/reference.html#grouped-window-functions>
HOP windowing function like this:
  - HOP(timestamp_field, frequency_interval, window_size)

Beam SQL implemented incorrectly, swapping frequency_interval
and window_size:
  - HOP(timestamp_field, window_size, frequency_interval)


*The fix*

*The commit containing the fix swapping the parameters match Calcite doc
has been just pushed, see BEAM-3610
<https://issues.apache.org/jira/browse/BEAM-3610>.*


Regards,
Anton

Reply via email to