Re: [PR] [FLINK-12450] Add leftshift, rightshift functions support in Table API and SQL [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25053: URL: https://github.com/apache/flink/pull/25053#issuecomment-2781251920 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [hotfix][doc] missing "STATISTICS" sql reserved keyword in zh doc [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25041: URL: https://github.com/apache/flink/pull/25041#issuecomment-2781251894 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24997: URL: https://github.com/apache/flink/pull/24997#issuecomment-2781251865 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [hotfix] Fix npm issue in document Build [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25147: URL: https://github.com/apache/flink/pull/25147#issuecomment-2781252369 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-26232][tests][JUnit5 migration] Module:flink-avro [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25087: URL: https://github.com/apache/flink/pull/25087#issuecomment-2781251939 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-36029] Add @Nullable Annotation to ValueState's Value Method Return Type [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25187: URL: https://github.com/apache/flink/pull/25187#issuecomment-2781252382 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] Update SimpleStringSchema.java [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25096: URL: https://github.com/apache/flink/pull/25096#issuecomment-2781252224 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25018: URL: https://github.com/apache/flink/pull/25018#issuecomment-2781251884 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35902][ui] WebUI Metrics RangeError on huge parallelism [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25123: URL: https://github.com/apache/flink/pull/25123#issuecomment-2781252328 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [BP-1.20] [FLINK-35657][runtime-web] use parseFloat for metric value [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25047: URL: https://github.com/apache/flink/pull/25047#issuecomment-2781251915 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35628][docs] Provide a Chinese translation of datagen.md [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25128: URL: https://github.com/apache/flink/pull/25128#issuecomment-2781252349 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-26940][table] Add the built-in function SUBSTRING_INDEX [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24972: URL: https://github.com/apache/flink/pull/24972#issuecomment-2781251502 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [hotfix] [docs/test] Fix docs and testcases of Json format [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25188: URL: https://github.com/apache/flink/pull/25188#issuecomment-2781252394 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [hotfix] [docs] Fix typo in docker.md [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25194: URL: https://github.com/apache/flink/pull/25194#issuecomment-2781252402 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [BP-2.0][FLINK-37609][format] Bump parquet to 1.15.1 [flink]

2025-04-05 Thread via GitHub
flinkbot commented on PR #26411: URL: https://github.com/apache/flink/pull/26411#issuecomment-2781253105 ## CI report: * 2b2dabf17a8f3928b5afc14b8f43de96aad9e078 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35864][table] Add CONV function [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25109: URL: https://github.com/apache/flink/pull/25109#issuecomment-2781252287 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-36008][Documentation] Script and guidance to preview connector docs contributions [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25181: URL: https://github.com/apache/flink/pull/25181#issuecomment-2781252375 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

[jira] [Updated] (FLINK-35595) MailboxProcessor#processMailsWhenDefaultActionUnavailable is allocation intensive

2025-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35595: --- Labels: pull-request-available (was: ) > MailboxProcessor#processMailsWhenDefaultActionUnav

Re: [PR] [FLINK-35925] remove hive connector from main repo [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25129: URL: https://github.com/apache/flink/pull/25129#issuecomment-2781252356 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35560][Table SQL/Gateway] Support custom query operation validator for sql gateway [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25092: URL: https://github.com/apache/flink/pull/25092#issuecomment-2781251964 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

[jira] [Updated] (FLINK-35642) parsing the configuration file in flink, when configuring the s3 key, if there is contain # char, the correct key will be split

2025-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35642: --- Labels: pull-request-available (was: ) > parsing the configuration file in flink, when conf

Re: [PR] [Fix][javadocs] Fix typo in DataStreamSource [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25124: URL: https://github.com/apache/flink/pull/25124#issuecomment-2781252341 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35897][Checkpoint] Cleanup completed resource when checkpoint is canceled [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25120: URL: https://github.com/apache/flink/pull/25120#issuecomment-2781252314 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.18 [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25016: URL: https://github.com/apache/flink/pull/25016#issuecomment-2781251871 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35704] Use ForkJoinPool in NonSplittingRecursiveEnumerator [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24986: URL: https://github.com/apache/flink/pull/24986#issuecomment-2781251517 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35797] DRAFT of work for FLIP-456. [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25063: URL: https://github.com/apache/flink/pull/25063#issuecomment-2781251934 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-20539][table-planner] Fix type mismatch when casting ROW [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24994: URL: https://github.com/apache/flink/pull/24994#issuecomment-2781251846 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [BP-1.19] [FLINK-35657][runtime-web] use parseFloat for metric value [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25046: URL: https://github.com/apache/flink/pull/25046#issuecomment-2781251905 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.19 [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25017: URL: https://github.com/apache/flink/pull/25017#issuecomment-2781251876 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35653][docs] add missing "env.execute" explanation in fraud detection example [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24959: URL: https://github.com/apache/flink/pull/24959#issuecomment-2781251491 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #25027: URL: https://github.com/apache/flink/pull/25027#issuecomment-2781251887 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-26943][table] Add the built-in function DATE_ADD [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24988: URL: https://github.com/apache/flink/pull/24988#issuecomment-2781251765 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35595][core] MailboxProcessor#processMailsWhenDefaultActionUnavailable avoids allocating Optional [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24923: URL: https://github.com/apache/flink/pull/24923#issuecomment-2781251445 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [hotfix][Table SQL / API] fix create table from values decimal issue [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24981: URL: https://github.com/apache/flink/pull/24981#issuecomment-2781251508 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35642] parsing the configuration file,Special handle s3 secret… [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24957: URL: https://github.com/apache/flink/pull/24957#issuecomment-2781251486 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] Update flink-operations-playground.md for a typo [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24927: URL: https://github.com/apache/flink/pull/24927#issuecomment-2781251455 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-30400][docs] Add some notes about changes for flink-connector-base dependency in externalized connectors [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24930: URL: https://github.com/apache/flink/pull/24930#issuecomment-2781251463 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-35598][sql-parser] Fix error comparison type ExtendedSqlRowTypeNameSpec#equalsDeep [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24937: URL: https://github.com/apache/flink/pull/24937#issuecomment-2781251470 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] Documentation typo [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24951: URL: https://github.com/apache/flink/pull/24951#issuecomment-2781251482 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-32562][connectors/filesystem] Handle concatenable compressed streams correctly in FileCompactor [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24914: URL: https://github.com/apache/flink/pull/24914#issuecomment-2781251413 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-XXX][planner] Support custom shuffle for lookup join [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #24920: URL: https://github.com/apache/flink/pull/24920#issuecomment-2781251432 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

[jira] [Commented] (FLINK-37609) Bump parquet libs to 1.15.1

2025-04-05 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941316#comment-17941316 ] Ferenc Csaky commented on FLINK-37609: -- Thanks for the BP PRs! Opened a PR for {{re

Re: [PR] [BP-2.0][FLINK-37609][format] Bump parquet to 1.15.1 [flink]

2025-04-05 Thread via GitHub
ferenc-csaky commented on PR #26411: URL: https://github.com/apache/flink/pull/26411#issuecomment-2781248548 cc @snuyanzin -- 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] [BP-2.0][FLINK-37609][format] Bump parquet to 1.15.1 [flink]

2025-04-05 Thread via GitHub
ferenc-csaky opened a new pull request, #26411: URL: https://github.com/apache/flink/pull/26411 2.0 backport of https://github.com/apache/flink/pull/26398 -- 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 t

Re: [PR] [FLINK-37618][table-planner] Fix PTFs INTERVAL argument [flink]

2025-04-05 Thread via GitHub
flinkbot commented on PR #26410: URL: https://github.com/apache/flink/pull/26410#issuecomment-2781173611 ## CI report: * 4964f8052e88cf984b34febfa39aa9550fc11fc3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-37618) Support PTFs INTERVAL argument

2025-04-05 Thread juntaozhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941310#comment-17941310 ] juntaozhang commented on FLINK-37618: - hi [~twalthr], sorry bother you, when I run P

[jira] [Updated] (FLINK-37618) Support PTFs INTERVAL argument

2025-04-05 Thread juntaozhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] juntaozhang updated FLINK-37618: Description: SELECT * FROM f(d => INTERVAL '1' SECOND)   {code} org.apache.flink.table.api.Valida

[jira] [Updated] (FLINK-37618) Support PTFs INTERVAL argument

2025-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37618: --- Labels: pull-request-available (was: ) > Support PTFs INTERVAL argument > -

[jira] [Created] (FLINK-37618) Support PTFs INTERVAL argument

2025-04-05 Thread juntaozhang (Jira)
juntaozhang created FLINK-37618: --- Summary: Support PTFs INTERVAL argument Key: FLINK-37618 URL: https://issues.apache.org/jira/browse/FLINK-37618 Project: Flink Issue Type: Sub-task C

[PR] [FLINK-37618][table-planner] Fix PTFs INTERVAL argument [flink]

2025-04-05 Thread via GitHub
juntaozhang opened a new pull request, #26410: URL: https://github.com/apache/flink/pull/26410 ## What is the purpose of the change *Support INTERVAL argument in PTFs* ## Brief change log add visit parameter of `DayTimeIntervalType` in `CastAvoidanceChecker`

Re: [PR] [FLINK-35516][Connector/Files] Update the Experimental annotation for files connector [flink]

2025-04-05 Thread via GitHub
RocMarshal closed pull request #24885: [FLINK-35516][Connector/Files] Update the Experimental annotation for files connector URL: https://github.com/apache/flink/pull/24885 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-37609) Bump parquet libs to 1.15.1

2025-04-05 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941303#comment-17941303 ] Sergey Nuyanzin commented on FLINK-37609: - Backport PRs https://github.com/apach

Re: [PR] [BP-1.19][FLINK-37609][format] Bump parquet to 1.15.1 [flink]

2025-04-05 Thread via GitHub
snuyanzin commented on PR #26409: URL: https://github.com/apache/flink/pull/26409#issuecomment-278918 @ferenc-csaky since you were asking about this -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: [PR] [BP-1.19] Bump parquet to 1.15.1 [flink]

2025-04-05 Thread via GitHub
flinkbot commented on PR #26409: URL: https://github.com/apache/flink/pull/26409#issuecomment-2781057334 ## CI report: * 96ea207466073fb87dd4314d6635a4a0a45eb70c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [BP-1.20] Bump parquet to 1.15.1 [flink]

2025-04-05 Thread via GitHub
flinkbot commented on PR #26408: URL: https://github.com/apache/flink/pull/26408#issuecomment-2781054376 ## CI report: * 2e438789c9c5a9fff1c9f944a68656ef8a049935 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [BP-1.19] Bump parquet to 1.15.1 [flink]

2025-04-05 Thread via GitHub
snuyanzin opened a new pull request, #26409: URL: https://github.com/apache/flink/pull/26409 1.19 backport of https://github.com/apache/flink/commit/5aaff07fe925b289a2cabe9269a015ebc2255223 and https://github.com/apache/flink/commit/d8cd5591d3136187695727202dc16bc96ce2caae -- This is

Re: [PR] [BP-1.20] Bump parquet to 1.15.1 [flink]

2025-04-05 Thread via GitHub
snuyanzin commented on PR #26408: URL: https://github.com/apache/flink/pull/26408#issuecomment-2781051525 cc @ferenc-csaky since you were asking about this -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[PR] [BP-1.20] Bump parquet to 1.15.1 [flink]

2025-04-05 Thread via GitHub
snuyanzin opened a new pull request, #26408: URL: https://github.com/apache/flink/pull/26408 1.20 backport of https://github.com/apache/flink/commit/5aaff07fe925b289a2cabe9269a015ebc2255223 and https://github.com/apache/flink/commit/d8cd5591d3136187695727202dc16bc96ce2caae -- This is

Re: [PR] [FLINK-37579] Avoid duplicate generate ResourceProfile [flink]

2025-04-05 Thread via GitHub
beliefer commented on PR #26377: URL: https://github.com/apache/flink/pull/26377#issuecomment-2768210159 ping @tillrohrmann cc @1996fanrui @davidradl @GOODBOY008 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-23900) Migrate to ClusterActorRefProvider

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-23900: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Migrate to ClusterActorRefProvider >

Re: [PR] [FLINK-30721][avro-confluent-registry] Enable 8byte schema id [flink]

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

[jira] [Updated] (FLINK-32184) Use revision version property

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32184: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Use revision version property > -

Re: [PR] [FLINK-37587][runtime] Fix error when adding a column using transform which has the same column name with one column of source table. [flink-cdc]

2025-04-05 Thread via GitHub
yuxiqian commented on PR #3974: URL: https://github.com/apache/flink-cdc/pull/3974#issuecomment-2765783565 Thanks for @lvyanquan's nice work! I've prepared a simple composer ITcase to cover this scenario, could you please integrate it and check if it works? ```java // In `FlinkPipe

Re: [PR] [FLINK-37579] Avoid duplicate generate ResourceProfile [flink]

2025-04-05 Thread via GitHub
beliefer closed pull request #26371: [FLINK-37579] Avoid duplicate generate ResourceProfile URL: https://github.com/apache/flink/pull/26371 -- 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 specif

Re: [PR] [FLINK-23378][flink-streaming-java] ContinuousProcessingTimeTrigger can't triger the last fireTimestamp [flink]

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

[jira] [Created] (FLINK-37547) Add initial document for PTFs

2025-04-05 Thread Timo Walther (Jira)
Timo Walther created FLINK-37547: Summary: Add initial document for PTFs Key: FLINK-37547 URL: https://issues.apache.org/jira/browse/FLINK-37547 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-20572: --- Affects Version/s: 2.1.0 > HiveCatalog should be a standalone module > -

Re: [PR] [FLINK-13910] Add missing serialVersionUID for serializable classes [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #10610: [FLINK-13910] Add missing serialVersionUID for serializable classes URL: https://github.com/apache/flink/pull/10610 -- 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

[jira] [Updated] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-27455: --- Fix Version/s: 2.1.0 (was: 2.0.0) > [JUnit5 Migration] SnapshotMigrationTestB

Re: [PR] [FLINK-26945][Table SQL/API] Add DATE_SUB supported in SQL & Table API [flink]

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

[jira] [Created] (FLINK-37539) performance optimization in Paimon Sink to reduce end-to-end checkpoint time

2025-04-05 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-37539: -- Summary: performance optimization in Paimon Sink to reduce end-to-end checkpoint time Key: FLINK-37539 URL: https://issues.apache.org/jira/browse/FLINK-37539 Project: Fli

Re: [PR] [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization [flink]

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

Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]

2025-04-05 Thread via GitHub
davidradl commented on code in PR #26328: URL: https://github.com/apache/flink/pull/26328#discussion_r2005993388 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/functions/DeclaringAsyncKeyedCoProcessFunction.java: ## @@ -0,0 +1,170 @@ +/* + * Licensed to

Re: [PR] [FLINK-24546][docs]Add description for acknowledgement [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #17495: [FLINK-24546][docs]Add description for acknowledgement URL: https://github.com/apache/flink/pull/17495 -- 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

Re: [PR] [FLINK-29770]hbase connector supports out of order data [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #21169: [FLINK-29770]hbase connector supports out of order data URL: https://github.com/apache/flink/pull/21169 -- 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 t

Re: [PR] [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor URL: https://github.com/apache/flink/pull/10357 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

Re: [PR] fix the syntax for multiple insert [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #19776: fix the syntax for multiple insert URL: https://github.com/apache/flink/pull/19776 -- 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

Re: [PR] [FLINK-30570] Fix error inferred partition condition [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #21622: [FLINK-30570] Fix error inferred partition condition URL: https://github.com/apache/flink/pull/21622 -- 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 t

[jira] [Updated] (FLINK-35326) Implement lineage interface for hive connector

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35326: --- Affects Version/s: 2.1.0 (was: 1.20.0) > Implement lineage interface for

[jira] [Updated] (FLINK-33558) Externalize Elasticsearch Python connector code

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33558: --- Affects Version/s: 2.1.0 (was: 1.18.0) > Externalize Elasticsearch Python

Re: [PR] [FLINK-30888][doc] Flink Doc(zh version) has misspelled words [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #21876: [FLINK-30888][doc] Flink Doc(zh version) has misspelled words URL: https://github.com/apache/flink/pull/21876 -- 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 t

[jira] [Updated] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules

2025-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37525: --- Labels: pull-request-available (was: ) > Introduce overload findModuleFactory to improve th

Re: [PR] [FLINK-30036][kubernetes] force delete pod when the k8s node is under NotReady state [flink]

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

Re: [PR] [FLINK-13665][flink-planner] Use of decimal(p, s) where p is less tha… [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #9402: [FLINK-13665][flink-planner] Use of decimal(p, s) where p is less tha… URL: https://github.com/apache/flink/pull/9402 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-28830) new stack udtf doesn't support atomic type

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28830: --- Affects Version/s: 2.1.0 (was: 1.16.0) > new stack udtf doesn't support a

Re: [PR] [FLINK-36648] Bump Flink version to Flink 2.0.0 [flink-connector-kafka]

2025-04-05 Thread via GitHub
rmetzger commented on code in PR #140: URL: https://github.com/apache/flink-connector-kafka/pull/140#discussion_r2015803052 ## flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceITTest.java: ## @@ -805,30 +801,31 @@ private Kaf

[jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36911: --- Fix Version/s: 2.1.0 (was: 2.0.0) > add more calcite rules to improve flink p

[jira] [Updated] (FLINK-32444) Enable object reuse for Flink SQL jobs by default

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32444: --- Affects Version/s: 2.1.0 > Enable object reuse for Flink SQL jobs by default > -

Re: [PR] [hotfix][docs] Remove the redundant punctuation in dev/training/index.md [flink]

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

Re: [PR] [FLINK-21784][state/heap] Allow Restore Operation customization [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #19307: [FLINK-21784][state/heap] Allow Restore Operation customization URL: https://github.com/apache/flink/pull/19307 -- 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

Re: [PR] [FLINK-27482][code] Updated config.sh [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #21631: [FLINK-27482][code] Updated config.sh URL: https://github.com/apache/flink/pull/21631 -- 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 com

Re: [PR] [hotfix] Preconditions.checkState should follows the Flink code style [flink]

2025-04-05 Thread via GitHub
beliefer commented on PR #26340: URL: https://github.com/apache/flink/pull/26340#issuecomment-2748105568 ping @StephanEwen @xintongsong cc @1996fanrui @GOODBOY008 @davidradl -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-17784: --- Affects Version/s: (was: 2.1.0) > Better detection for parquet and orc in hive > ---

[jira] [Updated] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30467: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Improve the accuracy of estimating the ro

Re: [PR] [FLINK-37598][table] Support list and map state in PTFs [flink]

2025-04-05 Thread via GitHub
twalthr commented on code in PR #26396: URL: https://github.com/apache/flink/pull/26396#discussion_r2028257636 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ProcessTableFunctionTestUtils.java: ## @@ -605,6 +614,80 @@ publi

Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc]

2025-04-05 Thread via GitHub
loserwang1024 commented on PR #3442: URL: https://github.com/apache/flink-cdc/pull/3442#issuecomment-2747384264 > Does postgres,oracle,mssql have schema change record? @AppleJunJiang postgres logical repliacation doesn't have schema change record, this is why this pr is not ready.

Re: [PR] [FLINK-30738] Disable verbose mode of CycloneDX plugin [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #22012: [FLINK-30738] Disable verbose mode of CycloneDX plugin URL: https://github.com/apache/flink/pull/22012 -- 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

Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink]

2025-04-05 Thread via GitHub
flinkbot commented on PR #26326: URL: https://github.com/apache/flink/pull/26326#issuecomment-2739983029 ## CI report: * e94cb2cf544a31b0eb37a51549ae8f1f1b86873d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-29789][tests] Fix flaky test in CheckpointCoordinatorTest [flink]

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

[jira] [Updated] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34665: --- Affects Version/s: 2.1.0 (was: 1.20.0) > Add streaming rule for union to

  1   2   3   4   5   6   7   >