Re: [PR] [FLINK-31336][table] fix interval type info lost in sql and table api. [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22105: [FLINK-31336][table] fix interval type info lost in sql and table api. URL: https://github.com/apache/flink/pull/22105 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [WIP][FLINK-30975][filesystem][s3] upgrade dependencies to aws sdk v2 [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #21924: URL: https://github.com/apache/flink/pull/21924#issuecomment-2771459450 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-27815] batch sql rule optimize [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #21997: URL: https://github.com/apache/flink/pull/21997#issuecomment-2771459748 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-31192][connectors/dataGen] Fix dataGen takes too long to initi… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22010: [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi… URL: https://github.com/apache/flink/pull/22010 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [hotfix] [docs] Replace deprecated option in jdbc connector of Chinese document [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22013: [hotfix] [docs] Replace deprecated option in jdbc connector of Chinese document URL: https://github.com/apache/flink/pull/22013 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

Re: [PR] [FLINK-30810] Rework CliClientITCase extends AbstractStatementTestBase [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #21979: URL: https://github.com/apache/flink/pull/21979#issuecomment-2771459707 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-31161][build] bump versions-maven-plugin to 2.14.2. [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #21978: [FLINK-31161][build] bump versions-maven-plugin to 2.14.2. URL: https://github.com/apache/flink/pull/21978 -- 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] [Updated] (FLINK-37596) Close metric groups for finished splits

2025-04-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37596: --- Labels: pull-request-available (was: ) > Close metric groups for finished splits >

Re: [PR] [Improve] Use 'isEmpty()' replace '<= 0'. [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #21454: URL: https://github.com/apache/flink/pull/21454#issuecomment-2771456445 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] Update intro_to_table_api.md [flink]

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

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

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

Re: [PR] [FLINK-30817] Fix ClassCastException in TestValuesTableFactory [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #21878: URL: https://github.com/apache/flink/pull/21878#issuecomment-2771459043 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] typo in the javadoc of the functions in KeyedStateStore [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #21745: [hotfix] typo in the javadoc of the functions in KeyedStateStore URL: https://github.com/apache/flink/pull/21745 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Updated] (FLINK-34554) FLIP-511: Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint

2025-04-02 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-34554: Summary: FLIP-511: Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created trans

Re: [PR] [FLINK-37597] Use ResourceGuard to make sure snapshot quit before ForSt disposal [flink]

2025-04-02 Thread via GitHub
fredia commented on code in PR #26392: URL: https://github.com/apache/flink/pull/26392#discussion_r2026327063 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/snapshot/ForStNativeFullSnapshotStrategy.java: ## @@ -152,12 +153,14 @@ publi

Re: [PR] fix: missing serialVersionUID of serializable classes [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #24047: URL: https://github.com/apache/flink/pull/24047#issuecomment-2774622884 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-32530][table] Fix array_position return null value semantic, w… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22946: URL: https://github.com/apache/flink/pull/22946#issuecomment-2774620117 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-32175] [docs-zh] translate doc(datagen.md) into chinese [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #24006: URL: https://github.com/apache/flink/pull/24006#issuecomment-2774622533 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 to remove .all from java opts under application profiling [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #23093: URL: https://github.com/apache/flink/pull/23093#issuecomment-2774621741 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-7129]Support dynamically changing CEP patterns [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #23025: [FLINK-7129]Support dynamically changing CEP patterns URL: https://github.com/apache/flink/pull/23025 -- 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-30475][runtime][impovement] RocksDBMapState clear with deleteRange [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #21543: URL: https://github.com/apache/flink/pull/21543#issuecomment-2771457375 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] Update over-agg.md [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #21475: URL: https://github.com/apache/flink/pull/21475#issuecomment-2771456922 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-37597] Use ResourceGuard to make sure snapshot quit before ForSt disposal [flink]

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

[jira] [Updated] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint

2025-04-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37524: --- Labels: pull-request-available (was: ) > State Serializer in ForState should restore from o

Re: [PR] [FLINK-30088][runtime] Fix excessive state updates for TtlMapState and TtlListState [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #21406: [FLINK-30088][runtime] Fix excessive state updates for TtlMapState and TtlListState URL: https://github.com/apache/flink/pull/21406 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[PR] [FLINK-31406] Do not delete jobgraph on scale only last-state upgrades [flink-kubernetes-operator]

2025-04-02 Thread via GitHub
pchoudhury22 opened a new pull request, #967: URL: https://github.com/apache/flink-kubernetes-operator/pull/967 ### What is the purpose of the change Retain job graph on Scale only last state upgrades. ### Brief change log Add mechanism to detect upgrade for SCALE only di

[jira] [Updated] (FLINK-35117) AsyncScalarFunction has a dependency issue.

2025-04-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35117: --- Labels: easyfix pull-request-available (was: easyfix) > AsyncScalarFunction has a dependenc

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

2025-04-02 Thread via GitHub
hlteoh37 commented on code in PR #26274: URL: https://github.com/apache/flink/pull/26274#discussion_r2025160358 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java: ## @@ -327,7 +349,12 @@ private void flush() t

Re: [PR] [FLINK-35117][Table SQL/Planner] Add commons-text to allowed classloader list [flink]

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

Re: [PR] [FLINK-34554] Introduce transaction strategies [flink-connector-kafka]

2025-04-02 Thread via GitHub
fapaul commented on code in PR #154: URL: https://github.com/apache/flink-connector-kafka/pull/154#discussion_r2024533233 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java: ## @@ -293,22 +309,38 @@ private TransactionAbortS

Re: [PR] [FLINK-37524] Make ForStState Restore from previous StateMetaInfo [flink]

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

[PR] Adding Elasticsearch Connector v4.0.0 [flink-web]

2025-04-02 Thread via GitHub
reswqa opened a new pull request, #786: URL: https://github.com/apache/flink-web/pull/786 (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 unsubscribe, e-mai

Re: [PR] [FLINK-37604] Generate static UIDs for pipeline operators [flink-cdc]

2025-04-02 Thread via GitHub
yuxiqian commented on PR #3977: URL: https://github.com/apache/flink-cdc/pull/3977#issuecomment-2774458157 It seems we already have the pipeline option `schema.operator.uid` to configure UID, but only for Schema Operators. So maybe the description of `operator.uid.prefix` isn't precise as i

[jira] [Commented] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint

2025-04-02 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940537#comment-17940537 ] Yue Ma commented on FLINK-37524: [https://github.com/apache/flink/pull/26391]    [~Yanfe

[jira] [Updated] (FLINK-37521) Implement async state version of KeyedCoProcessOperator

2025-04-02 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-37521: --- Summary: Implement async state version of KeyedCoProcessOperator (was: Introduce CoStreamFlatMap wi

[jira] [Updated] (FLINK-37520) Implement async state version of CoStreamFlatMap

2025-04-02 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-37520: --- Summary: Implement async state version of CoStreamFlatMap (was: Introduce KeyedCoProcessOperator wi

[jira] [Resolved] (FLINK-37521) Implement async state version of KeyedCoProcessOperator

2025-04-02 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-37521. Assignee: Yanfei Lei Resolution: Resolved Merged into master via 4a0c2e40506558e877b6b4188ab

[PR] [FLINK-35117][Table SQL/Planner] Add commons-text to allowed classloader list [flink]

2025-04-02 Thread via GitHub
MartijnVisser opened a new pull request, #26390: URL: https://github.com/apache/flink/pull/26390 ## What is the purpose of the change * Add missing dependency to table classloader ## Brief change log * Add `commons-text` to the allowed classloader list ## Verifying

[jira] [Closed] (FLINK-37521) Implement async state version of KeyedCoProcessOperator

2025-04-02 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-37521. -- > Implement async state version of KeyedCoProcessOperator > --

[PR] [FLINK-37597] Use ResourceGuard to make sure snapshot quit before ForSt disposal [flink]

2025-04-02 Thread via GitHub
fredia opened a new pull request, #26392: URL: https://github.com/apache/flink/pull/26392 ## What is the purpose of the change - Use ResourceGuard to make sure snapshot quit before ForSt disposal - Enable ForSt in existing ITCases(Recover https://github.com/apache/flink/pul

Re: [PR] [FLINK-31301][planner] Add support of nested columns in column list o… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22363: URL: https://github.com/apache/flink/pull/22363#issuecomment-2774616477 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-37597) Use ResourceGuard to make sure snapshot quit before ForSt disposal

2025-04-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37597: --- Labels: pull-request-available (was: ) > Use ResourceGuard to make sure snapshot quit befor

Re: [PR] [FLINK-31301][planner] Add support of nested columns in column list o… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22363: [FLINK-31301][planner] Add support of nested columns in column list o… URL: https://github.com/apache/flink/pull/22363 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-28372][rpc] Migrate to Akka Artery [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22271: URL: https://github.com/apache/flink/pull/22271#issuecomment-2774616101 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][doc] fix typo in mysql db prompt [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22396: [hotfix][doc] fix typo in mysql db prompt URL: https://github.com/apache/flink/pull/22396 -- 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

Re: [PR] [FLINK-31344][planner] Support to update nested columns in update sta… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22378: [FLINK-31344][planner] Support to update nested columns in update sta… URL: https://github.com/apache/flink/pull/22378 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-28372][rpc] Migrate to Akka Artery [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22271: [FLINK-28372][rpc] Migrate to Akka Artery URL: https://github.com/apache/flink/pull/22271 -- 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

Re: [PR] [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8 [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22481: URL: https://github.com/apache/flink/pull/22481#issuecomment-2774617153 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-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator URL: https://github.com/apache/flink/pull/22495 -- This is an automated message from the Apache Gi

Re: [PR] [FLINK-31426][table] Upgrade the deprecated UniqueConstraint to the n… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22301: URL: https://github.com/apache/flink/pull/22301#issuecomment-2774616169 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-31320][table]Modify DATE_FORMAT system (built-in) function to accepts DATEs [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22353: URL: https://github.com/apache/flink/pull/22353#issuecomment-2774616413 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-31518][Runtime / REST] Fix StandaloneHaServices#getClusterRestEndpointLeaderRetreiver to return correct rest port [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22308: [FLINK-31518][Runtime / REST] Fix StandaloneHaServices#getClusterRestEndpointLeaderRetreiver to return correct rest port URL: https://github.com/apache/flink/pull/22308 -- This is an automated message from the Apache Git Service. To respond to

Re: [PR] [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8 [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22481: [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8 URL: https://github.com/apache/flink/pull/22481 -- 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-31426][table] Upgrade the deprecated UniqueConstraint to the n… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22301: [FLINK-31426][table] Upgrade the deprecated UniqueConstraint to the n… URL: https://github.com/apache/flink/pull/22301 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-31947] enable stdout for flink-console.sh [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22491: [FLINK-31947] enable stdout for flink-console.sh URL: https://github.com/apache/flink/pull/22491 -- 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 s

Re: [PR] [FLINK-31828][planner] Use the inner serializer for RawType when doin… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22455: URL: https://github.com/apache/flink/pull/22455#issuecomment-2774617009 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-31928][build] Upgrade okhttp3 to 4.11.0 [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22499: [FLINK-31928][build] Upgrade okhttp3 to 4.11.0 URL: https://github.com/apache/flink/pull/22499 -- 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 spe

Re: [PR] [FLINK-32044][table-api] Validate catalog name when listFunctions in FunctionCatalog [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22563: URL: https://github.com/apache/flink/pull/22563#issuecomment-2774617769 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-32006] Harden and speed up AsyncWaitOperatorTest#testProcessingTimeAlwaysTimeoutFunctionWithRetry [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22523: URL: https://github.com/apache/flink/pull/22523#issuecomment-2774617598 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-31689][flink-connector-files] Check expired file state before … [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22400: URL: https://github.com/apache/flink/pull/22400#issuecomment-2774616792 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-31875][filesystems] Override the flink-parent dependencyManagement definition for hadoop-common of OSS [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22439: [FLINK-31875][filesystems] Override the flink-parent dependencyManagement definition for hadoop-common of OSS URL: https://github.com/apache/flink/pull/22439 -- This is an automated message from the Apache Git Service. To respond to the message

Re: [PR] [FLINK-31828][planner] Use the inner serializer for RawType when doin… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22455: [FLINK-31828][planner] Use the inner serializer for RawType when doin… URL: https://github.com/apache/flink/pull/22455 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-31755][planner] Make SqlRowOperator to create row with PEEK_FIELDS_NO_EXPAND struct type [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22369: URL: https://github.com/apache/flink/pull/22369#issuecomment-2774616550 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-31344][planner] Support to update nested columns in update sta… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22378: URL: https://github.com/apache/flink/pull/22378#issuecomment-2774616620 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-30093][protobuf] Fix compile errors for google.protobuf.Timestamp type [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22752: [FLINK-30093][protobuf] Fix compile errors for google.protobuf.Timestamp type URL: https://github.com/apache/flink/pull/22752 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] Updating docs on how to upgrade kafka connectors [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22575: URL: https://github.com/apache/flink/pull/22575#issuecomment-2774617825 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-32122] Update the Azure Blob Storage document to assist in configuring the MSI provider with a shaded class name [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22602: [FLINK-32122] Update the Azure Blob Storage document to assist in configuring the MSI provider with a shaded class name URL: https://github.com/apache/flink/pull/22602 -- This is an automated message from the Apache Git Service. To respond to t

Re: [PR] Updating docs on how to upgrade kafka connectors [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22575: Updating docs on how to upgrade kafka connectors URL: https://github.com/apache/flink/pull/22575 -- 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 s

Re: [PR] [FLINK-32188][Table SQL / Planner] Support to "where" query and simplify condition for an array-type filed of temporary table. [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22719: URL: https://github.com/apache/flink/pull/22719#issuecomment-2774618562 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-32188][Table SQL / Planner] Support to "where" query and simplify condition for an array-type filed of temporary table. [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22719: [FLINK-32188][Table SQL / Planner] Support to "where" query and simplify condition for an array-type filed of temporary table. URL: https://github.com/apache/flink/pull/22719 -- This is an automated message from the Apache Git Service. To respo

Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22745: URL: https://github.com/apache/flink/pull/22745#issuecomment-2774618606 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-32159] AbstractColumnReader throws NPE [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22702: URL: https://github.com/apache/flink/pull/22702#issuecomment-2774618483 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] KafkaSource: disable setting client id prefix if client.id is set [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22662: URL: https://github.com/apache/flink/pull/22662#issuecomment-2774618197 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-32203] Remove monitoringInterval to reduce probability of ClassLoader memory leak [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22664: [FLINK-32203] Remove monitoringInterval to reduce probability of ClassLoader memory leak URL: https://github.com/apache/flink/pull/22664 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

Re: [PR] [FLINK-23190][runtime] Make schedulers allocate slots more evenly [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22592: [FLINK-23190][runtime] Make schedulers allocate slots more evenly URL: https://github.com/apache/flink/pull/22592 -- 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

Re: [PR] [FLINK-24696][docs-zh]Translate how to configure unaligned checkpoints into Chinese [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22582: URL: https://github.com/apache/flink/pull/22582#issuecomment-2774617904 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] [WIP] Don't merge, just for CI test [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22880: URL: https://github.com/apache/flink/pull/22880#issuecomment-2774619412 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-32454] deserializeStreamStateHandle of checkpoint read byte in… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22886: [FLINK-32454] deserializeStreamStateHandle of checkpoint read byte in… URL: https://github.com/apache/flink/pull/22886 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [hotfix] Fix typo in setMaxParallelism() when create iteration sink [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22796: URL: https://github.com/apache/flink/pull/22796#issuecomment-2774618954 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-32263]-table-Add-ELT-function [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22853: URL: https://github.com/apache/flink/pull/22853#issuecomment-2774619101 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-32253][runtime] Update pending resource requests on nodes unblocked. [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22870: URL: https://github.com/apache/flink/pull/22870#issuecomment-2774619258 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-32454] deserializeStreamStateHandle of checkpoint read byte in… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22886: URL: https://github.com/apache/flink/pull/22886#issuecomment-2774619475 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-31875][filesystems] Override the flink-parent dependencyManagement definition for hadoop-common of OSS [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22439: URL: https://github.com/apache/flink/pull/22439#issuecomment-2774616942 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-32264][table] Add-built-in FIELD-function. [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22849: URL: https://github.com/apache/flink/pull/22849#issuecomment-2774619030 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-32305] [History Server] Add number of workers to parallelize job archive processing [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22754: [FLINK-32305] [History Server] Add number of workers to parallelize job archive processing URL: https://github.com/apache/flink/pull/22754 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

Re: [PR] [hotfix] Fix typo in setMaxParallelism() when create iteration sink [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22796: [hotfix] Fix typo in setMaxParallelism() when create iteration sink URL: https://github.com/apache/flink/pull/22796 -- 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] [WIP] Don't merge, just for CI test [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22880: [WIP] Don't merge, just for CI test URL: https://github.com/apache/flink/pull/22880 -- 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 comme

Re: [PR] [FLINK-31883] Using the unboxed types that prevent nullability issues [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22456: [FLINK-31883] Using the unboxed types that prevent nullability issues URL: https://github.com/apache/flink/pull/22456 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-32216][table-planner] Delete the redundant else statement in SetOperationParseStrategy [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22676: URL: https://github.com/apache/flink/pull/22676#issuecomment-2774618413 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-32488][REST] Introduce separate configuration to control expiry of E… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22906: URL: https://github.com/apache/flink/pull/22906#issuecomment-2774619737 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-32264][table] Add-built-in FIELD-function. [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22849: [FLINK-32264][table] Add-built-in FIELD-function. URL: https://github.com/apache/flink/pull/22849 -- 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

Re: [PR] kafka.md Format adjustment [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22857: URL: https://github.com/apache/flink/pull/22857#issuecomment-2774619177 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-32488][REST] Introduce separate configuration to control expiry of E… [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #22906: [FLINK-32488][REST] Introduce separate configuration to control expiry of E… URL: https://github.com/apache/flink/pull/22906 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] [FLINK-32501][table-planner] Fix wrong plan of a proctime window aggregation generated due to incorrect cost evaluation [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22964: URL: https://github.com/apache/flink/pull/22964#issuecomment-2774620172 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-28171 enable add appProtocol via the configuration [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22936: URL: https://github.com/apache/flink/pull/22936#issuecomment-2774619956 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-31947] enable stdout for flink-console.sh [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #22491: URL: https://github.com/apache/flink/pull/22491#issuecomment-2774617228 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] fix(sec): upgrade com.google.guava:guava to 32.0.0-jre [flink]

2025-04-02 Thread via GitHub
github-actions[bot] commented on PR #23030: URL: https://github.com/apache/flink/pull/23030#issuecomment-2774621115 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-32627] Add support for dynamic time window function [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #23023: [FLINK-32627] Add support for dynamic time window function URL: https://github.com/apache/flink/pull/23023 -- 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

Re: [PR] Bump word-wrap from 1.2.3 to 1.2.4 in /flink-runtime-web/web-dashboard [flink]

2025-04-02 Thread via GitHub
github-actions[bot] closed pull request #23024: Bump word-wrap from 1.2.3 to 1.2.4 in /flink-runtime-web/web-dashboard URL: https://github.com/apache/flink/pull/23024 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-32508][metrics][prometheus] Add support for native counters an… [flink]

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