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

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

[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-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

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-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-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] [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-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-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-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] [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

[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] [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-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] [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] [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-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] [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-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] [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-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] [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] [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] [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-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] [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] 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] [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-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] [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] [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] 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] [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] [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

[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] [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.

[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] [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

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] 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-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] 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

[jira] [Updated] (FLINK-25353) Add tests to ensure API graduation process is honoured

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

[jira] [Updated] (FLINK-32699) select typeof(proctime()); throw exception in sql-client

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32699: --- Fix Version/s: 2.1.0 (was: 2.0.0) > select typeof(proctime()); throw exceptio

[jira] [Updated] (FLINK-30970) Fix SQL Client doc still uses old style output

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30970: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Fix SQL Client doc still uses old style o

[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: 2.1.0 > Better detection for parquet and orc in hive > --

Re: [PR] [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A… [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #17891: URL: https://github.com/apache/flink/pull/17891#issuecomment-2764409750 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-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side

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

Re: [PR] [FLINK-29551][table] Improving adaptive hash join by using sort merge join strategy per partition instead of all partitions [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #20996: [FLINK-29551][table] Improving adaptive hash join by using sort merge join strategy per partition instead of all partitions URL: https://github.com/apache/flink/pull/20996 -- This is an automated message from the Apache Git Service. To respond

Re: [PR] [FLINK-30309][runtime] Allow users to supply custom SslContexts [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #21457: URL: https://github.com/apache/flink/pull/21457#issuecomment-2771456525 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-37511][rest] Use Jackson serialization in JobPlanInfo.Plan [flink]

2025-04-05 Thread via GitHub
Efrat19 commented on PR #26320: URL: https://github.com/apache/flink/pull/26320#issuecomment-2746070543 @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-30551] Add open/close interface to PartitionCommitPolicy [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #21623: URL: https://github.com/apache/flink/pull/21623#issuecomment-2771458089 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] [hotfix][rpc] Use AtomicLong#getAndIncrement to simplify increment number [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #18295: [hotfix][rpc] Use AtomicLong#getAndIncrement to simplify increment number URL: https://github.com/apache/flink/pull/18295 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [FLINK-37584] Bump assertj-core [flink]

2025-04-05 Thread via GitHub
ferenc-csaky merged PR #26376: URL: https://github.com/apache/flink/pull/26376 -- 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] Draft [FLINK-33335] (CI) [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #23605: Draft [FLINK-5] (CI) URL: https://github.com/apache/flink/pull/23605 -- 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 unsu

Re: [PR] [BP-1.17][FLINK-30629][Client/Job Submission] Increase clientHeartbeatTimeout … [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #23074: [BP-1.17][FLINK-30629][Client/Job Submission] Increase clientHeartbeatTimeout … URL: https://github.com/apache/flink/pull/23074 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Created] (FLINK-37600) Add a pre-commit git hook for running linting checks

2025-04-05 Thread Thomas Cooper (Jira)
Thomas Cooper created FLINK-37600: - Summary: Add a pre-commit git hook for running linting checks Key: FLINK-37600 URL: https://issues.apache.org/jira/browse/FLINK-37600 Project: Flink Issue

[jira] [Updated] (FLINK-21179) Make sure that the open/close methods of the Python DataStream Function are not implemented when using in ReducingState and AggregatingState

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-21179: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Make sure that the open/close methods of

[jira] [Updated] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-18565: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Add Support for Azure Event Grid DataStre

Re: [PR] [FLINK-37416][BugFix][Connectors/DynamoDB] Fix state inconsistency issue in DDB connector when sending split finished event from reader -> enumerator [flink-connector-aws]

2025-04-05 Thread via GitHub
gguptp commented on code in PR #193: URL: https://github.com/apache/flink-connector-aws/pull/193#discussion_r2014045507 ## flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/DynamoDbStreamsSourceReader.java: ## @@ -80,8

[jira] [Updated] (FLINK-31951) Mix schema record source creates corrupt record

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

[PR] [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationC… [flink]

2025-04-05 Thread via GitHub
fsk119 opened a new pull request, #26324: URL: https://github.com/apache/flink/pull/26324 CP #26314 -- 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:

Re: [PR] [FLINK-29646][sql-gateway] rest endpoint return a simpler error message [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #21076: URL: https://github.com/apache/flink/pull/21076#issuecomment-2768305237 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-33634 [flink-kubernetes-operator]

2025-04-05 Thread via GitHub
davidradl commented on code in PR #957: URL: https://github.com/apache/flink-kubernetes-operator/pull/957#discussion_r2007936365 ## flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/utils/ConditionUtils.java: ## @@ -0,0 +1,51 @@ +/* + * Licens

Re: [PR] [FLINK-23031][table-runtime]Make processing time trigger dont repeat itself when no new element come in [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #16207: [FLINK-23031][table-runtime]Make processing time trigger dont repeat itself when no new element come in URL: https://github.com/apache/flink/pull/16207 -- This is an automated message from the Apache Git Service. To respond to the message, plea

Re: [PR] [FLINK-32485][state-backends] Support build flink-state-backend-changelog test-jar [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #22905: URL: https://github.com/apache/flink/pull/22905#issuecomment-2774619677 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-15553) Create table ddl support comment after computed column

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-15553: --- Affects Version/s: 2.1.0 (was: 1.10.0) > Create table ddl support commen

Re: [PR] [FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator [flink]

2025-04-05 Thread via GitHub
davidradl commented on PR #26357: URL: https://github.com/apache/flink/pull/26357#issuecomment-2758935452 @mxm there are numerous table planner test failures in the CI tests. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [FLINK-26732][runtime] logs key info for DefaultResourceAllocationStr… [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #19149: URL: https://github.com/apache/flink/pull/19149#issuecomment-2765254654 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-29971][HBase] Fix hbase sink will lose data at some extreme case. [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #21334: [FLINK-29971][HBase] Fix hbase sink will lose data at some extreme case. URL: https://github.com/apache/flink/pull/21334 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [FLINK-37128][pipeline-connector/mysql] Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill [flink-cdc]

2025-04-05 Thread via GitHub
beryllw commented on PR #3874: URL: https://github.com/apache/flink-cdc/pull/3874#issuecomment-2742926693 @leonardBang PTAL. Could you please take a look? This feature will be beneficial for large tables with fast binlog writing. During the binlog replay phase, filtering the data to be r

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

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

[jira] [Updated] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-23942: --- Affects Version/s: 2.1.0 > Python documentation redirects to shared pages should activate python tab

Re: [PR] [FLINK-37521][runtime] Implement async state version of KeyedCoProcessOperator [flink]

2025-04-05 Thread via GitHub
fredia commented on PR #26328: URL: https://github.com/apache/flink/pull/26328#issuecomment-2774208393 Thanks for reviewing, updated and merged. -- 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 th

Re: [PR] [FLINK-26498][TABLE][WINDOW]emit result when cleanupTime timer call onEventTime if allowlatency e… [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #18995: [FLINK-26498][TABLE][WINDOW]emit result when cleanupTime timer call onEventTime if allowlatency e… URL: https://github.com/apache/flink/pull/18995 -- This is an automated message from the Apache Git Service. To respond to the message, please lo

Re: [PR] [FLINK-24386] Guard JobMaster against exceptions from starting the Op… [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #21538: URL: https://github.com/apache/flink/pull/21538#issuecomment-2771457240 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-29040) When using the JDBC Catalog, the custom cannot be applied because it is fixed in the code

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29040: --- Affects Version/s: 2.1.0 (was: 1.16.0) > When using the JDBC Catalog, the

[jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31116: --- Affects Version/s: 2.1.0 (was: 1.16.1) > Support taskmanager related para

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

2025-04-05 Thread via GitHub
davidradl commented on code in PR #26396: URL: https://github.com/apache/flink/pull/26396#discussion_r2027100263 ## docs/content.zh/docs/dev/table/functions/ptfs.md: ## @@ -708,6 +708,80 @@ class CountingFunction extends ProcessTableFunction { {{< /tab >}} {{< /tabs >}} +##

[jira] [Updated] (FLINK-36339) Remove java serialization from SQL serializers

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36339: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Remove java serialization from SQL serial

[jira] [Updated] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-20834: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Add metrics for reporting the memory usag

Re: [PR] [FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter. [flink]

2025-04-05 Thread via GitHub
Poorvankbhatia commented on code in PR #26274: URL: https://github.com/apache/flink/pull/26274#discussion_r2027547696 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/RequestBuffer.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to t

Re: [PR] [FLINK-37475] Drop ChangelogNormalize for piping from upsert source to sink [flink]

2025-04-05 Thread via GitHub
davidradl commented on code in PR #26306: URL: https://github.com/apache/flink/pull/26306#discussion_r2005889032 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/trait/DeleteKindTrait.scala: ## @@ -0,0 +1,100 @@ +/* + * Licensed to the Apache

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

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #20806: Update overview.md URL: https://github.com/apache/flink/pull/20806 -- 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

Re: [PR] [FLINK-37463] make serialzer in ForStMapState Threadlocal [flink]

2025-04-05 Thread via GitHub
mayuehappy commented on PR #26286: URL: https://github.com/apache/flink/pull/26286#issuecomment-2732089735 @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] [hotfix] Simplify the variable checkpointStatsSnapshotCacheExpireAfterWrite [flink]

2025-04-05 Thread via GitHub
beliefer commented on PR #26349: URL: https://github.com/apache/flink/pull/26349#issuecomment-2767877279 @1996fanrui @davidradl @hlteoh37 Thank you all! -- 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] [FLINK-11470][runtime] Pass configurations to filesystems when executing in LocalStreamEnvironment [flink]

2025-04-05 Thread via GitHub
github-actions[bot] closed pull request #17580: [FLINK-11470][runtime] Pass configurations to filesystems when executing in LocalStreamEnvironment URL: https://github.com/apache/flink/pull/17580 -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-37002) Migrate DecomposeGroupingSetsRule

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

[jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34973: --- Affects Version/s: 2.1.0 > FLIP-425: Asynchronous Execution Model >

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

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

[jira] [Updated] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc.

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36136: --- Affects Version/s: 2.1.0 > Remove TableSource & TableSink impl and utils, docs and etc. > --

[jira] [Updated] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed

2025-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37453: --- Labels: pull-request-available (was: ) > Migration Tests / data_stream_migration_test (8, 1

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-17337: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Send UPDATE messages instead of INSERT an

[jira] [Updated] (FLINK-35145) Add timeout for cluster termination

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

[jira] [Closed] (FLINK-37571) Last state upgrade mode broken for Flink 2.0

2025-04-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-37571. -- Fix Version/s: kubernetes-operator-1.12.0 Resolution: Fixed merged to main 93e68f2bc2a007dfcfe4

[jira] [Updated] (FLINK-32573) Translate "Custom Serialization for Managed State" page into Chinese

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32573: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Translate "Custom Serialization for Manag

[jira] [Updated] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord

2025-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-20853: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Add reader schema null check for AvroDese

Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-connector-hive [flink]

2025-04-05 Thread via GitHub
github-actions[bot] commented on PR #23480: URL: https://github.com/apache/flink/pull/23480#issuecomment-2777666434 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

  1   2   3   4   5   6   7   >