[jira] [Commented] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-02-17 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818247#comment-17818247 ] ude commented on FLINK-34016: - OK [~xuyangzhong] , look forward to your PR! > Janin

[jira] [Updated] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-07 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-34016: Description: After submit the following flink sql by sql-client.sh will throw an exception: {code:java} Ca

[jira] [Updated] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-07 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-34016: Description: After submit the following flink sql by sql-client.sh will throw an exception: {code:java} Ca

[jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

2024-01-07 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804161#comment-17804161 ] ude commented on FLINK-28693: - same problem [FLINK-34016|https://issues.apache.org/j

[jira] [Updated] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-24 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-34016: Attachment: image-2024-01-25-11-53-06-158.png > Janino compile failed when watermark with column by udf >

[jira] [Updated] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-24 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-34016: Attachment: image-2024-01-25-11-54-54-381.png > Janino compile failed when watermark with column by udf >

[jira] [Updated] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-24 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-34016: Attachment: image-2024-01-25-12-57-34-632.png > Janino compile failed when watermark with column by udf >

[jira] [Updated] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-24 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-34016: Attachment: image-2024-01-25-12-57-21-318.png > Janino compile failed when watermark with column by udf >

[jira] [Commented] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-24 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810671#comment-17810671 ] ude commented on FLINK-34016: - [~337361...@qq.com] Yes, I can recover stably. I am u

[jira] [Created] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed

2024-04-07 Thread JJJJude (Jira)
ude created FLINK-35039: --- Summary: Create Profiling JobManager/TaskManager Instance failed Key: FLINK-35039 URL: https://issues.apache.org/jira/browse/FLINK-35039 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed

2024-04-07 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834758#comment-17834758 ] ude commented on FLINK-35039: - [~Yu Chen] Please have a look, If my modification pla

[jira] [Created] (FLINK-35110) Modify the spelling mistakes in the taskmanager html

2024-04-15 Thread JJJJude (Jira)
ude created FLINK-35110: --- Summary: Modify the spelling mistakes in the taskmanager html Key: FLINK-35110 URL: https://issues.apache.org/jira/browse/FLINK-35110 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-35111) Modify the spelling mistakes in the taskmanager html

2024-04-15 Thread JJJJude (Jira)
ude created FLINK-35111: --- Summary: Modify the spelling mistakes in the taskmanager html Key: FLINK-35111 URL: https://issues.apache.org/jira/browse/FLINK-35111 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-35111) Modify the spelling mistakes in the taskmanager html

2024-04-15 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837485#comment-17837485 ] ude commented on FLINK-35111: - [~dannycranmer] Thank you for your reply, but I found

[jira] [Comment Edited] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed

2024-04-16 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834758#comment-17834758 ] ude edited comment on FLINK-35039 at 4/16/24 8:36 AM: -- [~Yu

[jira] [Commented] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed

2024-04-19 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838907#comment-17838907 ] ude commented on FLINK-35039: - Hi [~yunta] , I don't know why YARN doesn't support H

[jira] [Created] (FLINK-35313) Add upsert changelog mode to avoid UPDATE_BEFORE records push down

2024-05-08 Thread JJJJude (Jira)
ude created FLINK-35313: --- Summary: Add upsert changelog mode to avoid UPDATE_BEFORE records push down Key: FLINK-35313 URL: https://issues.apache.org/jira/browse/FLINK-35313 Project: Flink Iss

[jira] [Commented] (FLINK-35313) Add upsert changelog mode to avoid UPDATE_BEFORE records push down

2024-05-08 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844843#comment-17844843 ] ude commented on FLINK-35313: - migrate from[ https://github.com/apache/flink-cdc/is

[jira] [Comment Edited] (FLINK-35313) Add upsert changelog mode to avoid UPDATE_BEFORE records push down

2024-05-08 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844843#comment-17844843 ] ude edited comment on FLINK-35313 at 5/9/24 3:14 AM: - migrat

[jira] [Updated] (FLINK-35313) Add upsert changelog mode to avoid UPDATE_BEFORE records push down

2024-05-09 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-35313: Attachment: image-2024-05-09-15-02-33-572.png > Add upsert changelog mode to avoid UPDATE_BEFORE records p

[jira] [Updated] (FLINK-35313) Add upsert changelog mode to avoid UPDATE_BEFORE records push down

2024-05-09 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-35313: Attachment: (was: image-2024-05-09-15-02-33-572.png) > Add upsert changelog mode to avoid UPDATE_BEFOR

[jira] [Commented] (FLINK-29625) Optimize changelog normalize for upsert source

2024-05-14 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846258#comment-17846258 ] ude commented on FLINK-29625: - Hi [~jiabao.sun], I encountered the same problem, see

[jira] [Comment Edited] (FLINK-29625) Optimize changelog normalize for upsert source

2024-05-14 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846258#comment-17846258 ] ude edited comment on FLINK-29625 at 5/14/24 10:20 AM: --- Hi

[jira] [Comment Edited] (FLINK-29625) Optimize changelog normalize for upsert source

2024-05-14 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846258#comment-17846258 ] ude edited comment on FLINK-29625 at 5/14/24 10:21 AM: --- Hi