[jira] [Assigned] (FLINK-31374) ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

[ https://issues.apache.org/jira/browse/FLINK-31374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang reassigned FLINK-31374: - Assignee: jiangxin li > ProxyStreamPartitioner should implement ConfigurableStreamParti

[jira] [Resolved] (FLINK-31374) ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

[ https://issues.apache.org/jira/browse/FLINK-31374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-31374. --- Resolution: Fixed Resolved on master via 990337bf5a0a23b08be85c475043a047703772c8 > ProxySt

[GitHub] [flink-ml] lindong28 commented on pull request #232: [hotfix] Update pattern matching in test_ml_lib_completeness to work with release branch

lindong28 commented on PR #232: URL: https://github.com/apache/flink-ml/pull/232#issuecomment-1504759529 @flinkbot run azure -- 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 specific c

[GitHub] [flink-connector-opensearch] MartijnVisser merged pull request #18: [hotfix] Use 1.0.0-1.16 baseline for API compatibility checks

MartijnVisser merged PR #18: URL: https://github.com/apache/flink-connector-opensearch/pull/18 -- 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 specific comment. To unsubscribe, e-mail: issues-un

[GitHub] [flink] Aitozi commented on a diff in pull request #22324: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

Aitozi commented on code in PR #22324: URL: https://github.com/apache/flink/pull/22324#discussion_r1163697823 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java: ## @@ -435,6 +435,16 @@ public class ExecutionConfigOpti

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #220: [FLINK-31325] Improve performance of Swing

zhipeng93 commented on code in PR #220: URL: https://github.com/apache/flink-ml/pull/220#discussion_r1163692614 ## flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/swing/Swing.java: ## @@ -147,9 +148,11 @@ public Table[] transform(Table... inputs) {

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #220: [FLINK-31325] Improve performance of Swing

zhipeng93 commented on code in PR #220: URL: https://github.com/apache/flink-ml/pull/220#discussion_r1163692614 ## flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/swing/Swing.java: ## @@ -147,9 +148,11 @@ public Table[] transform(Table... inputs) {

[GitHub] [flink] slfan1989 commented on pull request #22374: [FLINK-31761] Fix Some Typo And Improve lambda expressions.

slfan1989 commented on PR #22374: URL: https://github.com/apache/flink/pull/22374#issuecomment-1504748992 @1996fanrui Can you help review this pr? Thank you very much! This is a small change. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink-ml] zhipeng93 commented on pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

zhipeng93 commented on PR #230: URL: https://github.com/apache/flink-ml/pull/230#issuecomment-1504743193 Thanks for the update. LGTM. -- 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 specific

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

zhipeng93 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163685932 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/CoGroupOperator.java: ## @@ -0,0 +1,313 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

zhipeng93 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163671343 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/CoGroupOperator.java: ## @@ -0,0 +1,313 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

zhipeng93 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163672488 ## flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/DataStreamUtilsTest.java: ## @@ -59,6 +64,54 @@ public void testMapPartition() throws Exception {

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

zhipeng93 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163671787 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/CoGroupOperator.java: ## @@ -0,0 +1,313 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

zhipeng93 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163671343 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/CoGroupOperator.java: ## @@ -0,0 +1,313 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Commented] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711203#comment-17711203 ] Aitozi commented on FLINK-31533: Yes, it's indeed need to revisit the parser of the ctas

[GitHub] [flink-ml] zhipeng93 merged pull request #231: [FLINK-31374] ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

zhipeng93 merged PR #231: URL: https://github.com/apache/flink-ml/pull/231 -- 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 specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

[GitHub] [flink-ml] zhipeng93 commented on pull request #231: [FLINK-31374] ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

zhipeng93 commented on PR #231: URL: https://github.com/apache/flink-ml/pull/231#issuecomment-1504703810 Thanks for the update. LGTM. -- 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 specific

[jira] [Comment Edited] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711200#comment-17711200 ] Aitozi edited comment on FLINK-18027 at 4/12/23 5:43 AM: - The co

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711200#comment-17711200 ] Aitozi commented on FLINK-18027: The content is modified from  [https://github.com/apa

[GitHub] [flink] Aitozi commented on a diff in pull request #22378: [FLINK-31344][planner] Support to update nested columns in update sta…

Aitozi commented on code in PR #22378: URL: https://github.com/apache/flink/pull/22378#discussion_r1162597631 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/RowLevelUpdateTest.xml: ## @@ -20,17 +20,17 @@ limitations under the

[GitHub] [flink] Aitozi commented on a diff in pull request #22378: [FLINK-31344][planner] Support to update nested columns in update sta…

Aitozi commented on code in PR #22378: URL: https://github.com/apache/flink/pull/22378#discussion_r1162702918 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/RowLevelUpdateTest.xml: ## @@ -20,17 +20,17 @@ limitations under the

[GitHub] [flink-ml] lindong28 opened a new pull request, #232: [hotfix] Update pattern matching in test_ml_lib_completeness to work with release branch

lindong28 opened a new pull request, #232: URL: https://github.com/apache/flink-ml/pull/232 ## What is the purpose of the change Update pattern matching in test_ml_lib_completeness to work with release branch ## Brief change log Updated test_ml_lib_completeness. #

[jira] [Commented] (FLINK-31775) High-Availability not supported in kubernetes when istio enabled

[ https://issues.apache.org/jira/browse/FLINK-31775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711185#comment-17711185 ] Weihua Hu commented on FLINK-31775: --- Thanks [~sergiosp] report this. IMHO, this is t

[GitHub] [flink] pgaref commented on a diff in pull request #21923: FLINK-13871: Consolidate volatile status fields in StreamTask

pgaref commented on code in PR #21923: URL: https://github.com/apache/flink/pull/21923#discussion_r1163517899 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -980,8 +963,7 @@ protected CompletableFuture getCompletionFuture()

[GitHub] [flink] pgaref commented on a diff in pull request #21923: FLINK-13871: Consolidate volatile status fields in StreamTask

pgaref commented on code in PR #21923: URL: https://github.com/apache/flink/pull/21923#discussion_r1163517899 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -980,8 +963,7 @@ protected CompletableFuture getCompletionFuture()

[GitHub] [flink] pgaref commented on a diff in pull request #21923: FLINK-13871: Consolidate volatile status fields in StreamTask

pgaref commented on code in PR #21923: URL: https://github.com/apache/flink/pull/21923#discussion_r1163517899 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -980,8 +963,7 @@ protected CompletableFuture getCompletionFuture()

[GitHub] [flink] pgaref commented on a diff in pull request #21923: FLINK-13871: Consolidate volatile status fields in StreamTask

pgaref commented on code in PR #21923: URL: https://github.com/apache/flink/pull/21923#discussion_r1163517899 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -980,8 +963,7 @@ protected CompletableFuture getCompletionFuture()

[GitHub] [flink] pgaref commented on a diff in pull request #21923: FLINK-13871: Consolidate volatile status fields in StreamTask

pgaref commented on code in PR #21923: URL: https://github.com/apache/flink/pull/21923#discussion_r1163517899 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -980,8 +963,7 @@ protected CompletableFuture getCompletionFuture()

[jira] [Updated] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liam updated FLINK-31762: - Description: To simplify the demonstration, let us assume that there are two topics, and each topic has four pa

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #229: [FLINK-31255] Wraps the operator config about serializer

jiangxin369 commented on code in PR #229: URL: https://github.com/apache/flink-ml/pull/229#discussion_r1161619708 ## flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java: ## @@ -104,6 +107,33 @@ public static StreamConfig createWrappedOperatorC

[GitHub] [flink-ml] jiangxin369 commented on pull request #231: [FLINK-31374] ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

jiangxin369 commented on PR #231: URL: https://github.com/apache/flink-ml/pull/231#issuecomment-1504431951 @zhipeng93 Thanks for the review, I've updated the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-31301) Unsupported nested columns in column list of insert statement

[ https://issues.apache.org/jira/browse/FLINK-31301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711166#comment-17711166 ] lincoln lee commented on FLINK-31301: - [~aitozi] thanks for fixing this! I'll try to

[jira] [Comment Edited] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711161#comment-17711161 ] luoyuxia edited comment on FLINK-31533 at 4/12/23 1:27 AM: --- [~

[jira] [Comment Edited] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711161#comment-17711161 ] luoyuxia edited comment on FLINK-31533 at 4/12/23 1:27 AM: --- [~

[jira] [Commented] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711161#comment-17711161 ] luoyuxia commented on FLINK-31533: -- [~aitozi] Thanks for voluntering,  but please remem

[jira] [Assigned] (FLINK-31774) Add document for delete and update statement

[ https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-31774: Assignee: Aitozi > Add document for delete and update statement > ---

[jira] [Commented] (FLINK-31774) Add document for delete and update statement

[ https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711159#comment-17711159 ] luoyuxia commented on FLINK-31774: -- [~aitozi] Thanks for raising it and voluntering. I

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

lindong28 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163455375 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/CoGroupOperator.java: ## @@ -0,0 +1,313 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

lindong28 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163453972 ## flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/DataStreamUtilsTest.java: ## @@ -59,6 +64,54 @@ public void testMapPartition() throws Exception {

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

lindong28 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163453972 ## flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/DataStreamUtilsTest.java: ## @@ -59,6 +64,54 @@ public void testMapPartition() throws Exception {

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

lindong28 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163453277 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/CoGroupOperator.java: ## @@ -0,0 +1,313 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

lindong28 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163450592 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/CoGroupOperator.java: ## @@ -0,0 +1,313 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #230: [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup

lindong28 commented on code in PR #230: URL: https://github.com/apache/flink-ml/pull/230#discussion_r1163449957 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/CoGroupOperator.java: ## @@ -0,0 +1,313 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-connector-kafka] tzulitai commented on pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

tzulitai commented on PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#issuecomment-1504292430 Merged via https://github.com/apache/flink-connector-kafka/commit/a7785630e714af303b224c38d9a6caa89a551265 I squashed my changes along with your comment. Please let me k

[GitHub] [flink-connector-kafka] tzulitai closed pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

tzulitai closed pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink URL: https://github.com/apache/flink-connector-kafka/pull/18 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-connector-kafka] tzulitai commented on pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

tzulitai commented on PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#issuecomment-1504282565 @AlexAxeman thanks a lot for your contribution! +1 LGTM. Since there's other work that is sort of depending on this feature, I'll proceed to merge this PR and address my

[jira] [Comment Edited] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS

[ https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710375#comment-17710375 ] Sergio Sainz edited comment on FLINK-28171 at 4/11/23 11:46 PM: --

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

tzulitai commented on code in PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1163427396 ## flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilderTest.java: ## @@ -86,6 +89,16 @@ public vo

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21923: FLINK-13871: Consolidate volatile status fields in StreamTask

rkhachatryan commented on code in PR #21923: URL: https://github.com/apache/flink/pull/21923#discussion_r1163352135 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -980,8 +963,7 @@ protected CompletableFuture getCompletionFut

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21833: [FLINK-30852][runtime] Checking task cancelation explicitly rather than failing the cancel method

rkhachatryan commented on code in PR #21833: URL: https://github.com/apache/flink/pull/21833#discussion_r1163338534 ## flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java: ## @@ -1300,9 +1304,7 @@ public TestInvokableCorrect(Environment environment) {

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #563: [FLINK-31716] Event UID field is missing the first time that an event…

morhidi commented on PR #563: URL: https://github.com/apache/flink-kubernetes-operator/pull/563#issuecomment-1504075103 +1 LGTM -- 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 specific comme

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22377: [FLINK-31765][runtime][test] Disable changelog backend for RocksDB migration tests

rkhachatryan commented on code in PR #22377: URL: https://github.com/apache/flink/pull/22377#discussion_r1163316537 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/StatefulJobSnapshotMigrationITCase.java: ## @@ -136,6 +136,9 @@ public void testSavepoint() throws

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #563: [FLINK-31716] Event UID field is missing the first time that an event…

morhidi commented on code in PR #563: URL: https://github.com/apache/flink-kubernetes-operator/pull/563#discussion_r1163279331 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/EventUtilsTest.java: ## @@ -72,6 +72,7 @@ public void accept(Even

[GitHub] [flink-connector-opensearch] reta commented on pull request #18: [hotfix] Use 1.0.0-1.16 baseline for API compatibility checks

reta commented on PR #18: URL: https://github.com/apache/flink-connector-opensearch/pull/18#issuecomment-1504021457 @MartijnVisser if you have time, super small one, thank you -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink-kubernetes-operator] rodmeneses opened a new pull request, #563: [FLINK-31716] Event UID field is missing the first time that an event…

rodmeneses opened a new pull request, #563: URL: https://github.com/apache/flink-kubernetes-operator/pull/563 What is the purpose of the change Fixes a bug reported on https://issues.apache.org/jira/browse/FLINK-31716 where the event being consumed for the first time didn't have a

[jira] [Commented] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711097#comment-17711097 ] Roman Khachatryan commented on FLINK-31743: --- [~assassinj] are you still planni

[jira] [Updated] (FLINK-31775) High-Availability not supported in kubernetes when istio enabled

[ https://issues.apache.org/jira/browse/FLINK-31775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Sainz updated FLINK-31775: - Description: When using native kubernetes deployment mode with high-availability (HA), and when

[jira] [Reopened] (FLINK-31716) Event UID field is missing the first time that an event is consumed

[ https://issues.apache.org/jira/browse/FLINK-31716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reopened FLINK-31716: > Event UID field is missing the first time that an event is consumed > --

[jira] [Updated] (FLINK-31775) High-Availability not supported in kubernetes when istio enabled

[ https://issues.apache.org/jira/browse/FLINK-31775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Sainz updated FLINK-31775: - Description: When using native kubernetes deployment mode with high-availability, and when new

[jira] [Updated] (FLINK-31775) High-Availability not supported in kubernetes when istio enabled

[ https://issues.apache.org/jira/browse/FLINK-31775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Sainz updated FLINK-31775: - Description: When using native kubernetes deployment mode, and when new TaskManager pod is star

[jira] [Updated] (FLINK-31775) High-Availability not supported in kubernetes when istio enabled

[ https://issues.apache.org/jira/browse/FLINK-31775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Sainz updated FLINK-31775: - Description: When using native kubernetes deployment mode, and when new TaskManager pod is star

[jira] [Created] (FLINK-31775) High-Availability not supported in kubernetes when istio enabled

Sergio Sainz created FLINK-31775: Summary: High-Availability not supported in kubernetes when istio enabled Key: FLINK-31775 URL: https://issues.apache.org/jira/browse/FLINK-31775 Project: Flink

[GitHub] [flink] MartijnVisser closed pull request #22371: [FLINK-28171] [flink-kubernates] enable add appProtocol via the configuration and verify it is not overridden by Default port defintion

MartijnVisser closed pull request #22371: [FLINK-28171] [flink-kubernates] enable add appProtocol via the configuration and verify it is not overridden by Default port defintion URL: https://github.com/apache/flink/pull/22371 -- This is an automated message from the Apache Git Service. To re

[GitHub] [flink-connector-elasticsearch] MartijnVisser commented on pull request #59: [FLINK-31696] ElasticSearch nightly CI failure

MartijnVisser commented on PR #59: URL: https://github.com/apache/flink-connector-elasticsearch/pull/59#issuecomment-1503913242 Nightly triggered at https://github.com/apache/flink-connector-elasticsearch/actions/runs/4670944068 -- This is an automated message from the Apache Git Service

[jira] [Assigned] (FLINK-17508) Develop Oracle Catalog

[ https://issues.apache.org/jira/browse/FLINK-17508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-17508: -- Assignee: (was: RocMarshal) > Develop Oracle Catalog > -- > >

[jira] [Closed] (FLINK-31696) ElasticSearch nightly CI failure

[ https://issues.apache.org/jira/browse/FLINK-31696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31696. -- Fix Version/s: elasticsearch-4.0.0 Resolution: Fixed Fixed in main: 85f0f4057a6b241a7d9

[GitHub] [flink-connector-elasticsearch] MartijnVisser merged pull request #59: [FLINK-31696] ElasticSearch nightly CI failure

MartijnVisser merged PR #59: URL: https://github.com/apache/flink-connector-elasticsearch/pull/59 -- 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 specific comment. To unsubscribe, e-mail: issues

[GitHub] [flink-connector-elasticsearch] reta commented on pull request #59: [FLINK-31696] ElasticSearch nightly CI failure

reta commented on PR #59: URL: https://github.com/apache/flink-connector-elasticsearch/pull/59#issuecomment-1503855950 > @reta Can you include setting the version for the connector to 4.0-SNAPSHOT, given that we'll drop support for Flink 1.16 with this PR? @MartijnVisser it was done

[GitHub] [flink] flinkbot commented on pull request #22381: [FLINK-31763][runtime] Ensure that the total number of requested buffers does not exceed poolSize + maxOverdraftBuffersPerGate

flinkbot commented on PR #22381: URL: https://github.com/apache/flink/pull/22381#issuecomment-1503852904 ## CI report: * d4ac5891e842a21920525a5ed5f0ccce5206718c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31763) Ensure that the total number of requested buffers does not exceed poolSize + maxOverdraftBuffersPerGate

[ https://issues.apache.org/jira/browse/FLINK-31763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31763: --- Labels: pull-request-available (was: ) > Ensure that the total number of requested buffers

[GitHub] [flink] reswqa opened a new pull request, #22381: [FLINK-31763][runtime] Ensure that the total number of requested buffers does not exceed poolSize + maxOverdraftBuffersPerGate

reswqa opened a new pull request, #22381: URL: https://github.com/apache/flink/pull/22381 ## What is the purpose of the change *As we discussed in [FLINK-31610](https://issues.apache.org/jira/browse/FLINK-31610), new buffers can be requested only when `numOfRequestedMemorySegments +

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

tzulitai commented on code in PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1163104861 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProducer.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

tzulitai commented on code in PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1163104861 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProducer.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink-connector-kafka] AlexAxeman commented on a diff in pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

AlexAxeman commented on code in PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1163100734 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProducer.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Softw

[GitHub] [flink-connector-kafka] AlexAxeman commented on a diff in pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

AlexAxeman commented on code in PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1163098741 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProducer.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Softw

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

tzulitai commented on code in PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1163096185 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProducer.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink] mohsenrezaeithe commented on pull request #22302: [hotfix] [docs] Fix `ROW()` decleration syntax

mohsenrezaeithe commented on PR #22302: URL: https://github.com/apache/flink/pull/22302#issuecomment-1503771608 @wuchong could you please approve this? -- 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 g

[GitHub] [flink-connector-opensearch] reta opened a new pull request, #18: [hotfix] Use 1.0.0-1.16 baseline for API compatibility checks

reta opened a new pull request, #18: URL: https://github.com/apache/flink-connector-opensearch/pull/18 Use 1.0.0-1.16 baseline for API compatibility checks -- 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

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

tzulitai commented on code in PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1163083277 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProducer.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Softwar

[jira] [Updated] (FLINK-31696) ElasticSearch nightly CI failure

[ https://issues.apache.org/jira/browse/FLINK-31696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31696: --- Labels: pull-request-available (was: ) > ElasticSearch nightly CI failure > ---

[GitHub] [flink-connector-elasticsearch] reta opened a new pull request, #59: [FLINK-31696] ElasticSearch nightly CI failure

reta opened a new pull request, #59: URL: https://github.com/apache/flink-connector-elasticsearch/pull/59 ElasticSearch nightly CI failure -- 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 spec

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #16: [hotfix] Fix nightly build for 1.18-SNAPSHOT, drop 1.16-SNAPSHOT from the nightly matrix

reta commented on code in PR #16: URL: https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1163061352 ## .github/workflows/release.yml: ## @@ -24,7 +24,7 @@ jobs: if: github.repository_owner == 'apache' strategy: matrix: -flink: [1.

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711040#comment-17711040 ] Aitozi commented on FLINK-18027: [~libenchao] do you know why the explicit ROW construct

[jira] [Updated] (FLINK-17508) Develop Oracle Catalog

[ https://issues.apache.org/jira/browse/FLINK-17508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-17508: --- Summary: Develop Oracle Catalog (was: Develop OracleCatalog) > Develop Oracle Catalog > ---

[jira] [Closed] (FLINK-29672) Support oracle catalog

[ https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29672. -- Resolution: Duplicate > Support oracle catalog > --- > >

[GitHub] [flink-shaded] MartijnVisser commented on a diff in pull request #120: [FLINK-31719][Build/Shaded] Update Netty to 4.1.91.Final

MartijnVisser commented on code in PR #120: URL: https://github.com/apache/flink-shaded/pull/120#discussion_r1163023881 ## pom.xml: ## @@ -355,6 +355,20 @@ under the License. + + +org.cyclonedx +

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

tzulitai commented on code in PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1163021963 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProducer.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Softwar

[jira] [Commented] (FLINK-31774) Add document for delete and update statement

[ https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711033#comment-17711033 ] Aitozi commented on FLINK-31774: I think we should add the description for this two stat

[jira] [Updated] (FLINK-31774) Add document for delete and update statement

[ https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-31774: --- Parent: FLINK-30648 Issue Type: Sub-task (was: Improvement) > Add document for delete and update st

[GitHub] [flink-connector-opensearch] MartijnVisser commented on pull request #16: [hotfix] Fix nightly build for 1.18-SNAPSHOT, drop 1.16-SNAPSHOT from the nightly matrix

MartijnVisser commented on PR #16: URL: https://github.com/apache/flink-connector-opensearch/pull/16#issuecomment-1503642528 > may I ask you please to trigger nightly action manually https://github.com/apache/flink-connector-opensearch/actions/runs/4669419298 is started! -- This i

[GitHub] [flink-connector-opensearch] MartijnVisser commented on a diff in pull request #16: [hotfix] Fix nightly build for 1.18-SNAPSHOT, drop 1.16-SNAPSHOT from the nightly matrix

MartijnVisser commented on code in PR #16: URL: https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1163012687 ## .github/workflows/release.yml: ## @@ -24,7 +24,7 @@ jobs: if: github.repository_owner == 'apache' strategy: matrix: -f

[jira] [Created] (FLINK-31774) Add document for delete and update statement

Aitozi created FLINK-31774: -- Summary: Add document for delete and update statement Key: FLINK-31774 URL: https://issues.apache.org/jira/browse/FLINK-31774 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-31760) COALESCE() with NULL arguments throws error

[ https://issues.apache.org/jira/browse/FLINK-31760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711022#comment-17711022 ] Mohsen Rezaei commented on FLINK-31760: --- [~lincoln.86xy], if I understand correctl

[GitHub] [flink-connector-opensearch] reta commented on pull request #16: [hotfix] Fix nightly build for 1.18-SNAPSHOT, drop 1.16-SNAPSHOT from the nightly matrix

reta commented on PR #16: URL: https://github.com/apache/flink-connector-opensearch/pull/16#issuecomment-1503618001 > LGTM Thanks a lot, may I ask you please to trigger nightly action manually when you have an opportunity, thank you (once it is green, I will replicate changes to Ela

[GitHub] [flink-connector-opensearch] MartijnVisser merged pull request #16: [hotfix] Fix nightly build for 1.18-SNAPSHOT, drop 1.16-SNAPSHOT from the nightly matrix

MartijnVisser merged PR #16: URL: https://github.com/apache/flink-connector-opensearch/pull/16 -- 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 specific comment. To unsubscribe, e-mail: issues-un

[GitHub] [flink-connector-opensearch] MartijnVisser commented on a diff in pull request #16: [hotfix] Fix nightly build for 1.18-SNAPSHOT, drop 1.16-SNAPSHOT from the nightly matrix

MartijnVisser commented on code in PR #16: URL: https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1162981670 ## .github/workflows/release.yml: ## @@ -24,7 +24,7 @@ jobs: if: github.repository_owner == 'apache' strategy: matrix: -f

[jira] [Commented] (FLINK-31760) COALESCE() with NULL arguments throws error

[ https://issues.apache.org/jira/browse/FLINK-31760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711014#comment-17711014 ] Mohsen Rezaei commented on FLINK-31760: --- Hi [~lemonjing], thanks for the quick res

[jira] (FLINK-31760) COALESCE() with NULL arguments throws error

[ https://issues.apache.org/jira/browse/FLINK-31760 ] Mohsen Rezaei deleted comment on FLINK-31760: --- was (Author: JIRAUSER298550): Hi [~lemonjing], thanks for the quick response. I'm interested in providing a fix, but I need to dig a bit and

[jira] [Commented] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711002#comment-17711002 ] Aitozi commented on FLINK-31533: [~luoyuxia] I think it's a useful feature, and I'd like

[GitHub] [flink] godfreyhe commented on a diff in pull request #22376: [FLINK-31767][table-planner] Improve the implementation for "analyze table" execution on partitioned table

godfreyhe commented on code in PR #22376: URL: https://github.com/apache/flink/pull/22376#discussion_r1162913583 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/AnalyzeTableUtil.java: ## @@ -137,13 +138,46 @@ private static CatalogColumnStat

  1   2   >