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

2025-07-27 Thread via GitHub
github-actions[bot] commented on PR #24923: URL: https://github.com/apache/flink/pull/24923#issuecomment-3125714806 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] [api][java] react agent api [flink-agents]

2025-07-27 Thread via GitHub
letaoj opened a new pull request, #82: URL: https://github.com/apache/flink-agents/pull/82 Linked issue: #57 ### Purpose of change This change added a base API for react agent definition, aiming to provide the basic loop of the react agent. ### Tests

[jira] [Commented] (FLINK-38131) Repartition BroadcastState with finished operators

2025-07-27 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010242#comment-18010242 ] Zakelly Lan commented on FLINK-38131: - [~zhourenxiang] This seems valid, would you p

[jira] [Resolved] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend

2025-07-27 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37294. - Fix Version/s: 2.2.0 Resolution: Fixed > Support state migration between disabling and en

[jira] [Commented] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend

2025-07-27 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010240#comment-18010240 ] Zakelly Lan commented on FLINK-37294: - Merge 076b8bd into master > Support state mi

Re: [PR] [FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend [flink]

2025-07-27 Thread via GitHub
Zakelly merged PR #26651: URL: https://github.com/apache/flink/pull/26651 -- 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: [D] Community Sync [flink-agents]

2025-07-27 Thread via GitHub
GitHub user xintongsong edited a discussion: Community Sync There's a community sync for discussing developing progress, technical designs and community issues about Flink Agents. Everyone is welcome to join. * Schedule: 3am Wed UTC * [Google Calendar](https://calendar.google.com/calendar/u/

Re: [PR] Add Flink 2.1.0 release [flink-web]

2025-07-27 Thread via GitHub
leonardBang commented on code in PR #800: URL: https://github.com/apache/flink-web/pull/800#discussion_r2234502885 ## docs/data/release_archive.yml: ## @@ -1,5 +1,9 @@ release_archive: flink: +- + version_short: "2.0" Review Comment: ```suggestion versi

Re: [PR] [FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend [flink]

2025-07-27 Thread via GitHub
Zakelly commented on code in PR #26651: URL: https://github.com/apache/flink/pull/26651#discussion_r2234476547 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java: ## @@ -299,6 +296,52 @@ private StateTable tryRegisterStateTable(

Re: [D] Community Sync [flink-agents]

2025-07-27 Thread via GitHub
GitHub user xintongsong edited a discussion: Community Sync There's a community sync for discussing developing progress, technical designs and community issues about Flink Agents. Everyone is welcome to join. * Schedule: 3am Wed UTC * Google Calendar: https://calendar.google.com/calendar/u/0?

Re: [PR] [FLINK-35855][table] Upgrade Calcite to 1.36.0 [flink]

2025-07-27 Thread via GitHub
snuyanzin commented on code in PR #26827: URL: https://github.com/apache/flink/pull/26827#discussion_r2234166361 ## flink-table/flink-sql-client/src/test/resources/sql/table.q: ## @@ -1092,25 +1092,25 @@ Sink(table=[default_catalog.default_database.orders2], fields=[user, produ

Re: [PR] [FLINK-35855][table] Upgrade Calcite to 1.36.0 [flink]

2025-07-27 Thread via GitHub
snuyanzin commented on code in PR #26827: URL: https://github.com/apache/flink/pull/26827#discussion_r2234166361 ## flink-table/flink-sql-client/src/test/resources/sql/table.q: ## @@ -1092,25 +1092,25 @@ Sink(table=[default_catalog.default_database.orders2], fields=[user, produ

Re: [PR] [FLINK-35855][table] Upgrade Calcite to 1.36.0 [flink]

2025-07-27 Thread via GitHub
snuyanzin commented on code in PR #26827: URL: https://github.com/apache/flink/pull/26827#discussion_r2234166361 ## flink-table/flink-sql-client/src/test/resources/sql/table.q: ## @@ -1092,25 +1092,25 @@ Sink(table=[default_catalog.default_database.orders2], fields=[user, produ

Re: [PR] [FLINK-35855][table] Upgrade Calcite to 1.36.0 [flink]

2025-07-27 Thread via GitHub
snuyanzin commented on code in PR #26827: URL: https://github.com/apache/flink/pull/26827#discussion_r2234136612 ## flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java: ## @@ -2511,6 +2529,11 @@ protected void convertFrom(

Re: [PR] [FLINK-32033][Kubernetes-Operator] Fix Lifecycle Status of FlinkDeployment Resource in case of MISSING/ERROR JM status [flink-kubernetes-operator]

2025-07-27 Thread via GitHub
nishita-09 commented on PR #997: URL: https://github.com/apache/flink-kubernetes-operator/pull/997#issuecomment-3124305698 @gyfora The branch was not updated hence had to update it so this would need to be built again. Also kindly, do let me know if there are any further comments on the ch

[jira] [Comment Edited] (FLINK-35746) Add logic to override observed config based on settings observed through REST API

2025-07-27 Thread Nishita Pattanayak (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010190#comment-18010190 ] Nishita Pattanayak edited comment on FLINK-35746 at 7/27/25 10:51 AM:

[jira] [Commented] (FLINK-35746) Add logic to override observed config based on settings observed through REST API

2025-07-27 Thread Nishita Pattanayak (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010190#comment-18010190 ] Nishita Pattanayak commented on FLINK-35746: [~gyfora] Currently the attache

[jira] [Updated] (FLINK-35746) Add logic to override observed config based on settings observed through REST API

2025-07-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35746: --- Labels: pull-request-available (was: ) > Add logic to override observed config based on set

[PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator]

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

Re: [PR] [FLINK-38137][state] RocksDB and ForSt state backend are compatible with the case where the user value of the map state is null [flink]

2025-07-27 Thread via GitHub
1996fanrui commented on code in PR #26831: URL: https://github.com/apache/flink/pull/26831#discussion_r2233898522 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/AbstractRocksDBState.java: ## @@ -176,7 +176,10 @@ byte[] serializeV

Re: [PR] [client] optimise JobStatusPollingUtils of pollJobResultAsync [flink]

2025-07-27 Thread via GitHub
flinkbot commented on PR #26835: URL: https://github.com/apache/flink/pull/26835#issuecomment-3124286079 ## CI report: * b5e83e2a272dc4d5f34e2ee4837c894ce6139001 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [client] optimise JobStatusPollingUtils of pollJobResultAsync [flink]

2025-07-27 Thread via GitHub
huleidada opened a new pull request, #26835: URL: https://github.com/apache/flink/pull/26835 [client] optimise JobStatusPollingUtils of pollJobResultAsync -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[jira] [Created] (FLINK-38144) Change log state backend is not compatible with the case where the user value of the map state is null

2025-07-27 Thread Rui Fan (Jira)
Rui Fan created FLINK-38144: --- Summary: Change log state backend is not compatible with the case where the user value of the map state is null Key: FLINK-38144 URL: https://issues.apache.org/jira/browse/FLINK-38144