[
https://issues.apache.org/jira/browse/FLINK-29737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623041#comment-17623041
]
chenzihao commented on FLINK-29737:
-----------------------------------
I have simply extended the functionality of DATAGEN to support the smooth
change of data generation rate. And support adjusting the data change period
and the peak value. If this small improvement is useful for Flink, I am willing
to open a PR. [~lzljs3620320] Please help to review this, thanks a lot.
> Support DataGen on waveform function
> ------------------------------------
>
> Key: FLINK-29737
> URL: https://issues.apache.org/jira/browse/FLINK-29737
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
> Reporter: chenzihao
> Priority: Major
> Attachments: image-2022-10-24-16-09-47-386.png,
> image-2022-10-24-16-09-52-410.png
>
>
> In some scenarios, we need to simulate flow changes in the production
> environment. The current DATAGEN feature only supports data generation at a
> constant rate. We try to simulate increments of flow using batch jobs, but
> the production rate is not smooth, so I suggest that we can support sin-based
> data generation in order to get smooth changes.
> 1. add another batch job to simulate increments of flow.
> !image-2022-10-24-16-09-52-410.png!
> 2. sin-based.
> !image-2022-10-24-16-09-47-386.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
