[jira] [Commented] (FLINK-36222) Support the use of LLM models for data processing in the transform module.

2024-09-09 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880304#comment-17880304 ] luolei commented on FLINK-36222: [~kunni] Can you assign this issue to me ? Thank you.

[jira] [Commented] (FLINK-35684) Add missing option for DataSource and DataSink

2024-09-09 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880301#comment-17880301 ] luolei commented on FLINK-35684: [~kunni] Can you assign this issue to me ? Thank you.

[jira] [Commented] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states and add RocksDB state cleanup configuration.

2024-08-26 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876747#comment-17876747 ] luolei commented on FLINK-36149: Thank you for your suggestion. Yes, it is more reasonab

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states and add RocksDB state cleanup configuration.

2024-08-26 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Description: 1、Problem description: {code:java} select * from  (      SELECT *, ROW_NUMBER() OVER (PARTITION

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states and add RocksDB state cleanup configuration.

2024-08-26 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Summary: Support cleaning up expired states to prevent the continuous increase of states and add RocksDB sta

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Description: 1、Problem description: {code:java} select * from  (      SELECT *, ROW_NUMBER() OVER (PARTITION

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Description: {code:java} select * from  (      SELECT *, ROW_NUMBER() OVER (PARTITION BY song_id, user_id, F

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: (was: image-2024-08-24-23-10-29-444.png) > Support cleaning up expired states to prevent the

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: 1724512324453-1.jpg 1724512362249-1.jpg Description: {code:java} select *

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: (was: 1724512324453.jpg) > Support cleaning up expired states to prevent the continuous incr

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: 1724512324453.jpg 1724512362249.jpg > Support cleaning up expired states to prev

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: (was: image-2024-08-24-23-09-53-925.png) > Support cleaning up expired states to prevent the

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: (was: 1724512324453-1.jpg) > Support cleaning up expired states to prevent the continuous in

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: (was: 1724512362249.jpg) > Support cleaning up expired states to prevent the continuous incr

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: (was: 1724512362249-1.jpg) > Support cleaning up expired states to prevent the continuous in

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: 1724512324453.jpg 1724512362249.jpg Description: {code:java} select * from

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Description: {code:java} select * from  (      SELECT *, ROW_NUMBER() OVER (PARTITION BY song_id, user_id, F

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: image-2024-08-24-23-10-29-444.png > Support cleaning up expired states to prevent the continuous

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Attachment: image-2024-08-24-23-09-53-925.png > Support cleaning up expired states to prevent the continuous

[jira] [Updated] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-36149: --- Description: {code:java} select * from  (      SELECT *, ROW_NUMBER() OVER (PARTITION BY song_id, user_id, F

[jira] [Created] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states.

2024-08-24 Thread luolei (Jira)
luolei created FLINK-36149: -- Summary: Support cleaning up expired states to prevent the continuous increase of states. Key: FLINK-36149 URL: https://issues.apache.org/jira/browse/FLINK-36149 Project: Flink

[jira] [Updated] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.

2024-08-06 Thread luolei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luolei updated FLINK-35988: --- Priority: Major (was: Minor) > Reduce the number of state queries in the AppendOnlyFirstNFunction. > --

[jira] [Created] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.

2024-08-06 Thread luolei (Jira)
luolei created FLINK-35988: -- Summary: Reduce the number of state queries in the AppendOnlyFirstNFunction. Key: FLINK-35988 URL: https://issues.apache.org/jira/browse/FLINK-35988 Project: Flink Issu