[jira] [Commented] (FLINK-34677) Refactor the structure of documentation for Flink CDC

2024-03-19 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828201#comment-17828201 ] Zhongqiang Gong commented on FLINK-34677: - [~renqs] [~leonard]  About ci of docu

[PR] [Draft] Merge SpeculativeScheduler to AdaptiveBatchScheduler [flink]

2024-03-19 Thread via GitHub
JunRuiLee opened a new pull request, #24524: URL: https://github.com/apache/flink/pull/24524 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2024-03-19 Thread via GitHub
drorventura commented on PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-2006100743 Hi Is this going to be merged soon? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [Draft] Merge SpeculativeScheduler to AdaptiveBatchScheduler [flink]

2024-03-19 Thread via GitHub
flinkbot commented on PR #24524: URL: https://github.com/apache/flink/pull/24524#issuecomment-2006117882 ## CI report: * d0709bdc64d8de4f7a7fa9db976281729772417c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34720) Deploy Maven Snapshot failed on AZP

2024-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828208#comment-17828208 ] Matthias Pohl commented on FLINK-34720: --- Your conclusion is correct. I missed cert

[jira] [Closed] (FLINK-34720) Deploy Maven Snapshot failed on AZP

2024-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-34720. - Resolution: Duplicate > Deploy Maven Snapshot failed on AZP > --

[jira] [Commented] (FLINK-34720) Deploy Maven Snapshot failed on AZP

2024-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828209#comment-17828209 ] Matthias Pohl commented on FLINK-34720: --- master: 676a1995c2b20e2ffc20c0b9b99d14656

Re: [PR] [FLINK-34720][ci] Fallback to $MAVEN_WRAPPER [flink]

2024-03-19 Thread via GitHub
XComp closed pull request #24521: [FLINK-34720][ci] Fallback to $MAVEN_WRAPPER URL: https://github.com/apache/flink/pull/24521 -- 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. T

Re: [PR] [FLINK-34720][ci] Fallback to $MAVEN_WRAPPER [flink]

2024-03-19 Thread via GitHub
XComp commented on PR #24521: URL: https://github.com/apache/flink/pull/24521#issuecomment-2006129783 Thanks for looking into it. I decided to revert FLINK-34194 because it's not only affecting the artifact deployment (also the docs CI is failing). I will reopen FLINK-34194 and cover the ch

[jira] [Created] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large

2024-03-19 Thread Wancheng Xiao (Jira)
Wancheng Xiao created FLINK-34727: - Summary: RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large Key: FLINK-34727 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Reopened] (FLINK-34194) Upgrade Flink CI Docker container to Ubuntu 22.04

2024-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-34194: --- There are issues with the artifact deployment and docs build where the workflows are still rely

[jira] [Commented] (FLINK-34726) Flink Kubernetes Operator has some room for optimizing performance.

2024-03-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828210#comment-17828210 ] Gyula Fora commented on FLINK-34726: Thanks for the detailed analysis [~Fei Feng] .

[jira] [Updated] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large

2024-03-19 Thread Wancheng Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wancheng Xiao updated FLINK-34727: -- Description: The task was succeed, but "RestClusterClient.requestJobResult()" encountered an

[jira] [Updated] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large

2024-03-19 Thread Wancheng Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wancheng Xiao updated FLINK-34727: -- Description: The task was succeed, but "RestClusterClient.requestJobResult()" encountered an

[jira] [Updated] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large

2024-03-19 Thread Wancheng Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wancheng Xiao updated FLINK-34727: -- Description: The task was succeed, but "RestClusterClient.requestJobResult()" encountered an

Re: [PR] [FLINK-34686][cdc] add docs about yarn deployment [flink-cdc]

2024-03-19 Thread via GitHub
leonardBang commented on code in PR #3163: URL: https://github.com/apache/flink-cdc/pull/3163#discussion_r1529878089 ## docs/content/docs/deployment/yarn.md: ## @@ -23,3 +23,131 @@ KIND, either express or implied. See the License for the specific language governing permissions

[PR] [FLINK-34724][docs] Fix broken web link in document of legacy Flink CDC Sources [flink-cdc]

2024-03-19 Thread via GitHub
loserwang1024 opened a new pull request, #3167: URL: https://github.com/apache/flink-cdc/pull/3167 In current document, many link is broken due to directory structure changes, such as: - http://localhost:1313/flink/flink-cdc-docs-master/docs/connectors/legacy-flink-cdc-sources/overvi

[jira] [Updated] (FLINK-34724) Fix broken web link in document of legacy Flink CDC Sources

2024-03-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34724: --- Labels: pull-request-available (was: ) > Fix broken web link in document of legacy Flink C

Re: [PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-19 Thread via GitHub
LadyForest merged PR #24511: URL: https://github.com/apache/flink/pull/24511 -- 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.ap

[jira] [Assigned] (FLINK-34713) Updates the docs stable version

2024-03-19 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34713: --- Assignee: lincoln lee > Updates the docs stable version > --- >

[jira] [Updated] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large

2024-03-19 Thread Wancheng Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wancheng Xiao updated FLINK-34727: -- Description: The task was succeed, but "RestClusterClient.requestJobResult()" encountered an

[jira] [Updated] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large

2024-03-19 Thread Wancheng Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wancheng Xiao updated FLINK-34727: -- Attachment: image-2024-03-19-15-51-20-150.png > RestClusterClient.requestJobResult throw Conne

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2024-03-19 Thread via GitHub
reswqa commented on code in PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1529874870 ## flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java: ## @@ -0,0 +1,107 @@ +

Re: [PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-19 Thread via GitHub
LadyForest merged PR #24512: URL: https://github.com/apache/flink/pull/24512 -- 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.ap

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-19 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828216#comment-17828216 ] Jane Chan commented on FLINK-29114: --- Fixed in release-1.17 0b430c2e614a7a9936e5eedf49e

[jira] [Commented] (FLINK-34677) Refactor the structure of documentation for Flink CDC

2024-03-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828217#comment-17828217 ] Leonard Xu commented on FLINK-34677: [~gongzhongqiang] Good idea, +1 for this propos

[jira] [Resolved] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-19 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan resolved FLINK-29114. --- Resolution: Fixed > TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with >

[jira] [Updated] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-19 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-29114: -- Fix Version/s: 1.17.3 1.18.2 > TableSourceITCase#testTableHintWithLogicalTableScanR

[jira] [Updated] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-19 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-29114: -- Affects Version/s: 1.18.0 1.17.0 > TableSourceITCase#testTableHintWithLogicalTa

[jira] [Closed] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-19 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan closed FLINK-29114. - > TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with > result mismatch > --

[jira] [Created] (FLINK-34728) operator does not need to upload and download the jar when deploying session job

2024-03-19 Thread Fei Feng (Jira)
Fei Feng created FLINK-34728: Summary: operator does not need to upload and download the jar when deploying session job Key: FLINK-34728 URL: https://issues.apache.org/jira/browse/FLINK-34728 Project: Fli

[jira] [Updated] (FLINK-34728) operator does not need to upload and download the jar when deploying session job

2024-03-19 Thread Fei Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fei Feng updated FLINK-34728: - Attachment: image-2024-03-19-15-59-20-933.png > operator does not need to upload and download the jar wh

[jira] [Updated] (FLINK-34728) operator does not need to upload and download the jar when deploying session job

2024-03-19 Thread Fei Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fei Feng updated FLINK-34728: - Description: Problem: By reading the source code of the sessionjob's first reconcilition in the sessio

[jira] [Updated] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large

2024-03-19 Thread Wancheng Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wancheng Xiao updated FLINK-34727: -- Description: The task was succeed, but "RestClusterClient.requestJobResult()" encountered an

Re: [PR] [FLINK-34724][docs] Fix broken web link in document of legacy Flink CDC Sources [flink-cdc]

2024-03-19 Thread via GitHub
PatrickRen commented on code in PR #3167: URL: https://github.com/apache/flink-cdc/pull/3167#discussion_r1529899354 ## docs/content.zh/docs/connectors/legacy-flink-cdc-sources/overview.md: ## @@ -304,4 +305,93 @@ you can construct `JsonDebeziumDeserializationSchema` as followin

[jira] [Commented] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService

2024-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828221#comment-17828221 ] Matthias Pohl commented on FLINK-34672: --- IMHO, the both locks are still necessary

[PR] [FLINK-34727][REST]fix rest request writer future not return [flink]

2024-03-19 Thread via GitHub
moesome opened a new pull request, #24525: URL: https://github.com/apache/flink/pull/24525 ## What is the purpose of the change "thenAccept()" did not returned sendResponse's future, causing the server shutdown process before the request was sent complete. ## Brief change

[jira] [Commented] (FLINK-34728) operator does not need to upload and download the jar when deploying session job

2024-03-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828222#comment-17828222 ] Gyula Fora commented on FLINK-34728: That makes sense, however this is more a ticket

[jira] [Updated] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large

2024-03-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34727: --- Labels: pull-request-available (was: ) > RestClusterClient.requestJobResult throw Connectio

Re: [PR] [FLINK-34686][cdc] add docs about yarn deployment [flink-cdc]

2024-03-19 Thread via GitHub
PatrickRen merged PR #3163: URL: https://github.com/apache/flink-cdc/pull/3163 -- 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.

[jira] [Commented] (FLINK-34686) "Deployment - YARN" Page for Flink CDC Documentation

2024-03-19 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828224#comment-17828224 ] Qingsheng Ren commented on FLINK-34686: --- flink-cdc master: 32c8e0bc2a2a8b3f6ea73d2

[jira] [Resolved] (FLINK-34686) "Deployment - YARN" Page for Flink CDC Documentation

2024-03-19 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34686. --- Resolution: Done > "Deployment - YARN" Page for Flink CDC Documentation > --

Re: [PR] [FLINK-34727][REST]fix rest request writer future not return [flink]

2024-03-19 Thread via GitHub
flinkbot commented on PR #24525: URL: https://github.com/apache/flink/pull/24525#issuecomment-2006254957 ## CI report: * 19349af695590b592c7785f0b6d4209df83c1394 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation

2024-03-19 Thread LvYanquan (Jira)
LvYanquan created FLINK-34729: - Summary: "Core Concept" Pages for Flink CDC Chinese Documentation Key: FLINK-34729 URL: https://issues.apache.org/jira/browse/FLINK-34729 Project: Flink Issue Type

[jira] [Commented] (FLINK-34651) The HiveTableSink of Flink does not support writing to S3

2024-03-19 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828225#comment-17828225 ] shizhengchao commented on FLINK-34651: -- [~easonqin]  It won't take effect because t

[jira] [Commented] (FLINK-34651) The HiveTableSink of Flink does not support writing to S3

2024-03-19 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828226#comment-17828226 ] shizhengchao commented on FLINK-34651: -- a > The HiveTableSink of Flink does not su

Re: [PR] [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 [flink]

2024-03-19 Thread via GitHub
lincoln-lil commented on PR #24517: URL: https://github.com/apache/flink/pull/24517#issuecomment-2006256748 @masteryhx Thanks for looking into it and the tips! I'll try regrenerating data. -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[jira] (FLINK-34651) The HiveTableSink of Flink does not support writing to S3

2024-03-19 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34651 ] shizhengchao deleted comment on FLINK-34651: -- was (Author: tinny): a > The HiveTableSink of Flink does not support writing to S3 > -

[jira] [Created] (FLINK-34730) "Deployment" Page for Flink CDC Chinese Documentation

2024-03-19 Thread LvYanquan (Jira)
LvYanquan created FLINK-34730: - Summary: "Deployment" Page for Flink CDC Chinese Documentation Key: FLINK-34730 URL: https://issues.apache.org/jira/browse/FLINK-34730 Project: Flink Issue Type: S

[jira] [Created] (FLINK-34731) Remove SpeculativeScheduler and incorporate its features into AdaptiveBatchScheduler

2024-03-19 Thread Junrui Li (Jira)
Junrui Li created FLINK-34731: - Summary: Remove SpeculativeScheduler and incorporate its features into AdaptiveBatchScheduler Key: FLINK-34731 URL: https://issues.apache.org/jira/browse/FLINK-34731 Projec

[jira] [Updated] (FLINK-34730) "Deployment" Page for Flink CDC Chinese Documentation

2024-03-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34730: --- Parent: (was: FLINK-34677) Issue Type: Improvement (was: Sub-task) > "Deployment" Page

[jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese

2024-03-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34730: --- Summary: Translate pages of Flink CDC docs to Chinese (was: "Deployment" Page for Flink CDC Chinese

[jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese

2024-03-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34730: --- Fix Version/s: 3.1.0 > Translate pages of Flink CDC docs to Chinese > --

Re: [PR] [FLINK-34228] Add long UTF serializer/deserializer [flink]

2024-03-19 Thread via GitHub
gyfora merged PR #24191: URL: https://github.com/apache/flink/pull/24191 -- 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.apache

[jira] [Updated] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation

2024-03-19 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34729: -- Parent: (was: FLINK-34677) Issue Type: Improvement (was: Sub-task) > "Core Concept" Pages

[jira] [Updated] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation

2024-03-19 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34729: -- Parent: FLINK-34730 Issue Type: Sub-task (was: Improvement) > "Core Concept" Pages for Flink

[jira] [Closed] (FLINK-34228) Add long UTF serializer/deserializer

2024-03-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-34228. -- Fix Version/s: 1.20.0 Resolution: Fixed merged to master f75935245799471ddf025d2bab0d0d212e7908

[jira] [Created] (FLINK-34732) Add document dead link check for Flink CDC Documentation

2024-03-19 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-34732: --- Summary: Add document dead link check for Flink CDC Documentation Key: FLINK-34732 URL: https://issues.apache.org/jira/browse/FLINK-34732 Project: Flink

[PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]

2024-03-19 Thread via GitHub
liuyongvs opened a new pull request, #24526: URL: https://github.com/apache/flink/pull/24526 - What is the purpose of the change This is an implementation of ARRAY_INTERSECT - Brief change log ARRAY_INTERSECT for Table API and SQL ``` Returns an array of the element

[PR] [FLINK-34732][cdc][ci] Add document dead link check for Flink CDC Documentation [flink-cdc]

2024-03-19 Thread via GitHub
GOODBOY008 opened a new pull request, #3168: URL: https://github.com/apache/flink-cdc/pull/3168 … -- 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: is

Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]

2024-03-19 Thread via GitHub
liuyongvs commented on PR #24526: URL: https://github.com/apache/flink/pull/24526#issuecomment-2006330781 after discussion with @dawidwys here https://github.com/apache/flink/pull/23171#issuecomment-1956501651 -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-34732) Add document dead link check for Flink CDC Documentation

2024-03-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34732: --- Labels: pull-request-available (was: ) > Add document dead link check for Flink CDC Documen

Re: [PR] [FLINK-34503][table] Migrate JoinDeriveNullFilterRule to java. [flink]

2024-03-19 Thread via GitHub
liuyongvs commented on code in PR #24373: URL: https://github.com/apache/flink/pull/24373#discussion_r1500411569 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/JoinDeriveNullFilterRule.java: ## @@ -59,7 +59,7 @@ public class Jo

Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]

2024-03-19 Thread via GitHub
flinkbot commented on PR #24526: URL: https://github.com/apache/flink/pull/24526#issuecomment-2006346388 ## CI report: * 55306725ea542f506a4938e2d437e59687dbec13 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34724][docs] Fix broken web link in document of legacy Flink CDC Sources [flink-cdc]

2024-03-19 Thread via GitHub
PatrickRen merged PR #3167: URL: https://github.com/apache/flink-cdc/pull/3167 -- 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.

[jira] [Commented] (FLINK-34724) Fix broken web link in document of legacy Flink CDC Sources

2024-03-19 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828231#comment-17828231 ] Qingsheng Ren commented on FLINK-34724: --- flink-cdc master: 8098a9ca3e847a8f8ee2f46

[jira] [Resolved] (FLINK-34724) Fix broken web link in document of legacy Flink CDC Sources

2024-03-19 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34724. --- Assignee: Hongshun Wang Resolution: Fixed > Fix broken web link in document of legacy

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-03-19 Thread via GitHub
eskabetxe commented on code in PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1529961727 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/domain/TransactionId.java: ## @@ -0,0 +1,273 @@ +package org.

[jira] [Created] (FLINK-34733) OSS Filesystem throws ClassNotFoundException

2024-03-19 Thread zhuoshaojian (Jira)
zhuoshaojian created FLINK-34733: Summary: OSS Filesystem throws ClassNotFoundException Key: FLINK-34733 URL: https://issues.apache.org/jira/browse/FLINK-34733 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese

2024-03-19 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34730: -- Description: As https://issues.apache.org/jira/browse/FLINK-34677 introduced new structure of Documen

[jira] [Updated] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation

2024-03-19 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34729: -- Description: Translate [Core Concept|https://github.com/apache/flink-cdc/tree/master/docs/content/doc

[jira] [Created] (FLINK-34734) Update the titles for Chinese Documents.

2024-03-19 Thread LvYanquan (Jira)
LvYanquan created FLINK-34734: - Summary: Update the titles for Chinese Documents. Key: FLINK-34734 URL: https://issues.apache.org/jira/browse/FLINK-34734 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-34719) StreamRecordTest#testWithTimestamp fails on Azure

2024-03-19 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Skraba updated FLINK-34719: Fix Version/s: 1.20.0 (was: 1.12.0) > StreamRecordTest#testWithTimestamp fa

Re: [PR] [FLINK-34677][cdc] Synchronize Chinese documentations for Flink CDC [flink-cdc]

2024-03-19 Thread via GitHub
gtk96 commented on code in PR #3169: URL: https://github.com/apache/flink-cdc/pull/3169#discussion_r1529992363 ## docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md: ## @@ -26,7 +26,7 @@ under the License. # Streaming ELT from MySQL to Doris -This tutorial is to

[PR] [FLINK-34725][dist] Fix wrong config file dir when `config-parser-utils.sh` script attempt to retrieve the Java Home. [flink]

2024-03-19 Thread via GitHub
JunRuiLee opened a new pull request, #24527: URL: https://github.com/apache/flink/pull/24527 ## What is the purpose of the change Fix wrong config file dir when `config-parser-utils.sh` script attempt to retrieve the Java Home specified by the user in config file.

[jira] [Updated] (FLINK-34725) Dockerfiles for release publishing has incorrect config.yaml path

2024-03-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34725: --- Labels: pull-request-available (was: ) > Dockerfiles for release publishing has incorrect c

[PR] Update metric_reporters.md [flink]

2024-03-19 Thread via GitHub
Jathin21 opened a new pull request, #24528: URL: https://github.com/apache/flink/pull/24528 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

Re: [PR] Update metric_reporters.md [flink]

2024-03-19 Thread via GitHub
Jathin21 closed pull request #24528: Update metric_reporters.md URL: https://github.com/apache/flink/pull/24528 -- 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,

Re: [PR] Update metric_reporters.md [flink]

2024-03-19 Thread via GitHub
Jathin21 commented on PR #24528: URL: https://github.com/apache/flink/pull/24528#issuecomment-2006450994 metrics config update -- 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] [Updated] (FLINK-34734) Translate directory and page titles of Flink CDC docs to Chinese

2024-03-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34734: --- Summary: Translate directory and page titles of Flink CDC docs to Chinese (was: Update the titles f

[jira] [Commented] (FLINK-34734) Translate directory and page titles of Flink CDC docs to Chinese

2024-03-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828239#comment-17828239 ] Leonard Xu commented on FLINK-34734: Thanks [~kunni]for open this task, would you li

[jira] [Comment Edited] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService

2024-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828221#comment-17828221 ] Matthias Pohl edited comment on FLINK-34672 at 3/19/24 9:19 AM: --

[PR] [FLINK-34733] [filesystem] Fix oss filesystem ClassNotFoundException when configure 'fs.oss.credentials.provider'. [flink]

2024-03-19 Thread via GitHub
kocomic opened a new pull request, #24529: URL: https://github.com/apache/flink/pull/24529 ## What is the purpose of the change Fixing the exception in Alibaba Cloud OSS file system. ## Brief change log - *Remove the oss filesystem hard-coded shaded prefix of

[jira] [Comment Edited] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService

2024-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828221#comment-17828221 ] Matthias Pohl edited comment on FLINK-34672 at 3/19/24 9:20 AM: --

[jira] [Updated] (FLINK-34733) OSS Filesystem throws ClassNotFoundException

2024-03-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34733: --- Labels: pull-request-available (was: ) > OSS Filesystem throws ClassNotFoundException > ---

Re: [PR] [FLINK-34725][dist] Fix wrong config file dir when `config-parser-utils.sh` script attempt to retrieve the Java Home. [flink]

2024-03-19 Thread via GitHub
flinkbot commented on PR #24527: URL: https://github.com/apache/flink/pull/24527#issuecomment-2006463199 ## CI report: * a6b242c55dc132cd578eb900af510e76dc765b32 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] Update metric_reporters.md [flink]

2024-03-19 Thread via GitHub
flinkbot commented on PR #24528: URL: https://github.com/apache/flink/pull/24528#issuecomment-2006463703 ## CI report: * 0ee551089ad1365592a667816abc741f8f102c07 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34733] [filesystem] Fix oss filesystem ClassNotFoundException when configure 'fs.oss.credentials.provider'. [flink]

2024-03-19 Thread via GitHub
kocomic opened a new pull request, #24530: URL: https://github.com/apache/flink/pull/24530 ## What is the purpose of the change Fixing the exception in Alibaba Cloud OSS file system. ## Brief change log - *Remove the oss filesystem hard-coded shaded prefix of

Re: [PR] [FLINK-34733] [filesystem] Fix oss filesystem ClassNotFoundException when configure 'fs.oss.credentials.provider'. [flink]

2024-03-19 Thread via GitHub
flinkbot commented on PR #24529: URL: https://github.com/apache/flink/pull/24529#issuecomment-2006485049 ## CI report: * d83f7398d5084f6e0dce3d3452bd0543042a0596 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34733] [filesystem] Fix oss filesystem ClassNotFoundException when configure 'fs.oss.credentials.provider'. [flink]

2024-03-19 Thread via GitHub
kocomic opened a new pull request, #24531: URL: https://github.com/apache/flink/pull/24531 ## What is the purpose of the change Fixing the exception in Alibaba Cloud OSS file system. ## Brief change log - *Remove the oss filesystem hard-coded shaded prefix of

[jira] [Comment Edited] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService

2024-03-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828221#comment-17828221 ] Matthias Pohl edited comment on FLINK-34672 at 3/19/24 9:28 AM: --

[PR] [FLINK-34733] [filesystem] Fix oss filesystem ClassNotFoundException when configure 'fs.oss.credentials.provider'. [flink]

2024-03-19 Thread via GitHub
kocomic opened a new pull request, #24532: URL: https://github.com/apache/flink/pull/24532 ## What is the purpose of the change Fixing the exception in Alibaba Cloud OSS file system. ## Brief change log - *Remove the oss filesystem hard-coded shaded prefix of

Re: [PR] Update metric_reporters.md [flink]

2024-03-19 Thread via GitHub
Jathin21 closed pull request #24528: Update metric_reporters.md URL: https://github.com/apache/flink/pull/24528 -- 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,

[jira] [Commented] (FLINK-34734) Translate directory and page titles of Flink CDC docs to Chinese

2024-03-19 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828242#comment-17828242 ] LvYanquan commented on FLINK-34734: --- [~leonard]  Sure, I would like to do it. > Trans

Re: [PR] [FLINK-34677][cdc] Synchronize Chinese documentations for Flink CDC [flink-cdc]

2024-03-19 Thread via GitHub
PatrickRen commented on code in PR #3169: URL: https://github.com/apache/flink-cdc/pull/3169#discussion_r1530015148 ## docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md: ## @@ -26,7 +26,7 @@ under the License. # Streaming ELT from MySQL to Doris -This tutorial i

Re: [PR] [FLINK-34677][cdc] Synchronize Chinese documentations for Flink CDC [flink-cdc]

2024-03-19 Thread via GitHub
leonardBang commented on code in PR #3169: URL: https://github.com/apache/flink-cdc/pull/3169#discussion_r1530015268 ## docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md: ## @@ -26,7 +26,7 @@ under the License. # Streaming ELT from MySQL to Doris -This tutorial

Re: [PR] [FLINK-34733] [filesystem] Fix oss filesystem ClassNotFoundException when configure 'fs.oss.credentials.provider'. [flink]

2024-03-19 Thread via GitHub
flinkbot commented on PR #24530: URL: https://github.com/apache/flink/pull/24530#issuecomment-2006507063 ## CI report: * bb4009a79e36953d3f9fe8c10c06f70af724ef48 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34677][cdc] Synchronize Chinese documentations for Flink CDC [flink-cdc]

2024-03-19 Thread via GitHub
leonardBang commented on code in PR #3169: URL: https://github.com/apache/flink-cdc/pull/3169#discussion_r1530017327 ## docs/content.zh/docs/developer-guide/licenses.md: ## @@ -24,15 +24,15 @@ specific language governing permissions and limitations under the License. --> Revi

Re: [PR] [FLINK-34733] [filesystem] Fix oss filesystem ClassNotFoundException when configure 'fs.oss.credentials.provider'. [flink]

2024-03-19 Thread via GitHub
flinkbot commented on PR #24531: URL: https://github.com/apache/flink/pull/24531#issuecomment-2006507523 ## CI report: * cfff927567063c0768b435e0f850890ba3ea35db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34733] [filesystem] Fix oss filesystem ClassNotFoundException when configure 'fs.oss.credentials.provider'. [flink]

2024-03-19 Thread via GitHub
flinkbot commented on PR #24532: URL: https://github.com/apache/flink/pull/24532#issuecomment-2006507968 ## CI report: * 760d02ba02139dc2b6c5fc3d19e85cda4ee713ae UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

  1   2   3   >