Re: [PR] [FLINK-35098][ORC] Fix incorrect results with literal first expressions [flink]

2024-04-30 Thread via GitHub
empathy87 commented on code in PR #24659: URL: https://github.com/apache/flink/pull/24659#discussion_r1584273004 ## flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcFileSystemITCase.java: ## @@ -208,6 +208,15 @@ void testOrcFilterPushDown() throws

Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]

2024-04-30 Thread via GitHub
yunfengzhou-hub commented on code in PR #24698: URL: https://github.com/apache/flink/pull/24698#discussion_r1584175343 ## flink-core/src/main/java/org/apache/flink/core/state/StateFutureImpl.java: ## @@ -46,123 +46,169 @@ public class StateFutureImpl implements

[jira] [Resolved] (FLINK-35194) Support describe job syntax and execution

2024-04-30 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-35194. --- Resolution: Fixed > Support describe job syntax and execution >

[jira] [Commented] (FLINK-35194) Support describe job syntax and execution

2024-04-30 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842258#comment-17842258 ] dalongliu commented on FLINK-35194: --- Merged in master: 44528e0ee9fbed11b5417253534078d60fed3a12 >

Re: [PR] [FLINK-35194][table] Support describe job with job id [flink]

2024-04-30 Thread via GitHub
lsyldliu closed pull request #24728: [FLINK-35194][table] Support describe job with job id URL: https://github.com/apache/flink/pull/24728 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Comment Edited] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-04-30 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842254#comment-17842254 ] Flaviu Cicio edited comment on FLINK-33989 at 4/30/24 6:30 AM: --- Thank you

[jira] [Commented] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-04-30 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842254#comment-17842254 ] Flaviu Cicio commented on FLINK-33989: -- Thank you all for your involvement!   >From my

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

2024-04-30 Thread via GitHub
fredia commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1584188915 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java: ## @@ -0,0 +1,123 @@ +/* + * Licensed to the Apache

<    1   2