[
https://issues.apache.org/jira/browse/FLINK-32284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linweijiang updated FLINK-32284:
--------------------------------
Description:
This will happen no matter how much parallelism I set, and it will always be
in slot id 1.
I have set different parallelism (50/100/120/140).
The amount of data received is about the same as other slots, but the state is
much larger and growing.
The same code is running normally in the test environment (parallelism is 10).
Thank you for your help~
was:
This will happen no matter how much parallelism I set, and it will always be
in slot id 1.
I have set different parallelism (50/100/120/140).
The amount of data received is about the same as other slots, but the state is
much larger and growing
> When using session windows, the state of slot 1 keeps growing
> -------------------------------------------------------------
>
> Key: FLINK-32284
> URL: https://issues.apache.org/jira/browse/FLINK-32284
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.14.4
> Reporter: linweijiang
> Priority: Major
> Attachments: Checkpoint Details.png, Window Function Received
> Details.png
>
>
> This will happen no matter how much parallelism I set, and it will always be
> in slot id 1.
> I have set different parallelism (50/100/120/140).
> The amount of data received is about the same as other slots, but the state
> is much larger and growing.
> The same code is running normally in the test environment (parallelism is 10).
>
> Thank you for your help~
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
