张一帆 created FLINK-32627: --------------------------- Summary: Add support for dynamic time window function Key: FLINK-32627 URL: https://issues.apache.org/jira/browse/FLINK-32627 Project: Flink Issue Type: Improvement Components: API / DataStream Affects Versions: 1.18.0 Reporter: 张一帆 Fix For: 1.18.0
When using windows for calculations, when the logic is frequently modified and adjusted, the entire program needs to be stopped, the code is modified, the program is repackaged and then submitted to the cluster. It is impossible to achieve logic dynamic modification and external dynamic injection. The window information can be obtained from the data to trigger Redistribution of windows to achieve the effect of dynamic windows{*}{*} -- This message was sent by Atlassian Jira (v8.20.10#820010)