[GitHub] [flink] Vancior commented on a change in pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

Vancior commented on a change in pull request #18957: URL: https://github.com/apache/flink/pull/18957#discussion_r823294596 ## File path: flink-python/pyflink/datastream/window.py ## @@ -517,3 +538,721 @@ def __init__(self, self.window_state_descriptor = window_state_d

[GitHub] [flink] Vancior commented on a change in pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

Vancior commented on a change in pull request #18957: URL: https://github.com/apache/flink/pull/18957#discussion_r823283875 ## File path: flink-python/pyflink/datastream/window.py ## @@ -517,3 +538,721 @@ def __init__(self, self.window_state_descriptor = window_state_d

[GitHub] [flink] Vancior commented on a change in pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

Vancior commented on a change in pull request #18957: URL: https://github.com/apache/flink/pull/18957#discussion_r819330802 ## File path: flink-python/pyflink/fn_execution/datastream/window/window_assigner.py ## @@ -0,0 +1,376 @@ +import math +from typing import Iterable, Coll