Re: [PR] [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document. [flink]

2025-08-02 Thread via GitHub
github-actions[bot] closed pull request #22534: [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document. URL: https://github.com/apache/flink/pull/22534 -- This is an automated message from the Apache Git Service. To respond to the message, please lo

Re: [PR] [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document. [flink]

2025-08-02 Thread via GitHub
github-actions[bot] commented on PR #22534: URL: https://github.com/apache/flink/pull/22534#issuecomment-3147381522 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-37735][serializer] Replace class.newInstance with constructor.newInstance [flink]

2025-08-02 Thread via GitHub
X-czh commented on PR #26863: URL: https://github.com/apache/flink/pull/26863#issuecomment-3147299521 @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 comment. To

[jira] [Updated] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID

2025-08-02 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-38183: -- Description: As the design of [https://github.com/apache/flink-cdc/pull/2220|http://example.com/],CDC

[jira] [Updated] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID

2025-08-02 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-38183: -- Description: As the design of [https://github.com/apache/flink-cdc/pull/2220|http://example.com/],CDC

[jira] [Updated] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID

2025-08-02 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-38183: -- Description: As the design of [https://github.com/apache/flink-cdc/pull/2220|http://example.com/],CDC

[jira] [Updated] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID

2025-08-02 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-38183: -- Description: As the design of [https://github.com/apache/flink-cdc/pull/2220|http://example.com/],CDC

[PR] [api][java] Support DataStream / Table as input / output of Flink Agents in Java [flink-agents]

2025-08-02 Thread via GitHub
letaoj opened a new pull request, #85: URL: https://github.com/apache/flink-agents/pull/85 Linked issue: #xxx ### Purpose of change ### Tests ### API ### Documentation -- This is an automated message from t

[jira] [Updated] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID

2025-08-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38183: --- Labels: pull-request-available (was: ) > Data loss when cdc reading mysql that has out of o

[PR] [FLINK-38183] Fix the problem of data loss in the GTID disordered scenario [flink-cdc]

2025-08-02 Thread via GitHub
lzshlzsh opened a new pull request, #4072: URL: https://github.com/apache/flink-cdc/pull/4072 As the design of [https://github.com/apache/flink-cdc/pull/2220](http://example.com/),CDC only cares about the maximum GTID position and starts from it. For example, if reading from gtid offset 1-

[jira] [Created] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID

2025-08-02 Thread LiuZeshan (Jira)
LiuZeshan created FLINK-38183: - Summary: Data loss when cdc reading mysql that has out of order GTID Key: FLINK-38183 URL: https://issues.apache.org/jira/browse/FLINK-38183 Project: Flink Issue

Re: [PR] [FLINK-37700][table-planner] Fix SQL parse exception when creating a view with PTF [flink]

2025-08-02 Thread via GitHub
juntaozhang commented on code in PR #26487: URL: https://github.com/apache/flink/pull/26487#discussion_r2249492755 ## flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/SqlCall.java: ## @@ -0,0 +1,249 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc]

2025-08-02 Thread via GitHub
phamvinh1712 commented on PR #4004: URL: https://github.com/apache/flink-cdc/pull/4004#issuecomment-3146819556 hi @loserwang1024 @leonardBang @ruanhang1993 , thanks all for the feedbacks 🙌 and sorry for the late response. I've updated the configuration like suggested, could you help to

[PR] [minor][improvement] Add subdirectory scrapping to add all .jar in classpath [flink-cdc]

2025-08-02 Thread via GitHub
CatOrLeader opened a new pull request, #4071: URL: https://github.com/apache/flink-cdc/pull/4071 ## Rationale I was stuck with this issue for a while when deploying CDC pipelines on my cluster. It seems that it is not convenient to get .jar files only at the first level of depth, so

Re: [PR] [FLINK-36536] Bumped `commons-text` from 1.10.0 to 1.12.0 [flink]

2025-08-02 Thread via GitHub
snuyanzin commented on code in PR #26459: URL: https://github.com/apache/flink/pull/26459#discussion_r2249297445 ## flink-dist/src/main/resources/META-INF/NOTICE: ## @@ -13,9 +13,9 @@ This project bundles the following dependencies under the Apache Software Licens - commons-co

Re: [PR] [FLINK-37637] Avoid dead lock for Configuration's addAll [flink]

2025-08-02 Thread via GitHub
snuyanzin commented on code in PR #26426: URL: https://github.com/apache/flink/pull/26426#discussion_r2249278788 ## flink-core/src/main/java/org/apache/flink/configuration/Configuration.java: ## @@ -239,9 +239,21 @@ public void addAllToProperties(Properties props) { }

Re: [PR] [FLINK-37700][table-planner] Fix SQL parse exception when creating a view with PTF [flink]

2025-08-02 Thread via GitHub
snuyanzin commented on code in PR #26487: URL: https://github.com/apache/flink/pull/26487#discussion_r2249277947 ## flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/SqlCall.java: ## @@ -0,0 +1,249 @@ +/* + * Licensed to the Apache Software Foundation (ASF) un

Re: [PR] [FLINK-38135][table] Fix call to non-existent method for RAW type hashing [flink]

2025-08-02 Thread via GitHub
snuyanzin commented on code in PR #26823: URL: https://github.com/apache/flink/pull/26823#discussion_r2249274542 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/CalcITCase.scala: ## @@ -1692,9 +1692,10 @@ class CalcITCase extend

[jira] [Resolved] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL

2025-08-02 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-38069. - Fix Version/s: 2.2.0 Resolution: Fixed > The nullability of function ENCODE retur

Re: [PR] [FLINK-38135][table] Fix call to non-existent method for RAW type hashing [flink]

2025-08-02 Thread via GitHub
snuyanzin commented on code in PR #26823: URL: https://github.com/apache/flink/pull/26823#discussion_r2249274387 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/CalcITCase.scala: ## @@ -857,22 +857,22 @@ class CalcITCase extends

[jira] [Assigned] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL

2025-08-02 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-38069: --- Assignee: dylanhz > The nullability of function ENCODE return type differs in Table

Re: [PR] [FLINK-38069] Fix return type nullability diffs of function ENCODE & DECODE in SQL and Table API [flink]

2025-08-02 Thread via GitHub
snuyanzin merged PR #26771: URL: https://github.com/apache/flink/pull/26771 -- 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.apa

[jira] [Commented] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL

2025-08-02 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18011602#comment-18011602 ] Sergey Nuyanzin commented on FLINK-38069: - Merged as [a356421ded64dc95a7c274e25

[jira] [Resolved] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector

2025-08-02 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-38138. - Fix Version/s: 2.2.0 Resolution: Fixed > Array OOB error when trying to get a bin

[jira] [Commented] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector

2025-08-02 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18011599#comment-18011599 ] Sergey Nuyanzin commented on FLINK-38138: - Merged as [63b2ad5ffe8c3d064a7086fb9

Re: [PR] [FLINK-38138] Fix OOB error in ColumnarArrayData [flink]

2025-08-02 Thread via GitHub
snuyanzin merged PR #26826: URL: https://github.com/apache/flink/pull/26826 -- 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.apa

[jira] [Assigned] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector

2025-08-02 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-38138: --- Assignee: Voon Hou > Array OOB error when trying to get a binary from a non-zero of

[jira] [Commented] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support

2025-08-02 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18011597#comment-18011597 ] Sergey Nuyanzin commented on FLINK-38179: - Merged as [d0eb9ef97908053a51df6b8e7

[jira] [Updated] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support

2025-08-02 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-38179: Fix Version/s: 2.2.0 > Build Failure Due to os-maven-plugin Missing Support >

Re: [PR] [FLINK-38179] Upgrade os-maven-plugin for RISC-V riscv64 support [flink]

2025-08-02 Thread via GitHub
snuyanzin merged PR #26860: URL: https://github.com/apache/flink/pull/26860 -- 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.apa

Re: [PR] [FLINK-38179] Upgrade os-maven-plugin for RISC-V riscv64 support [flink]

2025-08-02 Thread via GitHub
snuyanzin commented on PR #26860: URL: https://github.com/apache/flink/pull/26860#issuecomment-3146539372 @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 comment.

[jira] [Resolved] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support

2025-08-02 Thread Gong Xiaofei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gong Xiaofei resolved FLINK-38179. -- Resolution: Fixed > Build Failure Due to os-maven-plugin Missing Support > ---

Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc]

2025-08-02 Thread via GitHub
mielientiev commented on PR #3845: URL: https://github.com/apache/flink-cdc/pull/3845#issuecomment-3146501691 @leonardBang @xiaom @ruanhang1993 Could you please review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator

2025-08-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37869: --- Labels: pull-request-available (was: ) > FINISHED bouned job can't be cleanup by the Flink

[PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator]

2025-08-02 Thread via GitHub
qinf opened a new pull request, #1003: URL: https://github.com/apache/flink-kubernetes-operator/pull/1003 ## What is the purpose of the change Fix finished bounded stream jobs can't be cleanup by the Flink Kubernetes Operator [FLINK-37869](https://issues.apache.org/jira/br

Re: [PR] [hotfix] Do not run community review label and stale PR workflow on forks [flink]

2025-08-02 Thread via GitHub
flinkbot commented on PR #26864: URL: https://github.com/apache/flink/pull/26864#issuecomment-3146369271 ## CI report: * e8c08de0501f6366b9505bdf23e998c3ce90f8c9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [hotfix] Do not run community review label and stale PR workflow on forks [flink]

2025-08-02 Thread via GitHub
snuyanzin commented on PR #26864: URL: https://github.com/apache/flink/pull/26864#issuecomment-3146368782 @davidradl , @tomncooper If I'm not mistaken you were some of the drivers of these workflows, could please take a look here? -- This is an automated message from the Apache Git Se

[PR] [hotfix] Do not run community review label on non Apache repo [flink]

2025-08-02 Thread via GitHub
snuyanzin opened a new pull request, #26864: URL: https://github.com/apache/flink/pull/26864 ## What is the purpose of the change The problem is that if someone syncs his/her fork with recent master then stale PR and community review process will start running on that fork as well...