[jira] [Resolved] (FLINK-36668) Release flink-connector-aws v5.0.0

2024-11-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-36668. - Resolution: Fixed  merged commit [{{6cad12a}}|https://github.com/apache/flink/commit/6c

[jira] [Assigned] (FLINK-36668) Release flink-connector-aws v5.0.0

2024-11-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-36668: --- Assignee: Hong Liang Teoh > Release flink-connector-aws v5.0.0 > --

Re: [PR] [FLINK-36047] Add CompiledPlan annotations to BatchExecOverAggregate [flink]

2024-11-11 Thread via GitHub
snuyanzin commented on code in PR #25635: URL: https://github.com/apache/flink/pull/25635#discussion_r1837235503 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/batch/OverAggregateBatchRestoreTest.java: ## @@ -0,0 +1,45 @@ +/* + *

Re: [PR] [FLINK-36492][TABLE API] Remove all deprecated methods in ListView [flink]

2024-11-11 Thread via GitHub
SamBarker commented on code in PR #25565: URL: https://github.com/apache/flink/pull/25565#discussion_r1837239642 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/dataview/ListView.java: ## @@ -186,22 +182,4 @@ public static DataType newListViewDataType(

Re: [PR] [FLINK-36493][TABLE API] Remove all deprecated methods in MapView [flink]

2024-11-11 Thread via GitHub
SamBarker commented on code in PR #25566: URL: https://github.com/apache/flink/pull/25566#discussion_r1837241184 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/dataview/MapView.java: ## @@ -88,11 +85,7 @@ * } * * } - * - * @param key type - * @

[PR] add operatorPod.webhook.container.env to allow customizating of flink-webhook container envs [flink-kubernetes-operator]

2024-11-11 Thread via GitHub
suez1224 opened a new pull request, #914: URL: https://github.com/apache/flink-kubernetes-operator/pull/914 ## What is the purpose of the change *(For example: This pull request adds a new feature to periodically create and maintain savepoints through the `FlinkDeployment` cus

Re: [PR] [FLINK-36047] Add CompiledPlan annotations to BatchExecOverAggregate [flink]

2024-11-11 Thread via GitHub
jnh5y commented on code in PR #25635: URL: https://github.com/apache/flink/pull/25635#discussion_r1837260891 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/batch/OverAggregateBatchRestoreTest.java: ## @@ -0,0 +1,45 @@ +/* + * Lice

[jira] [Commented] (FLINK-36686) allow customizing env variables for flink-webhook container

2024-11-11 Thread Shuyi Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897288#comment-17897288 ] Shuyi Chen commented on FLINK-36686: Created PR [https://github.com/apache/flink-kub

[jira] [Comment Edited] (FLINK-36686) allow customizing env variables for flink-webhook container

2024-11-11 Thread Shuyi Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897288#comment-17897288 ] Shuyi Chen edited comment on FLINK-36686 at 11/11/24 10:37 PM: ---

[jira] [Comment Edited] (FLINK-36686) allow customizing env variables for flink-webhook container

2024-11-11 Thread Shuyi Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897288#comment-17897288 ] Shuyi Chen edited comment on FLINK-36686 at 11/11/24 10:38 PM: ---

Re: [PR] [FLINK-36668][docs] Update AWS docs for v5.0 [flink]

2024-11-11 Thread via GitHub
hlteoh37 merged PR #25641: URL: https://github.com/apache/flink/pull/25641 -- 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

[jira] [Commented] (FLINK-36668) Release flink-connector-aws v5.0.0

2024-11-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897191#comment-17897191 ] Hong Liang Teoh commented on FLINK-36668: -  merged commit [{{54994fc}}|https://

[jira] [Commented] (FLINK-36668) Release flink-connector-aws v5.0.0

2024-11-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897190#comment-17897190 ] Hong Liang Teoh commented on FLINK-36668: -  merged commit [{{9d1e744}}|https://

Re: [PR] Update AWS docs for v5.0 [flink]

2024-11-11 Thread via GitHub
hlteoh37 merged PR #25640: URL: https://github.com/apache/flink/pull/25640 -- 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

Re: [PR] [FLINK-36668][build] Update AWS build for v5.0 [flink-connector-aws]

2024-11-11 Thread via GitHub
hlteoh37 merged PR #181: URL: https://github.com/apache/flink-connector-aws/pull/181 -- 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...@

Re: [PR] [FLINK-36668][docs] Update AWS docs for v5.0 [flink]

2024-11-11 Thread via GitHub
hlteoh37 merged PR #25615: URL: https://github.com/apache/flink/pull/25615 -- 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

[jira] [Commented] (FLINK-36668) Release flink-connector-aws v5.0.0

2024-11-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897189#comment-17897189 ] Hong Liang Teoh commented on FLINK-36668: -  merged commit [{{b55dec1}}|https://

[jira] [Updated] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.

2024-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35067: --- Labels: pull-request-available (was: ) > Support metadata 'op_type' virtual column for Pos

[jira] [Commented] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP

2024-11-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897323#comment-17897323 ] Weijie Guo commented on FLINK-36613: https://dev.azure.com/apache-flink/apache-flink

Re: [PR] [FLINK-36682][mysql][mongodb] Add scan.chunk.assign.strategy to avoid OOM exception. [flink-cdc]

2024-11-11 Thread via GitHub
lvyanquan commented on code in PR #3704: URL: https://github.com/apache/flink-cdc/pull/3704#discussion_r1837379995 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceOptions.java:

Re: [PR] [FLINK-36498] [table] Remove deprecated method ResolvedCatalogBaseTablele#getSchema [flink]

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

[jira] [Comment Edited] (FLINK-36474) YAML Table-merging route should accept more type widening cases

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895937#comment-17895937 ] Leonard Xu edited comment on FLINK-36474 at 11/11/24 11:18 AM: ---

[jira] [Updated] (FLINK-36545) generate-olm-bundle.sh switches uid/gid when running the OLM tool image

2024-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36545: --- Labels: pull-request-available (was: ) > generate-olm-bundle.sh switches uid/gid when runni

Re: [PR] [FLINK-36598][state/ForSt] Provide FileSystem instance in initialization [flink]

2024-11-11 Thread via GitHub
Zakelly commented on PR #25638: URL: https://github.com/apache/flink/pull/25638#issuecomment-2467948590 @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.

[PR] FLINK-36545: [OLM] fix uid/gid mixup when generating the OLM bundle. [flink-kubernetes-operator]

2024-11-11 Thread via GitHub
k-wall opened a new pull request, #913: URL: https://github.com/apache/flink-kubernetes-operator/pull/913 The docker container was being run with the uid/gid arguments switched about. ## What is the purpose of the change As pointed out by https://issues.apache.org/jira/b

[jira] [Comment Edited] (FLINK-36214) Error log when building flink-cdc-pipeline-udf-examples from source code

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892072#comment-17892072 ] Leonard Xu edited comment on FLINK-36214 at 11/11/24 11:31 AM: ---

[PR] Update AWS docs for v5.0 [flink]

2024-11-11 Thread via GitHub
hlteoh37 opened a new pull request, #25640: URL: https://github.com/apache/flink/pull/25640 ## What is the purpose of the change Update AWS docs for v5.0 ## Brief change log Update AWS docs for v5.0 ## Verifying this change This change is a trivial rework / code

Re: [PR] [BP-3.2][FLINK-36474] Support merging timestamp columns when routing [flink-cdc]

2024-11-11 Thread via GitHub
leonardBang merged PR #3693: URL: https://github.com/apache/flink-cdc/pull/3693 -- 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

[PR] [FLINK-36668][docs] Update AWS docs for v5.0 [flink]

2024-11-11 Thread via GitHub
hlteoh37 opened a new pull request, #25641: URL: https://github.com/apache/flink/pull/25641 ## What is the purpose of the change Update AWS docs for v5.0 ## Brief change log Update AWS docs for v5.0 ## Verifying this change This change is a trivial rework / code cle

Re: [PR] [FLINK-36517][cdc-connect][paimon] use filterAndCommit API for Avoid commit the same datafile duplicate [flink-cdc]

2024-11-11 Thread via GitHub
leonardBang merged PR #3639: URL: https://github.com/apache/flink-cdc/pull/3639 -- 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] [Updated] (FLINK-36517) Duplicate commit the same datafile in Paimon Sink

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36517: --- Fix Version/s: cdc-3.3.0 > Duplicate commit the same datafile in Paimon Sink > -

[jira] [Updated] (FLINK-36517) Duplicate commit the same datafile in Paimon Sink

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36517: --- Fix Version/s: cdc-3.2.1 > Duplicate commit the same datafile in Paimon Sink > -

[jira] [Assigned] (FLINK-36517) Duplicate commit the same datafile in Paimon Sink

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36517: -- Assignee: JunboWang > Duplicate commit the same datafile in Paimon Sink > ---

Re: [PR] [FLINK-36517][cdc-connect][paimon] use filterAndCommit API for Avoid commit the same datafile duplicate [flink-cdc]

2024-11-11 Thread via GitHub
leonardBang commented on PR #3639: URL: https://github.com/apache/flink-cdc/pull/3639#issuecomment-2468003278 @beryllw Would you like to backport this fix to release-3.2 branch? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-36517) Duplicate commit the same datafile in Paimon Sink

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897170#comment-17897170 ] Leonard Xu commented on FLINK-36517: master: ff77a490bd88d86952d47607f44a07163f5d8ce

Re: [PR] Update AWS docs for v5.0 [flink]

2024-11-11 Thread via GitHub
flinkbot commented on PR #25640: URL: https://github.com/apache/flink/pull/25640#issuecomment-2468003517 ## CI report: * 1065f7eed7613996db99b0bd1e0d5a6e28030c10 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36668][docs] Update AWS docs for v5.0 [flink]

2024-11-11 Thread via GitHub
flinkbot commented on PR #25641: URL: https://github.com/apache/flink/pull/25641#issuecomment-2468003927 ## CI report: * 3fbb73b9949c82cd8d228fb7ad9021a0ec9d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-36689) [UI] Upgrade runtime web Angular framework and associated deps to v15

2024-11-11 Thread Jason TANG (Jira)
Jason TANG created FLINK-36689: -- Summary: [UI] Upgrade runtime web Angular framework and associated deps to v15 Key: FLINK-36689 URL: https://issues.apache.org/jira/browse/FLINK-36689 Project: Flink

[jira] [Commented] (FLINK-36375) Missing default value in AddColumnEvent/RenameColumnEvent

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897137#comment-17897137 ] Leonard Xu commented on FLINK-36375: master: 8647fe4986a6f4de82021c1e1646f1bc5886bfb

Re: [PR] [FLINK-36375][cdc-runtime] fix missing default value in AddColumnEvent/RenameColunEvent [flink-cdc]

2024-11-11 Thread via GitHub
leonardBang merged PR #3622: URL: https://github.com/apache/flink-cdc/pull/3622 -- 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] [Assigned] (FLINK-36375) Missing default value in AddColumnEvent/RenameColumnEvent

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36375: -- Assignee: linqigeng > Missing default value in AddColumnEvent/RenameColumnEvent > ---

[jira] [Updated] (FLINK-36375) Missing default value in AddColumnEvent/RenameColumnEvent

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36375: --- Fix Version/s: cdc-3.3.0 cdc-3.2.1 > Missing default value in AddColumnEvent/Rena

[jira] [Updated] (FLINK-36689) [UI] Upgrade runtime web Angular framework and associated deps to latest version

2024-11-11 Thread Jason TANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason TANG updated FLINK-36689: --- Summary: [UI] Upgrade runtime web Angular framework and associated deps to latest version (was: [UI

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-11-11 Thread via GitHub
AHeise commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1836204570 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetIdentifierProvider.java: ## @@ -0,0 +1,15 @@ +package org.apache

[jira] [Updated] (FLINK-36689) [UI] Upgrade runtime web Angular framework and associated deps to latest version

2024-11-11 Thread Jason TANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason TANG updated FLINK-36689: --- Description: Angular framework and NG-ZORRO both have released their stable v18 versions. It is a g

Re: [PR] [FLINK-36093][transform] fix preTransformoperator wrongly filters columns when multiple transform [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on code in PR #3572: URL: https://github.com/apache/flink-cdc/pull/3572#discussion_r1836206210 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java: ## @@ -342,27 +342,77 @@ private CreateTableEvent tra

Re: [PR] [FLINK-36093][transform] fix preTransformoperator wrongly filters columns when multiple transform [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on code in PR #3572: URL: https://github.com/apache/flink-cdc/pull/3572#discussion_r1836206210 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java: ## @@ -342,27 +342,77 @@ private CreateTableEvent tra

[jira] [Closed] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

2024-11-11 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu closed FLINK-36687. - Resolution: Resolved > Improve Doris Pipeline Connector Version to 24.0.1 >

[jira] [Commented] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

2024-11-11 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897140#comment-17897140 ] Di Wu commented on FLINK-36687: --- This has been resolved here https://github.com/apache/fli

Re: [PR] [FLINK-36093][transform] fix preTransformoperator wrongly filters columns when multiple transform [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on code in PR #3572: URL: https://github.com/apache/flink-cdc/pull/3572#discussion_r1836254296 ## flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperatorTest.java: ## @@ -526,4 +526,39 @@ void testMetadataTransform

Re: [PR] [FLINK-36093][transform] fix preTransformoperator wrongly filters columns when multiple transform [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on code in PR #3572: URL: https://github.com/apache/flink-cdc/pull/3572#discussion_r1836260088 ## flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperatorTest.java: ## @@ -526,4 +526,39 @@ void testMetadataTransform

[PR] [hotfix][build] Add docs data file for v1.1-SNAPSHOT [flink-connector-prometheus]

2024-11-11 Thread via GitHub
nicusX opened a new pull request, #20: URL: https://github.com/apache/flink-connector-prometheus/pull/20 ## Purpose of the change Add docs data file for v1.1-SNAPSHOT ## Verifying this change This change is a trivial rework / code cleanup without any test coverage.

[PR] [hotfix][build] Add docs data file for v1.0.0 [flink-connector-prometheus]

2024-11-11 Thread via GitHub
nicusX opened a new pull request, #19: URL: https://github.com/apache/flink-connector-prometheus/pull/19 ## Purpose of the change Add docs data file for v1.0.0 ## Verifying this change This change is a trivial rework / code cleanup without any test coverage. ## Sig

Re: [PR] [tests][oceanbase] Fix oceanbase test failure, possibly caused by some interactions among cases [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on PR #3712: URL: https://github.com/apache/flink-cdc/pull/3712#issuecomment-2467634925 Done, please check. -- 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

Re: [PR] [FLINK-36093][transform] fix preTransformoperator wrongly filters columns when multiple transform [flink-cdc]

2024-11-11 Thread via GitHub
MOBIN-F commented on PR #3572: URL: https://github.com/apache/flink-cdc/pull/3572#issuecomment-2467581975 I previously ignored the scenario where projection was missing. I fixed it and added integrated / E2e tests , Can you review it again? @yuxiqian In my CI Aaction,the tests passed

[jira] [Created] (FLINK-36688) table.optimizer.reuse-source-enabled may cause disordered metadata columns when reading from Kafka.

2024-11-11 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-36688: -- Summary: table.optimizer.reuse-source-enabled may cause disordered metadata columns when reading from Kafka. Key: FLINK-36688 URL: https://issues.apache.org/jira/browse/FLINK-36688

[PR] [hotfix][build] Add docs data file for 1.0.0 [flink-connector-prometheus]

2024-11-11 Thread via GitHub
nicusX opened a new pull request, #18: URL: https://github.com/apache/flink-connector-prometheus/pull/18 ## Purpose of the change Add docs data file for v1.0.0 ## Verifying this change This change is a trivial rework / code cleanup without any test coverage. ## Sig

Re: [PR] [hotfix][build] Add docs data file for 1.0.0 [flink-connector-prometheus]

2024-11-11 Thread via GitHub
nicusX closed pull request #18: [hotfix][build] Add docs data file for 1.0.0 URL: https://github.com/apache/flink-connector-prometheus/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 spec

Re: [PR] Adding AWS Connectors v5.0.0 [flink-web]

2024-11-11 Thread via GitHub
hlteoh37 commented on code in PR #760: URL: https://github.com/apache/flink-web/pull/760#discussion_r1836506270 ## docs/data/release_archive.yml: ## @@ -641,6 +641,11 @@ release_archive: version: 3.3.0 release_date: "2024-10-17" filename: "kafka" +- name

Re: [PR] Adding AWS Connectors v5.0.0 [flink-web]

2024-11-11 Thread via GitHub
hlteoh37 merged PR #760: URL: https://github.com/apache/flink-web/pull/760 -- 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

Re: [PR] [BP-3.2][FLINK-36214] Downgrade scala-maven-plugin version to 4.8.0 to keep compatibility with Java 8 [flink-cdc]

2024-11-11 Thread via GitHub
leonardBang merged PR #3662: URL: https://github.com/apache/flink-cdc/pull/3662 -- 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

Re: [PR] [FLINK-36517][cdc-connect][paimon] use filterAndCommit API for Avoid commit the same datafile duplicate [flink-cdc]

2024-11-11 Thread via GitHub
beryllw commented on PR #3639: URL: https://github.com/apache/flink-cdc/pull/3639#issuecomment-2468035197 OK. -- 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

[PR] [FLINK-36668][build] Update AWS build for v5.0 [flink-connector-aws]

2024-11-11 Thread via GitHub
hlteoh37 opened a new pull request, #181: URL: https://github.com/apache/flink-connector-aws/pull/181 ## Purpose of the change Bump version to `5.1-SNAPSHOT` ## Verifying this change This change is a trivial rework / code cleanup without any test coverage. ## Signi

Re: [PR] [FLINK-36578][mysql][BUG] Add table information of binlog offsets when checkpointing added modified JsonStringFormatter [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on code in PR #3658: URL: https://github.com/apache/flink-cdc/pull/3658#discussion_r1836571642 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonStringFormatter.java:

[jira] [Resolved] (FLINK-36375) Missing default value in AddColumnEvent/RenameColumnEvent

2024-11-11 Thread linqigeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng resolved FLINK-36375. --- Resolution: Fixed > Missing default value in AddColumnEvent/RenameColumnEvent >

[PR] [FLINK-36498] [table] Remove deprecated method ResolvedCatalogBaseTablele#getSchema [flink]

2024-11-11 Thread via GitHub
tinaselenge opened a new pull request, #25639: URL: https://github.com/apache/flink/pull/25639 ## What is the purpose of the change This is a subtask of [[FLINK-36476](https://issues.apache.org/jira/browse/FLINK-36476)](https://issues.apache.org/jira/browse/FLINK-36476) Remov

[jira] [Updated] (FLINK-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema`

2024-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36498: --- Labels: pull-request-available (was: ) > Remove deprecated method `ResolvedCatalogBaseTable

[jira] [Closed] (FLINK-36474) YAML Table-merging route should accept more type widening cases

2024-11-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-36474. -- Resolution: Fixed > YAML Table-merging route should accept more type widening cases >

Re: [PR] [hotfix][build] Add docs data file for v1.1-SNAPSHOT [flink-connector-prometheus]

2024-11-11 Thread via GitHub
hlteoh37 merged PR #20: URL: https://github.com/apache/flink-connector-prometheus/pull/20 -- 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-unsubsc

Re: [PR] [hotfix][build] Add docs data file for v1.0.0 [flink-connector-prometheus]

2024-11-11 Thread via GitHub
hlteoh37 merged PR #19: URL: https://github.com/apache/flink-connector-prometheus/pull/19 -- 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-unsubsc

[PR] [FLINK-36375][cdc-runtime] Fix missed default value in AddColumnEvent/RenameColumnEvent [flink-cdc]

2024-11-11 Thread via GitHub
qg-lin opened a new pull request, #3714: URL: https://github.com/apache/flink-cdc/pull/3714 SchemaOperator receives an AddColumnEvent/RenameColumnEvent inLenient mode , the default value will be lost when sent downstream. JIRA: [https://issues.apache.org/jira/browse/FLINK-36375](https://

Re: [PR] [tests][oceanbase] Fix oceanbase test failure, possibly caused by some interactions among cases [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on PR #3712: URL: https://github.com/apache/flink-cdc/pull/3712#issuecomment-2467496270 Another [typical failure case](https://github.com/apache/flink-cdc/actions/runs/11772977376/job/32789167080) is in `testAllDataTypes`, `waitForSinkSize` never gets enough rows, and kee

Re: [PR] [tests][oceanbase] Fix oceanbase test failure, possibly caused by some interactions among cases [flink-cdc]

2024-11-11 Thread via GitHub
whhe commented on PR #3712: URL: https://github.com/apache/flink-cdc/pull/3712#issuecomment-2467514817 To avoid reading change events generated by another test case, how about using UniqueDatabase? Starting a new container for each test case may significantly increase the testing time.

[jira] [Commented] (FLINK-36397) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics.

2024-11-11 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897115#comment-17897115 ] Di Wu commented on FLINK-36397: --- In snapshotreader, the data from lw to hw will be replaye

Re: [PR] [FLINK-36687][cdc-pipeline-connector/doris] Improve Doris Pipeline Connector Version to 24.0.1 [flink-cdc]

2024-11-11 Thread via GitHub
JNSimba closed pull request #3710: [FLINK-36687][cdc-pipeline-connector/doris] Improve Doris Pipeline Connector Version to 24.0.1 URL: https://github.com/apache/flink-cdc/pull/3710 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-36646] Test different versions of the JDK in the Flink image [flink-kubernetes-operator]

2024-11-11 Thread via GitHub
SamBarker commented on PR #910: URL: https://github.com/apache/flink-kubernetes-operator/pull/910#issuecomment-2467565502 E2E test failed as expected: https://github.com/apache/flink-kubernetes-operator/actions/runs/11696768142/job/32793460638?pr=910#step:9:4256 -- This is an automated

Re: [PR] [FLINK-36315][cdc-base]The flink-cdc-base module supports source metric statistics [flink-cdc]

2024-11-11 Thread via GitHub
liuxiao2shf commented on code in PR #3619: URL: https://github.com/apache/flink-cdc/pull/3619#discussion_r1836096807 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/MySqlSourceMetricsTest.java: ## @@ -0,0 +1,350

Re: [PR] [FLINK-36315][cdc-base]The flink-cdc-base module supports source metric statistics [flink-cdc]

2024-11-11 Thread via GitHub
liuxiao2shf commented on code in PR #3619: URL: https://github.com/apache/flink-cdc/pull/3619#discussion_r1836096199 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/experimental/fetch/MySqlSourceFetchTaskContext.java: ##

[jira] [Assigned] (FLINK-36686) allow customizing env variables for flink-webhook container

2024-11-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-36686: -- Assignee: Shuyi Chen > allow customizing env variables for flink-webhook container >

[jira] [Commented] (FLINK-36686) allow customizing env variables for flink-webhook container

2024-11-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897101#comment-17897101 ] Gyula Fora commented on FLINK-36686: Makes sense! > allow customizing env variables

Re: [PR] [backport][FLINK-36332] Fix okhttp dependency handling [flink-kubernetes-operator]

2024-11-11 Thread via GitHub
gyfora merged PR #909: URL: https://github.com/apache/flink-kubernetes-operator/pull/909 -- 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

[jira] [Commented] (FLINK-36332) Allow the Operator http client to be customised

2024-11-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897102#comment-17897102 ] Gyula Fora commented on FLINK-36332: release-1.10 : 21321b0810895e35896d838f0f0d2f0c

[PR] [tests][oceanbase] Fix oceanbase test failure, possibly caused by some interactions among cases [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian opened a new pull request, #3712: URL: https://github.com/apache/flink-cdc/pull/3712 This fixes a mysterious test failure in OceanBaseMySQLModeITCase like [this](https://github.com/apache/flink-cdc/actions/runs/11720914709/job/32647267237). Recently it is happening quite frequently

Re: [PR] [FLINK-36093][transform] fix preTransformoperator wrongly filters columns when multiple transform [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on code in PR #3572: URL: https://github.com/apache/flink-cdc/pull/3572#discussion_r1836241798 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java: ## @@ -386,37 +436,16 @@ private Schema transformSchem

[jira] [Updated] (FLINK-36689) [UI] Upgrade runtime web Angular framework and associated deps to latest version

2024-11-11 Thread Jason TANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason TANG updated FLINK-36689: --- Description: Angular framework and NG-ZORRO both have released their stable v18 versions. It is a g

Re: [PR] [FLINK-36679][runtime] Add a metric to track checkpoint _metadata size [flink]

2024-11-11 Thread via GitHub
liuml07 commented on PR #25634: URL: https://github.com/apache/flink/pull/25634#issuecomment-2468823024 The failing test `RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState` seems to be unreliable. I see it's failing in multiple recent builds of other PRs. -- This is an

[jira] [Updated] (FLINK-36679) Add a metric to track checkpoint _metadata size

2024-11-11 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-36679: -- Description: Currently we expose multiple metrics for the checkpoint size. One specific inter

[jira] [Updated] (FLINK-36685) Enable update/create operation on flinkdeployment resource in mutation webhook

2024-11-11 Thread Shuyi Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-36685: --- Priority: Blocker (was: Minor) > Enable update/create operation on flinkdeployment resource in muta

Re: [PR] [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions [flink]

2024-11-11 Thread via GitHub
shmyer closed pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions URL: https://github.com/apache/flink/pull/14084 -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Commented] (FLINK-36685) Enable update/create operation on flinkdeployment resource in mutation webhook

2024-11-11 Thread Shuyi Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897251#comment-17897251 ] Shuyi Chen commented on FLINK-36685: Thanks [~gyfora]. We used mutation webhook to i

[jira] [Commented] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema`

2024-11-11 Thread Gantigmaa Selenge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897204#comment-17897204 ] Gantigmaa Selenge commented on FLINK-36495: --- Removing getSchema() results in s

[jira] [Comment Edited] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema`

2024-11-11 Thread Gantigmaa Selenge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897204#comment-17897204 ] Gantigmaa Selenge edited comment on FLINK-36495 at 11/11/24 4:45 PM: -

Re: [PR] [FLINK-36678][docs][deploy] Fixed the documentation error of Flink CDC YARN deployment mode [flink-cdc]

2024-11-11 Thread via GitHub
Timi988 commented on PR #3706: URL: https://github.com/apache/flink-cdc/pull/3706#issuecomment-2469756372 > @Timi988 Would you like to open a PR for release-3.2 branch? Okay -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

Re: [PR] [FLINK-36565] Route module allows merging Decimals with various precisions [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on code in PR #3651: URL: https://github.com/apache/flink-cdc/pull/3651#discussion_r1837584244 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java: ## @@ -611,14 +614,42 @@ public Object getFieldOrNull(RecordDat

Re: [PR] [FLINK-36565] Route module allows merging Decimals with various precisions [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on code in PR #3651: URL: https://github.com/apache/flink-cdc/pull/3651#discussion_r1837584244 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java: ## @@ -611,14 +614,42 @@ public Object getFieldOrNull(RecordDat

Re: [PR] [FLINK-36565] Route module allows merging Decimals with various precisions [flink-cdc]

2024-11-11 Thread via GitHub
yuxiqian commented on code in PR #3651: URL: https://github.com/apache/flink-cdc/pull/3651#discussion_r1837584244 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java: ## @@ -611,14 +614,42 @@ public Object getFieldOrNull(RecordDat

[jira] [Assigned] (FLINK-36693) Implement checkpoint for ForStSyncKeyedStateBackend

2024-11-11 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-36693: -- Assignee: Yanfei Lei > Implement checkpoint for ForStSyncKeyedStateBackend >

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-11-11 Thread via GitHub
pawel-big-lebowski commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1837597500 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java: ## @@ -0,0 +1,118 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-36685) Enable update/create operation on flinkdeployment resource in mutation webhook

2024-11-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897383#comment-17897383 ] Gyula Fora commented on FLINK-36685: Makes sense to have it the same for deployments

[jira] [Updated] (FLINK-27014) Fix exception when select null literal in subquery for Hive dialect

2024-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27014: --- Labels: pull-request-available (was: ) > Fix exception when select null literal in subquery

  1   2   >