Re: [PR] Added Confluent to Vendor Solutions section [flink]

2025-07-24 Thread via GitHub
github-actions[bot] closed pull request #26346: Added Confluent to Vendor Solutions section URL: https://github.com/apache/flink/pull/26346 -- 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] Added Confluent to Vendor Solutions section [flink]

2025-07-24 Thread via GitHub
github-actions[bot] commented on PR #26346: URL: https://github.com/apache/flink/pull/26346#issuecomment-3116561601 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-36986][table] Migrate SplitRemoteConditionFromJoinRule to java [flink]

2025-07-24 Thread via GitHub
github-actions[bot] closed pull request #25881: [FLINK-36986][table] Migrate SplitRemoteConditionFromJoinRule to java URL: https://github.com/apache/flink/pull/25881 -- 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-34015][checkpoint] fix that passing ignore-unclaimed-state through dynamic props does not take effect [flink]

2025-07-24 Thread via GitHub
github-actions[bot] commented on PR #24058: URL: https://github.com/apache/flink/pull/24058#issuecomment-3116561408 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-38139] Fix consecutive online schema change causes job failure. [flink-cdc]

2025-07-24 Thread via GitHub
yuxiqian commented on code in PR #4064: URL: https://github.com/apache/flink-cdc/pull/4064#discussion_r2227380966 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java: ## @@ -

[jira] [Updated] (FLINK-38134) Cannot recognize DropColumnEvent in method SchemaMergingUtils.getSchemaDifference.

2025-07-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38134: --- Labels: pull-request-available (was: ) > Cannot recognize DropColumnEvent in method > Sche

[PR] [FLINK-38134][cdc-common] Cannot recognize DropColumnEvent in method … [flink-cdc]

2025-07-24 Thread via GitHub
tbpure opened a new pull request, #4065: URL: https://github.com/apache/flink-cdc/pull/4065 This commit adds support for handling DropColumnEvent in the getSchemaDifference method, enabling schema evolution logic to correctly detect and process dropped columns. -- This is an automate

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

2025-07-24 Thread via GitHub
lsyldliu commented on code in PR #800: URL: https://github.com/apache/flink-web/pull/800#discussion_r2230097750 ## docs/content/posts/2025-07-31-release-2.1.0.md: ## @@ -0,0 +1,458 @@ +--- +authors: + - reswqa: +name: "Ron Liu" +twitter: "Ron999" + +date: "2025-07-31T08

Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink]

2025-07-24 Thread via GitHub
AlanConfluent commented on PR #26611: URL: https://github.com/apache/flink/pull/26611#issuecomment-3115423805 Thanks for all of the comments @davidradl. I held off on updating this until my actual functionality PR was merged, which it was, so I've gotten back to this. Please take another

Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink]

2025-07-24 Thread via GitHub
AlanConfluent commented on PR #26611: URL: https://github.com/apache/flink/pull/26611#issuecomment-3115407076 I also have https://github.com/apache/flink/pull/26610 which does some of the same but for scalar. I also want to make sure I don't have overly redundant wording between the two.

Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink]

2025-07-24 Thread via GitHub
AlanConfluent commented on code in PR #26611: URL: https://github.com/apache/flink/pull/26611#discussion_r2229844513 ## docs/content/docs/dev/table/functions/udfs.md: ## @@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python, please refer to the [Pyt

Re: [PR] [FLINK-37216] Default MAX_BATCH_SIZE_IN_BYTES should be greater than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions. [flink-cdc]

2025-07-24 Thread via GitHub
github-actions[bot] closed pull request #3891: [FLINK-37216] Default MAX_BATCH_SIZE_IN_BYTES should be greater than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions. URL: https://github.com/apache/flink-cdc/pull/3891 -- This is an automated message from the Apache Git Service. To re

Re: [PR] [FLINK-37216] Default MAX_BATCH_SIZE_IN_BYTES should be greater than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions. [flink-cdc]

2025-07-24 Thread via GitHub
github-actions[bot] commented on PR #3891: URL: https://github.com/apache/flink-cdc/pull/3891#issuecomment-3115369475 This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encou

Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink]

2025-07-24 Thread via GitHub
AlanConfluent commented on PR #26610: URL: https://github.com/apache/flink/pull/26610#issuecomment-3115325927 I have put in placeholders in English on the udf page in Chinese, as I have seen for PTFs. Hopefully this is fine until there is a translation made. -- This is an automated messa

Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink]

2025-07-24 Thread via GitHub
AlanConfluent commented on code in PR #26610: URL: https://github.com/apache/flink/pull/26610#discussion_r2229792104 ## docs/content/docs/dev/table/functions/udfs.md: ## @@ -1017,6 +1018,139 @@ If you intend to implement or call functions in Python, please refer to the [Pyt

Re: [PR] [FLINK-35546] Elasticsearch 8 connector fails fast for non-retryable bulk request items [flink-connector-elasticsearch]

2025-07-24 Thread via GitHub
liuml07 commented on PR #107: URL: https://github.com/apache/flink-connector-elasticsearch/pull/107#issuecomment-3115120510 @reswqa and @vahmed-hamdy Could you take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

Re: [PR] [FLINK-38140] Changes AsyncScalarFunction config from buffer-capacity to max-concurrent-operations [flink]

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

[PR] [FLINK-38140] Changes AsyncScalarFunction config from buffer-capacity to max-concurrent-operations [flink]

2025-07-24 Thread via GitHub
AlanConfluent opened a new pull request, #26830: URL: https://github.com/apache/flink/pull/26830 ## What is the purpose of the change Changes config name `table.exec.async-scalar.buffer-capacity` to `table.exec.async-scalar.max-concurrent-operations`. Uses `withDeprecated

[jira] [Updated] (FLINK-38140) Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations

2025-07-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38140: --- Labels: pull-request-available (was: ) > Change name from table.exec.async-scalar.buffer-ca

[jira] [Created] (FLINK-38140) Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations

2025-07-24 Thread Alan Sheinberg (Jira)
Alan Sheinberg created FLINK-38140: -- Summary: Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations Key: FLINK-38140 URL: https://issues.apache.org/jira/browse/FLINK-38140

Re: [PR] [FLINK-38093][k8s] Bump Fabric8 version to 7.3.1 [flink]

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

[jira] [Updated] (FLINK-38093) Update version of Fabric8 to 7.3.1

2025-07-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38093: --- Labels: pull-request-available (was: ) > Update version of Fabric8 to 7.3.1 > -

[PR] [FLINK-38093][k8s] Bump Fabric8 version to 7.3.1 [flink]

2025-07-24 Thread via GitHub
mateczagany opened a new pull request, #26829: URL: https://github.com/apache/flink/pull/26829 ## What is the purpose of the change Upgrade Fabric8 Kubernetes client to 7.3.1, which is the latest version as of creating this PR. The new version has changed the default HTTP clie

[PR] Feature migrate to flink 2.0.0 [flink-training]

2025-07-24 Thread via GitHub
XenoAmess opened a new pull request, #89: URL: https://github.com/apache/flink-training/pull/89 (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,

[PR] [api][python] Introduce Prompt, Tool and ChatModel in python [flink-agents]

2025-07-24 Thread via GitHub
wenjin272 opened a new pull request, #81: URL: https://github.com/apache/flink-agents/pull/81 Linked issue: #76 ### Purpose of change Introduce Prompt, Tool and ChatModel in python ### Tests unit tests ### API Yes, add Prompt, Tool and ChatModel api.

[PR] [WIP][API][Runtime] Support agent and action asynchronous execution [flink-agents]

2025-07-24 Thread via GitHub
codenohup opened a new pull request, #80: URL: https://github.com/apache/flink-agents/pull/80 Linked issue: #78 ### Purpose of change Enable the agent and action to support asynchronous and parallel processing for improved performance. Details can be found in the #78 .

Re: [PR] [FLINK-37583] Upgrade to Kafka 4.0.0 client. [flink-connector-kafka]

2025-07-24 Thread via GitHub
tomncooper commented on PR #161: URL: https://github.com/apache/flink-connector-kafka/pull/161#issuecomment-3113020885 @fapaul I squashed and rebased. However, before we merge this I think it would be good to do a Kafka connector 4.1 release with the 3.9.1 client. That way if there

Re: [PR] [FLINK-37914][table] Add built-in OBJECT_UPDATE function [flink]

2025-07-24 Thread via GitHub
twalthr commented on code in PR #26806: URL: https://github.com/apache/flink/pull/26806#discussion_r2227818783 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ObjectUpdateInputTypeStrategy.java: ## @@ -0,0 +1,198 @@ +/* + * Licen

Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra]

2025-07-24 Thread via GitHub
echauchot commented on PR #35: URL: https://github.com/apache/flink-connector-cassandra/pull/35#issuecomment-3112953358 please rebase on main as there were merged changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Resolved] (FLINK-38034) raise back the visibility of WriteAheadSinkTestBase to public

2025-07-24 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot resolved FLINK-38034. -- Fix Version/s: cassandra-3.3.0 Resolution: Fixed commit merged in main: dbb4ceb

Re: [PR] [FLINK-38034] Added WriteAheadSinkTestBase to Cassandra Connector Repository [flink-connector-cassandra]

2025-07-24 Thread via GitHub
boring-cyborg[bot] commented on PR #36: URL: https://github.com/apache/flink-connector-cassandra/pull/36#issuecomment-3112694641 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [FLINK-38034] Added WriteAheadSinkTestBase to Cassandra Connector Repository [flink-connector-cassandra]

2025-07-24 Thread via GitHub
echauchot merged PR #36: URL: https://github.com/apache/flink-connector-cassandra/pull/36 -- 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-unsubsc

Re: [PR] [FLINK-38034] Added WriteAheadSinkTestBase to Cassandra Connector Repository [flink-connector-cassandra]

2025-07-24 Thread via GitHub
Poorvankbhatia commented on PR #36: URL: https://github.com/apache/flink-connector-cassandra/pull/36#issuecomment-3112637910 Rebased from the main branch and squashed to the first commit. @echauchot -- This is an automated message from the Apache Git Service. To respond to the message, p

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

2025-07-24 Thread via GitHub
lincoln-lil commented on code in PR #800: URL: https://github.com/apache/flink-web/pull/800#discussion_r2227626623 ## docs/content/posts/2025-07-31-release-2.1.0.md: ## @@ -0,0 +1,458 @@ +--- +authors: + - reswqa: +name: "Ron Liu" +twitter: "Ron999" + +date: "2025-07-31

[jira] [Assigned] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1.

2025-07-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-38123: -- Assignee: Andrei Kaigorodov > The autoscaling example image is based on Flink 1.18 rather tha

[PR] [hotfix] Format code using tools/lint.sh [flink-agents]

2025-07-24 Thread via GitHub
codenohup opened a new pull request, #79: URL: https://github.com/apache/flink-agents/pull/79 Linked issue: #xxx ### Purpose of change Format code using tools/lint.sh ### Tests Code style/formatting changes only — no additional testing is required.