[
https://issues.apache.org/jira/browse/FLINK-32627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
张一帆 updated FLINK-32627:
------------------------
Description: 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 (was: 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{*}{*})
> 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: 张一帆
> Priority: Major
> 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)
