Re: [PR] [FLINK-36355][runtime] Remove deprecated xxxStreams#with [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25395: URL: https://github.com/apache/flink/pull/25395#issuecomment-2373170967 ## CI report: * 22acfa8478faca1e8df753a69ae7f1aa852c23e2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35874][cdc-connector][mysql] Obtain the high watermark offset and table data in the same transaction during the Snapshot phase [flink-cdc]

2024-09-24 Thread via GitHub
qiaozongmi commented on PR #3616: URL: https://github.com/apache/flink-cdc/pull/3616#issuecomment-2373163513 @leonardBang PTAL -- 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 commen

[PR] [FLINK-36355][runtime] Remove deprecated xxxStreams#with [flink]

2024-09-24 Thread via GitHub
yunfengzhou-hub opened a new pull request, #25395: URL: https://github.com/apache/flink/pull/25395 ## What is the purpose of the change Remove deprecated xxxStreams#with ## Verifying this change This change is a trivial rework / code cleanup without any test coverage.

[jira] [Created] (FLINK-36365) The fetchsize parameter of flink-sql-connector-mysql-cdc-3.2.0 does not take effect

2024-09-24 Thread zhanghuaibei (Jira)
zhanghuaibei created FLINK-36365: Summary: The fetchsize parameter of flink-sql-connector-mysql-cdc-3.2.0 does not take effect Key: FLINK-36365 URL: https://issues.apache.org/jira/browse/FLINK-36365 P

Re: [PR] [FLINK-36364][state/forst] Do not reuse serialized key in Forst map state and/or other namespaces [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25394: URL: https://github.com/apache/flink/pull/25394#issuecomment-2373137746 ## CI report: * 51a0c286b3e207436c35c266e2e6d9d89de255e2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34975][state/forst] Support multiget for forstdb [flink]

2024-09-24 Thread via GitHub
Zakelly commented on code in PR #25363: URL: https://github.com/apache/flink/pull/25363#discussion_r1774571210 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java: ## @@ -33,39 +37,169 @@ public class Fo

[jira] [Updated] (FLINK-36364) Do not reuse serialized key in Forst map state and/or other namespaces

2024-09-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36364: --- Labels: pull-request-available (was: ) > Do not reuse serialized key in Forst map state and

[PR] [FLINK-36364][state/forst] Do not reuse serialized key in Forst map state and/or other namespaces [flink]

2024-09-24 Thread via GitHub
Zakelly opened a new pull request, #25394: URL: https://github.com/apache/flink/pull/25394 ## What is the purpose of the change Currently, the forst reuse serialized key in any state with any namespaces, which is problematic in parallel state execution. This PR fixes this by limit th

Re: [PR] [FLINK-34975][state/forst] Support multiget for forstdb [flink]

2024-09-24 Thread via GitHub
fredia commented on code in PR #25363: URL: https://github.com/apache/flink/pull/25363#discussion_r1774562437 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java: ## @@ -33,39 +37,169 @@ public class For

[jira] [Created] (FLINK-36364) Do not reuse serialized key in Forst map state and/or other namespaces

2024-09-24 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-36364: --- Summary: Do not reuse serialized key in Forst map state and/or other namespaces Key: FLINK-36364 URL: https://issues.apache.org/jira/browse/FLINK-36364 Project: Flink

[jira] [Assigned] (FLINK-36331) Support multiGet when DB all in local

2024-09-24 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-36331: --- Assignee: Yanfei Lei > Support multiGet when DB all in local >

[jira] [Created] (FLINK-36363) Remove references to scala-relate api in tests among table modules

2024-09-24 Thread xuyang (Jira)
xuyang created FLINK-36363: -- Summary: Remove references to scala-relate api in tests among table modules Key: FLINK-36363 URL: https://issues.apache.org/jira/browse/FLINK-36363 Project: Flink Issue

Re: [PR] [FLINK-34975][state/forst] Support multiget when db all in local [flink]

2024-09-24 Thread via GitHub
Zakelly commented on code in PR #25363: URL: https://github.com/apache/flink/pull/25363#discussion_r1774522528 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java: ## @@ -33,39 +37,169 @@ public class Fo

Re: [PR] [FLINK-36361][table] Do not use StringBuilder for EquivalentExprShuttle [flink]

2024-09-24 Thread via GitHub
snuyanzin commented on PR #25388: URL: https://github.com/apache/flink/pull/25388#issuecomment-2373050542 @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] [Created] (FLINK-36362) Remove dependency about `flink-java` in table module

2024-09-24 Thread xuyang (Jira)
xuyang created FLINK-36362: -- Summary: Remove dependency about `flink-java` in table module Key: FLINK-36362 URL: https://issues.apache.org/jira/browse/FLINK-36362 Project: Flink Issue Type: Technica

Re: [PR] [DRAFT][FLINK-29741][scala] Remove flink-dist-scala, flink-scala, flink-streaming-scala module [flink]

2024-09-24 Thread via GitHub
codenohup commented on PR #25393: URL: https://github.com/apache/flink/pull/25393#issuecomment-2372993911 @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.

Re: [PR] FLINK-36332 Add option to select the Fabric8 httpclient implemention [flink-kubernetes-operator]

2024-09-24 Thread via GitHub
SamBarker commented on code in PR #881: URL: https://github.com/apache/flink-kubernetes-operator/pull/881#discussion_r1774430683 ## pom.xml: ## @@ -110,6 +110,7 @@ under the License. 10.15.2.0 +24.1.0 Review Comment: @gyfora @csviri Do you have

Re: [PR] FLINK-36332 Add option to select the Fabric8 httpclient implemention [flink-kubernetes-operator]

2024-09-24 Thread via GitHub
SamBarker commented on PR #881: URL: https://github.com/apache/flink-kubernetes-operator/pull/881#issuecomment-2372924564 > Do you have any recommendation how we should test this and make sure it works? Maybe we can add a case to the e2e-s somehow? Hmm thats a good question. It looks

Re: [PR] [DRAFT][FLINK-29741][scala] Remove flink-dist-scala, flink-scala, flink-streaming-scala module [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25393: URL: https://github.com/apache/flink/pull/25393#issuecomment-2372874312 ## CI report: * b7bba79ab00f296ef7657e28ee212a0fccbe0b27 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [DRAFT][FLINK-29741][scala] Remove flink-dist-scala, flink-scala, flink-streaming-scala module [flink]

2024-09-24 Thread via GitHub
codenohup opened a new pull request, #25393: URL: https://github.com/apache/flink/pull/25393 ## 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 t

Re: [PR] [FLINK-36360] Fix version name checks for preview release. [flink-docker]

2024-09-24 Thread via GitHub
xintongsong commented on code in PR #204: URL: https://github.com/apache/flink-docker/pull/204#discussion_r1774370440 ## add-version.sh: ## @@ -53,7 +53,7 @@ if [ -z "$flink_release" ] || [ -z "$flink_version" ]; then exit 1 fi -if [[ ! "$flink_version" =~ ^$flink_releas

[jira] [Resolved] (FLINK-36311) Remove deprecated flink-formats config options

2024-09-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu resolved FLINK-36311. - Resolution: Fixed Merged to master viade40ebe53797a4abe023a437e63d9ba5aa095d40 to 483a94a15aed6661a3332

[jira] [Resolved] (FLINK-36308) Remove deprecated CEP config options

2024-09-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu resolved FLINK-36308. - Resolution: Fixed Merged to master via 42d918dec1658c4dc1f0586148704c46bc1dd8d0 > Remove deprecated CEP

Re: [PR] [FLINK-36311][format/csv/json/avro] Remove deprecated APIs in Flink Csv/Json/Avro format [flink]

2024-09-24 Thread via GitHub
dianfu merged PR #25387: URL: https://github.com/apache/flink/pull/25387 -- 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

Re: [PR] [FLINK-36308][cep] Remove deprecated APIs from CEP module and dropped state compatible support for old versions [flink]

2024-09-24 Thread via GitHub
dianfu merged PR #25381: URL: https://github.com/apache/flink/pull/25381 -- 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

Re: [PR] [FLINK-34555][table] Migrate JoinConditionTypeCoerceRule to java. [flink]

2024-09-24 Thread via GitHub
liuyongvs commented on PR #24420: URL: https://github.com/apache/flink/pull/24420#issuecomment-2372782411 hi @snuyanzin , will you have time to review it again? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [PR] [FLINK-36355][runtime] Remove deprecated iterative stream [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25392: URL: https://github.com/apache/flink/pull/25392#issuecomment-2372772986 ## CI report: * 47c69c30b361bd0d01741f188f00bfe5ff447e85 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36275][rest] Remove deprecated ProgramArgsQueryParameter [flink]

2024-09-24 Thread via GitHub
reswqa commented on PR #25323: URL: https://github.com/apache/flink/pull/25323#issuecomment-2372769400 @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. T

[PR] [FLINK-36355][runtime] Remove deprecated iterative stream [flink]

2024-09-24 Thread via GitHub
yunfengzhou-hub opened a new pull request, #25392: URL: https://github.com/apache/flink/pull/25392 ## What is the purpose of the change Remove deprecated iterative stream ## Verifying this change This change is a trivial rework / code cleanup without any test coverage.

Re: [PR] [FLINK-36355][runtime] Remove deprecated KeydStream#asQueryableState [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25391: URL: https://github.com/apache/flink/pull/25391#issuecomment-2372757918 ## CI report: * 8b8cebfaea291433cc3fcae2c43feaaa96d0bc35 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36355][runtime] Remove miscellaneous deprecated interfaces related to DataStream [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25390: URL: https://github.com/apache/flink/pull/25390#issuecomment-2372754773 ## CI report: * e9ffd655c7ecbe468b288d36ff956c5e166f62ad UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-36355][runtime] Remove deprecated KeydStream#asQueryableState [flink]

2024-09-24 Thread via GitHub
yunfengzhou-hub opened a new pull request, #25391: URL: https://github.com/apache/flink/pull/25391 ## What is the purpose of the change Remove deprecated KeydStream#asQueryableState ## Verifying this change This change is a trivial rework / code cleanup without any test c

[PR] [FLINK-36355][runtime] Remove miscellaneous deprecated interfaces related to DataStream [flink]

2024-09-24 Thread via GitHub
yunfengzhou-hub opened a new pull request, #25390: URL: https://github.com/apache/flink/pull/25390 ## What is the purpose of the change Remove part of the deprecated interfaces related to DataStream ## Verifying this change This change is a trivial rework / code cleanup w

[jira] [Assigned] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

2024-09-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34702: --- Assignee: lincoln lee > Rank should not convert to StreamExecDuplicate when the input is no

[PR] 【update】Add new operator config "savepoint-create-subdir" to allow user to configure whether to create sub-directories named by job id under the 'state.savepoints.dir' [flink-kubernetes-operator]

2024-09-24 Thread via GitHub
xieyang1994 opened a new pull request, #882: URL: https://github.com/apache/flink-kubernetes-operator/pull/882 ## What is the purpose of the change Add new operator config "savepoint-create-subdir" to allow user to configure whether to create sub-directories named by job i

[jira] [Closed] (FLINK-36358) to_timestamp result is not correct when the string precision is long than date format

2024-09-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36358. --- Fixed in master: 74b9a480317b3b2d93bf6953ba8934dedab1375f > to_timestamp result is not correct when the

[jira] [Assigned] (FLINK-36358) to_timestamp result is not correct when the string precision is long than date format

2024-09-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36358: --- Assignee: Jacky Lau > to_timestamp result is not correct when the string precision is long

[jira] [Resolved] (FLINK-36358) to_timestamp result is not correct when the string precision is long than date format

2024-09-24 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacky Lau resolved FLINK-36358. --- Resolution: Fixed > to_timestamp result is not correct when the string precision is long than > dat

[jira] [Updated] (FLINK-36355) Remove deprecate API in flink-runtime exclude connector and state part

2024-09-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36355: --- Labels: pull-request-available (was: ) > Remove deprecate API in flink-runtime exclude conn

Re: [PR] [FLINK-36355][runtime] Remove deprecated interfaces related to window and time [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25389: URL: https://github.com/apache/flink/pull/25389#issuecomment-2372714805 ## CI report: * ebe505f07e27c07923e431747625e6596f3a0d8f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-36355][runtime] Remove deprecated interfaces related to window and time [flink]

2024-09-24 Thread via GitHub
yunfengzhou-hub opened a new pull request, #25389: URL: https://github.com/apache/flink/pull/25389 ## What is the purpose of the change Remove deprecated interfaces related to window and time ## Verifying this change This change is a trivial rework / code cleanup without

[jira] [Closed] (FLINK-36304) Remove deprecated Statebackend config options

2024-09-24 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuannan Su closed FLINK-36304. -- Resolution: Duplicate > Remove deprecated Statebackend config options > --

Re: [PR] [FLINK-36358][table] Fix incorrect timestamp to string behavior. [flink]

2024-09-24 Thread via GitHub
lincoln-lil merged PR #25382: URL: https://github.com/apache/flink/pull/25382 -- 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.a

Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink]

2024-09-24 Thread via GitHub
RocMarshal commented on code in PR #25218: URL: https://github.com/apache/flink/pull/25218#discussion_r1774238831 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAssigner.java: ## @@ -32,4 +48,74 @@ Collection assignSlots( Co

Re: [PR] [hotfix][tests] Separate Pipeline and Source E2e tests [flink-cdc]

2024-09-24 Thread via GitHub
github-actions[bot] commented on PR #3427: URL: https://github.com/apache/flink-cdc/pull/3427#issuecomment-2372600635 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [FLINK-36361][table] Do not use StringBuilder for EquivalentExprShuttle [flink]

2024-09-24 Thread via GitHub
jnh5y commented on code in PR #25388: URL: https://github.com/apache/flink/pull/25388#discussion_r1774214379 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRexUtil.scala: ## @@ -439,17 +439,16 @@ object FlinkRexUtil { })

Re: [PR] [FLINK-36361][table] Do not use StringBuilder for EquivalentExprShuttle [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25388: URL: https://github.com/apache/flink/pull/25388#issuecomment-2372519096 ## CI report: * d2bdb6986b4c962e75a542e66b2f95e06c7f4725 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36361][table] Do not use StringBuilder for EquivalentExprShuttle [flink]

2024-09-24 Thread via GitHub
snuyanzin commented on code in PR #25388: URL: https://github.com/apache/flink/pull/25388#discussion_r1774177868 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRexUtil.scala: ## @@ -439,17 +439,16 @@ object FlinkRexUtil { })

[jira] [Updated] (FLINK-36361) Do not use StringBuilder for EquivalentExprShuttle

2024-09-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36361: --- Labels: pull-request-available (was: ) > Do not use StringBuilder for EquivalentExprShuttle

Re: [PR] [FLINK-36361][table] Do not use StringBuilder for EquivalentExprShuttle [flink]

2024-09-24 Thread via GitHub
snuyanzin commented on code in PR #25388: URL: https://github.com/apache/flink/pull/25388#discussion_r1774176158 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/JoinDependentConditionDerivationRuleTest.xml: ## @@ -98,7 +98,

[PR] [FLINK-36361][table] Do not use StringBuilder for EquivalentExprShuttle [flink]

2024-09-24 Thread via GitHub
snuyanzin opened a new pull request, #25388: URL: https://github.com/apache/flink/pull/25388 ## What is the purpose of the change The idea is to use just set of RelNodes and do not generate toString each time. Also use the fact that Calcite can compare RelNodes

[jira] [Created] (FLINK-36361) Do not use StringBuilder for EquivalentExprShuttle

2024-09-24 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-36361: --- Summary: Do not use StringBuilder for EquivalentExprShuttle Key: FLINK-36361 URL: https://issues.apache.org/jira/browse/FLINK-36361 Project: Flink Issu

[PR] [FLINK-31987][Connectors/AWS] Implement KDS Table API support [flink-connector-aws]

2024-09-24 Thread via GitHub
karubian opened a new pull request, #171: URL: https://github.com/apache/flink-connector-aws/pull/171 ## Purpose of the change Implements the Table API for the Kinesis Source. ## Verifying this change This change added tests and can be verified as follows:

[jira] [Updated] (FLINK-34064) FLIP-417: Expose JobManagerOperatorMetrics via REST API

2024-09-24 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-34064: --- Summary: FLIP-417: Expose JobManagerOperatorMetrics via REST API (was: FLIP-471: Expose Job

Re: [PR] [FLINK-34702][table-planner] Avoid using StreamPhysicalDeduplicate and instead decide to perform exec node transformations in StreamPhysicalRank [flink]

2024-09-24 Thread via GitHub
lincoln-lil commented on code in PR #25380: URL: https://github.com/apache/flink/pull/25380#discussion_r1773643458 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalDeduplicate.scala: ## @@ -30,9 +30,10 @@ i

[jira] [Closed] (FLINK-36327) Remove the dependencies of the flink-scala and flink-streaming-scala modules from the table module.

2024-09-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36327. --- Assignee: xuyang Resolution: Fixed fixed in master: 7a06c3ba00ef0840ad59707cece2b9d3fcbd2409

Re: [PR] [FLINK-36327][table] Remove dependency about flink-scala and flink-streaming-scala in table module [flink]

2024-09-24 Thread via GitHub
lincoln-lil merged PR #25364: URL: https://github.com/apache/flink/pull/25364 -- 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.a

Re: [PR] [FLINK-36319][Connector/Prometheus] Fixed error handling behavior and other minor bugs [flink-connector-prometheus]

2024-09-24 Thread via GitHub
hlteoh37 merged PR #7: URL: https://github.com/apache/flink-connector-prometheus/pull/7 -- 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] [Resolved] (FLINK-36319) FAIL behavior on non-retriable write errors causes an infinite loop when restarting from checkpoint

2024-09-24 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-36319. - Resolution: Fixed  merged commit [{{776a0d2}}|https://github.com/apache/flink-connector

Re: [PR] [FLINK-34702][table-planner] Avoid using StreamPhysicalDeduplicate and instead decide to perform exec node transformations in StreamPhysicalRank [flink]

2024-09-24 Thread via GitHub
jnh5y commented on code in PR #25380: URL: https://github.com/apache/flink/pull/25380#discussion_r1773603139 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalDeduplicate.scala: ## @@ -30,9 +30,10 @@ import

Re: [PR] [FLINK-36360] Fix version name checks for preview release. [flink-docker]

2024-09-24 Thread via GitHub
davidradl commented on code in PR #204: URL: https://github.com/apache/flink-docker/pull/204#discussion_r1773514085 ## add-version.sh: ## @@ -53,7 +53,7 @@ if [ -z "$flink_release" ] || [ -z "$flink_version" ]; then exit 1 fi -if [[ ! "$flink_version" =~ ^$flink_release\

[jira] [Resolved] (FLINK-36274) Remove legacy ExternalizedCheckpointCleanup

2024-09-24 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36274. - Resolution: Fixed > Remove legacy ExternalizedCheckpointCleanup > --

[jira] [Resolved] (FLINK-34511) Flink 2.0: Remove legacy State&Checkpointing&Recovery options

2024-09-24 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-34511. - Fix Version/s: 2.0-preview Resolution: Fixed > Flink 2.0: Remove legacy State&Checkpointi

[jira] [Commented] (FLINK-36274) Remove legacy ExternalizedCheckpointCleanup

2024-09-24 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884289#comment-17884289 ] Zakelly Lan commented on FLINK-36274: - Merge 5d463de1 into master > Remove legacy E

Re: [PR] [FLINK-34511] Remove legacy State&Checkpointing&Recovery options [flink]

2024-09-24 Thread via GitHub
Zakelly merged PR #25346: URL: https://github.com/apache/flink/pull/25346 -- 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.apach

Re: [PR] [FLINK-34511] Remove legacy State&Checkpointing&Recovery options [flink]

2024-09-24 Thread via GitHub
Zakelly commented on PR #25346: URL: https://github.com/apache/flink/pull/25346#issuecomment-2371382886 Thanks for the review! The CI green, merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to g

[jira] [Closed] (FLINK-35765) Support Fine Grained Resource Specifications for Adaptive Scheduler

2024-09-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35765. --- Resolution: Duplicate Thanks [~mapohl] for picking it up. Following it in FLINK-29344 sounds make sense to

Re: [PR] [FLINK-36311][format/csv/json/avro] Remove deprecated APIs in Flink Csv/Json/Avro format [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25387: URL: https://github.com/apache/flink/pull/25387#issuecomment-2371260846 ## CI report: * c635580387d2c2ff6dc74b584feb1f027135a7e9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-36311) Remove deprecated flink-formats config options

2024-09-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36311: --- Labels: pull-request-available (was: ) > Remove deprecated flink-formats config options > -

[PR] [FLINK-36311][format/csv/json/avro] Remove deprecated APIs in Flink Csv/Json/Avro format [flink]

2024-09-24 Thread via GitHub
dianfu opened a new pull request, #25387: URL: https://github.com/apache/flink/pull/25387 ## 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 on

Re: [PR] Debug Flink E2E by azure pipeline [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25386: URL: https://github.com/apache/flink/pull/25386#issuecomment-2371241126 ## CI report: * c17b0445616b2b214deccb4af537949c14f25851 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] Debug Flink E2E by azure pipeline [flink]

2024-09-24 Thread via GitHub
xuyangzhong opened a new pull request, #25386: URL: https://github.com/apache/flink/pull/25386 None -- 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:

[jira] [Assigned] (FLINK-36286) Set up validation workflows

2024-09-24 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-36286: --- Assignee: Hong Liang Teoh > Set up validation workflows > -

[jira] [Updated] (FLINK-36286) Set up validation workflows

2024-09-24 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-36286: Component/s: Connectors / Prometheus > Set up validation workflows > -

[jira] [Resolved] (FLINK-36286) Set up validation workflows

2024-09-24 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-36286. - Resolution: Fixed  merged commit [{{47df621}}|https://github.com/apache/flink-connector

Re: [PR] [FLINK-36286][Connectors/Prometheus] Set up validation workflows [flink-connector-prometheus]

2024-09-24 Thread via GitHub
hlteoh37 merged PR #6: URL: https://github.com/apache/flink-connector-prometheus/pull/6 -- 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-36286][Connectors/Prometheus] Set up validation workflows [flink-connector-prometheus]

2024-09-24 Thread via GitHub
hlteoh37 commented on PR #6: URL: https://github.com/apache/flink-connector-prometheus/pull/6#issuecomment-2371154234 Validated that approval workflows have passed on custom fork ![image](https://github.com/user-attachments/assets/697b1d7a-d9d3-423f-8071-ad532e94f660) -- This

Re: [PR] [FLINK-36360] Introduce scripts for cutting branch for a preview release [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25385: URL: https://github.com/apache/flink/pull/25385#issuecomment-2371102934 ## CI report: * 5b5f789c1a77168de7b7b27fd95a541ad3bf79d4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-36360) Prepare release process and Scripts for the preview release

2024-09-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-36360: - Description: Flink Repo || ||Branch||Version||Tag (if any)|| |Regular|master|2.0-SNAPSHOT| | | |

[PR] [FLINK-36360] Introduce scripts for cutting branch for a preview release [flink]

2024-09-24 Thread via GitHub
xintongsong opened a new pull request, #25385: URL: https://github.com/apache/flink/pull/25385 ## 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 the

Re: [PR] [FLINK-34467] bump flink version to 1.20.0 [flink-connector-jdbc]

2024-09-24 Thread via GitHub
leonardBang commented on PR #137: URL: https://github.com/apache/flink-connector-jdbc/pull/137#issuecomment-2371026949 @lvyanquan Would you like to review this PR when you have time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[jira] [Updated] (FLINK-36360) Prepare release process and Scripts for the preview release

2024-09-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36360: --- Labels: pull-request-available (was: ) > Prepare release process and Scripts for the previe

[PR] [FLINK-36360] Fix version name checks for preview release. [flink-docker]

2024-09-24 Thread via GitHub
xintongsong opened a new pull request, #204: URL: https://github.com/apache/flink-docker/pull/204 (no comment) -- 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 unsubscrib

[jira] [Updated] (FLINK-36306) Remove deprecated API for 2.0-preview

2024-09-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36306: --- Description: ||Module||Contributor||Status|| |flink-sql-connector-hive-3.1.3_2.12|[~xuyangzhong]| |

[jira] [Updated] (FLINK-36306) Remove deprecated API for 2.0-preview

2024-09-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36306: --- Description: ||Module||Contributor||Status|| |flink-sql-connector-hive-3.1.3_2.12|[~xuyangzhong]| |

[jira] [Updated] (FLINK-36306) Remove deprecated API for 2.0-preview

2024-09-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36306: --- Description: ||Module||Contributor||Status|| |flink-sql-connector-hive-3.1.3_2.12|[~xuyangzhong]| |

[jira] [Updated] (FLINK-36306) Remove deprecated API for 2.0-preview

2024-09-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36306: --- Description: ||Module||Contributor||Status| | |flink-sql-connector-hive-3.1.3_2.12|[~xuyangzhong]||

[jira] [Updated] (FLINK-36360) Prepare release process and Scripts for the preview release

2024-09-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-36360: - Description: Flink Repo || ||Branch||Version||Tag (if any)|| |Regular|master|2.0-SNAPSHOT| | |re

[jira] [Updated] (FLINK-36360) Prepare release process and Scripts for the preview release

2024-09-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-36360: - Description: Flink Repo   || ||Branch||Version||Tag (if any)|| |Regular|master|2.0-SNAPSHOT| |

Re: [PR] [FLINK-30614][serializer] Remove old method of resolving schema compa… [flink]

2024-09-24 Thread via GitHub
flinkbot commented on PR #25384: URL: https://github.com/apache/flink/pull/25384#issuecomment-2370964707 ## CI report: * 3040dc7d55ac8379de8b94c469639518d1d6f3b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36269][python] Remove usage about TableEnvironmentInternal#fromTableSource in python module [flink]

2024-09-24 Thread via GitHub
HuangXingBo commented on code in PR #25322: URL: https://github.com/apache/flink/pull/25322#discussion_r1773132895 ## flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ByteArrayUtils.java: ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-30614][serializer] Remove old method of resolving schema compa… [flink]

2024-09-24 Thread via GitHub
AlexYinHan commented on PR #25384: URL: https://github.com/apache/flink/pull/25384#issuecomment-2370948960 @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 commen

[jira] [Updated] (FLINK-30614) Improve resolving schema compatibility -- Milestone two

2024-09-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30614: --- Labels: pull-request-available (was: ) > Improve resolving schema compatibility -- Mileston

[PR] [FLINK-30614][serializer] Remove old method of resolving schema compa… [flink]

2024-09-24 Thread via GitHub
AlexYinHan opened a new pull request, #25384: URL: https://github.com/apache/flink/pull/25384 ## What is the purpose of the change *For Milestone-2 of FLIP-263, this PR removes the old method of resolving schema compatibility.* ## Brief change log - *Re

[jira] [Created] (FLINK-36360) Prepare release process and Scripts for the preview release

2024-09-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-36360: Summary: Prepare release process and Scripts for the preview release Key: FLINK-36360 URL: https://issues.apache.org/jira/browse/FLINK-36360 Project: Flink

[jira] [Closed] (FLINK-36248) Introduce new Join Operator with Async State API

2024-09-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36248. --- Resolution: Fixed Fixed in master: 5a63c56ca0b38ebae9fc475708917c35a4168844 > Introduce new Join Op

Re: [PR] [FLINK-36248][table] Introduce new Join Operator with Async State API [flink]

2024-09-24 Thread via GitHub
lincoln-lil merged PR #25320: URL: https://github.com/apache/flink/pull/25320 -- 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.a

[jira] [Resolved] (FLINK-34082) Remove deprecated methods of Configuration in 2.0

2024-09-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34082. - Fix Version/s: 2.0-preview (was: 2.0.0) Resolution: Fixed > Remove depreca

[jira] [Resolved] (FLINK-34079) FLIP-405: Migrate string configuration key to ConfigOption

2024-09-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34079. - Fix Version/s: 2.0-preview (was: 2.0.0) Resolution: Fixed > FLIP-405: Migr

[jira] [Commented] (FLINK-34082) Remove deprecated methods of Configuration in 2.0

2024-09-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884218#comment-17884218 ] Rui Fan commented on FLINK-34082: - Merged to 2.0 via: * 16b8ed3fabc64fef387b641695472a9

  1   2   >