Re: [PR] [FLINK-37590][build] Add CI of python and add jdk11 to ensure compatibility. [flink-connector-kafka]

AHeise commented on PR #163: URL: https://github.com/apache/flink-connector-kafka/pull/163#issuecomment-2769558786 Sorry for unclean merge (rebase instead squash). Github showed me only 1 commit in this tab. -- This is an automated message from the Apache Git Service. To respond to the m

Re: [PR] [FLINK-28984][runtime] Fix the problem that FsCheckpointStateOutputStream is not being released normally [flink]

github-actions[bot] closed pull request #20689: [FLINK-28984][runtime] Fix the problem that FsCheckpointStateOutputStream is not being released normally URL: https://github.com/apache/flink/pull/20689 -- This is an automated message from the Apache Git Service. To respond to the message, plea

Re: [PR] [FLINK-28893][table] Add built-in conv function. [flink]

github-actions[bot] commented on PR #20746: URL: https://github.com/apache/flink/pull/20746#issuecomment-2768302883 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] [docs] Update gradle build script in the overview.md [flink]

github-actions[bot] closed pull request #20357: [hotfix] [docs] Update gradle build script in the overview.md URL: https://github.com/apache/flink/pull/20357 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above t

Re: [PR] [FLINK-37356] Recreate producer on error [flink-connector-kafka]

AHeise commented on code in PR #159: URL: https://github.com/apache/flink-connector-kafka/pull/159#discussion_r2022304362 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java: ## @@ -131,26 +131,33 @@ public void recycleByT

Re: [PR] [FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both outputs are idle [flink]

github-actions[bot] closed pull request #20832: [FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both outputs are idle URL: https://github.com/apache/flink/pull/20832 -- This is an automated message from the Apache Gi

Re: [PR] [FLINK-26203][Connectors / Pulsar][docs] Introduce Flink Pulsar SQL Connector [flink]

github-actions[bot] commented on PR #20886: URL: https://github.com/apache/flink/pull/20886#issuecomment-2768303914 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-33449][table]Support array_contains_seq function [flink]

davidradl commented on code in PR #23656: URL: https://github.com/apache/flink/pull/23656#discussion_r2022436903 ## docs/data/sql_functions.yml: ## @@ -658,6 +658,9 @@ collection: - sql: ARRAY_JOIN(array, delimiter[, nullReplacement]) table: array.arrayJoin(delimiter[, n

Re: [PR] [FLINK-28837][chinese-translation] Translate "Hybrid Source" page of … [flink]

github-actions[bot] commented on PR #20466: URL: https://github.com/apache/flink/pull/20466#issuecomment-2768300361 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-29339][runtime] JobMasterPartitionTracker returns future to avoid blocking main thread [flink]

github-actions[bot] closed pull request #20862: [FLINK-29339][runtime] JobMasterPartitionTracker returns future to avoid blocking main thread URL: https://github.com/apache/flink/pull/20862 -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

Re: [PR] [Flink]update some comments [flink]

github-actions[bot] closed pull request #21272: [Flink]update some comments URL: https://github.com/apache/flink/pull/21272 -- 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 u

[jira] [Updated] (FLINK-37590) Update the code of Python modules to adapt to Flink 2.0's pyFlink

[ https://issues.apache.org/jira/browse/FLINK-37590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37590: --- Labels: pull-request-available (was: ) > Update the code of Python modules to adapt to Flin

Re: [PR] [FLINK-20578] Allow for creation of empty arrays in Flink SQL query. [flink]

github-actions[bot] closed pull request #21156: [FLINK-20578] Allow for creation of empty arrays in Flink SQL query. URL: https://github.com/apache/flink/pull/21156 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[PR] [FLINK-37590][build] Add CI of python and add jdk11 to ensure compatibility. [flink-connector-kafka]

lvyanquan opened a new pull request, #163: URL: https://github.com/apache/flink-connector-kafka/pull/163 Add missing CI for python and jdk11 in https://github.com/apache/flink-connector-kafka/pull/140 -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022546637 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java: ## @@ -173,6 +173,12 @@ public final class FactoryUtil {

Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc]

JNSimba commented on PR #3767: URL: https://github.com/apache/flink-cdc/pull/3767#issuecomment-2768979218 > @JNSimba Could we provide this feature by `SupportsProjectionPushDown`? `debezium.column.include.list` and `debezium.column.exclude.list` is hard for users to understand and use. We c

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

flinkbot commented on PR #26382: URL: https://github.com/apache/flink/pull/26382#issuecomment-2768234322 ## CI report: * 8e59724aa9342a78a9b31d40eeb03ebfd6e0dec9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37590][build] Add CI of python and add jdk11 to ensure compatibility. [flink-connector-kafka]

AHeise commented on code in PR #163: URL: https://github.com/apache/flink-connector-kafka/pull/163#discussion_r2022895758 ## flink-python/pyflink/datastream/connectors/kafka.py: ## @@ -15,30 +15,24 @@ # See the License for the specific language governing permissions and # li

Re: [PR] [FLINK-37590][build] Add CI of python and add jdk11 to ensure compatibility. [flink-connector-kafka]

AHeise commented on code in PR #163: URL: https://github.com/apache/flink-connector-kafka/pull/163#discussion_r2022889546 ## flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java: ## @@ -66,8 +66,6 @@ import org.apache.flink.testutils.j

Re: [PR] [hotfix][docs] Update maven.md [flink]

github-actions[bot] commented on PR #20881: URL: https://github.com/apache/flink/pull/20881#issuecomment-2768303811 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-37151][runtime-web] Remove redundant testing dependencies and files [flink]

Laffery commented on PR #26383: URL: https://github.com/apache/flink/pull/26383#issuecomment-2768188636 This PR had been reviewed by @davidradl in #25997 -- 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-37583] Upgrade to Kafka 4.0.0 client. [flink-connector-kafka]

tomncooper commented on PR #161: URL: https://github.com/apache/flink-connector-kafka/pull/161#issuecomment-2769459080 I rebased after the merge of #138 and that restarted the CI. It seems that `KafkaWriterFaultToleranceITCase` is flaky as it passes locally with java 17 and 21 and h

Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]

csviri commented on PR #957: URL: https://github.com/apache/flink-kubernetes-operator/pull/957#issuecomment-2769206798 Would it be useful also to set also observedGeneration on the conditions, I believe it is in general a good practice. -- This is an automated message from the Apache Git

Re: Assistance Required: Issue with Savepoint Restore During Flink Upgrade (1.18.0 → 1.20.1)

Hi Jasvendra, In short 1.18 savepoint should be compatible from 1.20. We don't know such existing issue. Can you please come up with a bare minimal step-by-step or public repo where one can repro it easily? BR, G On Tue, Apr 1, 2025 at 2:37 PM jasvendra kumar wrote: > Dear Flink Community, >

Re: [PR] [FLINK-26358][Runtime / Coordination] Operator maxParallelism is lost during chaining [flink]

github-actions[bot] commented on PR #18926: URL: https://github.com/apache/flink/pull/18926#issuecomment-2765254141 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][docs] flink docs zh content fix [flink]

klion26 merged PR #26294: URL: https://github.com/apache/flink/pull/26294 -- 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: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]

lajith2006 commented on PR #957: URL: https://github.com/apache/flink-kubernetes-operator/pull/957#issuecomment-2768463731 As mentioned in the FLIP , we will have status.conditions, which holds the list of conditions that contains the status of Job transitions in each stage. When th

Re: [PR] [FLINK-37569] Add userKeySerializer in RegisteredKeyValueStateBackend V2 [flink]

Zakelly commented on code in PR #26364: URL: https://github.com/apache/flink/pull/26364#discussion_r2022324270 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackend.java: ## @@ -405,10 +424,11 @@ public S createState

Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc]

ruanhang1993 commented on code in PR #3916: URL: https://github.com/apache/flink-cdc/pull/3916#discussion_r2022315733 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-jdbc-parent/flink-cdc-pipeline-connector-jdbc-core/src/main/java/org/apache/flink/cdc/con

Re: [PR] [hotfix][docs] update create table syntax pseudo code [flink]

Sxnan merged PR #26384: URL: https://github.com/apache/flink/pull/26384 -- 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.apache.

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022521342 ## docs/content.zh/docs/dev/python/table/table_environment.md: ## @@ -199,6 +199,50 @@ TableEnvironment API {{< pythondoc file="pyflink.table.html#pyflink.t

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022522215 ## docs/content/docs/dev/python/table/table_environment.md: ## @@ -199,6 +199,61 @@ These APIs are used to create/remove Table API/SQL Tables and write queries:

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022520676 ## docs/content/docs/dev/python/table/table_environment.md: ## @@ -199,6 +199,61 @@ These APIs are used to create/remove Table API/SQL Tables and write queries:

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

lvyanquan commented on PR #3974: URL: https://github.com/apache/flink-cdc/pull/3974#issuecomment-2768774625 One issue here is that if users modify (delete, change type) columns in the original table (with the same name as transform), unexpected behavior may occur. I think we should sort

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022526540 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java: ## @@ -1212,6 +1297,44 @@ void createTemporarySystemFunction(

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022526540 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java: ## @@ -1212,6 +1297,44 @@ void createTemporarySystemFunction(

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022528177 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java: ## @@ -1212,6 +1297,44 @@ void createTemporarySystemFunction(

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022486807 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java: ## @@ -1122,6 +1178,35 @@ void createTemporarySystemFunction(

[jira] [Updated] (FLINK-37536) Improve SQL gateway documentation

[ https://issues.apache.org/jira/browse/FLINK-37536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37536: --- Labels: pull-request-available (was: ) > Improve SQL gateway documentation > -

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022535349 ## docs/content/docs/dev/python/table/table_environment.md: ## @@ -199,6 +199,61 @@ These APIs are used to create/remove Table API/SQL Tables and write queries:

[jira] [Created] (FLINK-37596) Close metric groups for finished splits

Efrat Levitan created FLINK-37596: - Summary: Close metric groups for finished splits Key: FLINK-37596 URL: https://issues.apache.org/jira/browse/FLINK-37596 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-37529) Add flink-cdc-commom to the package to all the incremental source framework

[ https://issues.apache.org/jira/browse/FLINK-37529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939941#comment-17939941 ] Hongshun Wang commented on FLINK-37529: --- Currently, flink-cdc-base dependends on f

[jira] [Updated] (FLINK-37529) Add flink-cdc-commom to the package to all the incremental source framework

[ https://issues.apache.org/jira/browse/FLINK-37529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-37529: -- Description: Currently, flink-cdc-base dependends on flink-cdc-common. Thus, all its children

[jira] (FLINK-37529) Add flink-cdc-commom to the package to all the incremental source framework

[ https://issues.apache.org/jira/browse/FLINK-37529 ] Hongshun Wang deleted comment on FLINK-37529: --- was (Author: JIRAUSER298968): Currently, flink-cdc-base dependends on flink-cdc-common. Thus, all its children module( such as flink-connecto

Re: [PR] [FLINK-37529][cdc-connector] Add flink-cdc-commo to the package to al… [flink-cdc]

loserwang1024 commented on PR #3962: URL: https://github.com/apache/flink-cdc/pull/3962#issuecomment-2768391321 @leonardBang @ruanhang1993 , CC. -- 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-19589][Filesystem][S3] Support per-connector FileSystem configuration [flink]

github-actions[bot] closed pull request #20367: [FLINK-19589][Filesystem][S3] Support per-connector FileSystem configuration URL: https://github.com/apache/flink/pull/20367 -- 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-36821] Update to Kafka 3.9.0 [flink-connector-kafka]

AHeise commented on PR #138: URL: https://github.com/apache/flink-connector-kafka/pull/138#issuecomment-2768488481 I'd prefer to have a release with 3.9 first. DataStream users are usually free to bump independent of this release anyways. -- This is an automated message from the Apache G

Re: [PR] fix version for supporting add file [flink]

github-actions[bot] commented on PR #20441: URL: https://github.com/apache/flink/pull/20441#issuecomment-2768300069 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][docs] update create table syntax pseudo code [flink]

Sxnan closed pull request #26355: [hotfix][docs] update create table syntax pseudo code URL: https://github.com/apache/flink/pull/26355 -- 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 c

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022486807 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java: ## @@ -1122,6 +1178,35 @@ void createTemporarySystemFunction(

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022493492 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -719,6 +750,32 @@ public boolean dropView(Strin

Re: [PR] [FLINK-29547][table] Fix the bug of Select a[1] which is array type for parquet complex type throw ClassCastException [flink]

github-actions[bot] commented on PR #20988: URL: https://github.com/apache/flink/pull/20988#issuecomment-2768304423 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-37484][cdc-connector] unevenly chunk split also enables unbounded-chunk-first.enabled. [flink-cdc]

loserwang1024 commented on PR #3954: URL: https://github.com/apache/flink-cdc/pull/3954#issuecomment-2768355162 Rebase this pr to master, @ruanhang1993 , CC -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

Re: [PR] [FLINK-29333][TABLE]Support the tableconfig object get configuration infos from flink-conf.yaml file [flink]

github-actions[bot] closed pull request #21011: [FLINK-29333][TABLE]Support the tableconfig object get configuration infos from flink-conf.yaml file URL: https://github.com/apache/flink/pull/21011 -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc]

yuxiqian commented on code in PR #3916: URL: https://github.com/apache/flink-cdc/pull/3916#discussion_r2022472467 ## flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java: ## @@ -205,7 +205,11 @@ private void translate(StreamExecutionEnv

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022473816 ## docs/content.zh/docs/dev/python/table/table_environment.md: ## @@ -199,6 +199,50 @@ TableEnvironment API {{< pythondoc file="pyflink.table.html#pyflink.t

Re: [PR] [FLINK-28825][k8s] Add K8S pod scheduler into Kubernetes options [flink]

github-actions[bot] commented on PR #20467: URL: https://github.com/apache/flink/pull/20467#issuecomment-2768300449 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-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022473816 ## docs/content.zh/docs/dev/python/table/table_environment.md: ## @@ -199,6 +199,50 @@ TableEnvironment API {{< pythondoc file="pyflink.table.html#pyflink.t

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022478102 ## docs/content.zh/docs/dev/python/table/table_environment.md: ## @@ -199,6 +199,50 @@ TableEnvironment API {{< pythondoc file="pyflink.table.html#pyflink.t

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022481127 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java: ## @@ -868,6 +868,62 @@ void createTemporarySystemFunction(

Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc]

yuxiqian commented on code in PR #3916: URL: https://github.com/apache/flink-cdc/pull/3916#discussion_r2022484480 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-jdbc-parent/flink-cdc-pipeline-connector-jdbc-core/src/main/java/org/apache/flink/cdc/connect

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022484221 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java: ## @@ -1122,6 +1178,35 @@ void createTemporarySystemFunction(

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022520676 ## docs/content/docs/dev/python/table/table_environment.md: ## @@ -199,6 +199,61 @@ These APIs are used to create/remove Table API/SQL Tables and write queries:

Re: [PR] [hotfix] Rename prefix to tag for FileChannelManagerImpl [flink]

beliefer commented on PR #26362: URL: https://github.com/apache/flink/pull/26362#issuecomment-2768933297 @davidradl Could you take a look again ? :-) -- 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

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022532895 ## docs/content/docs/dev/python/table/table_environment.md: ## @@ -795,6 +850,29 @@ These APIs are used to access catalogs and modules. You can find more detailed i

Re: [PR] [FLINK-27850][hive] HiveDialect supports add file [flink]

github-actions[bot] commented on PR #20284: URL: https://github.com/apache/flink/pull/20284#issuecomment-2768298910 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

[PR] [FLINK-37151][runtime-web] Remove redundant testing dependencies and files [flink]

Laffery opened a new pull request, #26383: URL: https://github.com/apache/flink/pull/26383 JIRA Ticket: [issues.apache.org/jira/browse/FLINK-37151](https://issues.apache.org/jira/browse/FLINK-37151) ## What is the purpose of the change Remove redundant testing dependencies and

Re: [PR] [FLINK-28984][runtime] Fix the problem that FsCheckpointStateOutputStream is not being released normally [flink]

github-actions[bot] commented on PR #20689: URL: https://github.com/apache/flink/pull/20689#issuecomment-2768302343 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-28515][checkpoint]Try to clean up localSnapshot files after checkpoint aborted [flink]

github-actions[bot] closed pull request #20249: [FLINK-28515][checkpoint]Try to clean up localSnapshot files after checkpoint aborted URL: https://github.com/apache/flink/pull/20249 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-37590][build] Add CI of python and add jdk11 to ensure compatibility. [flink-connector-kafka]

AHeise commented on PR #163: URL: https://github.com/apache/flink-connector-kafka/pull/163#issuecomment-2768987393 I think we previously ran python just against one java version. I'm fine with running it against 3 versions but just wanted to make sure it's a conscious decision. -- This

Re: [PR] [WIP][FLINK-28838] Avoid to notify the elementQueue consumer when the fetc… [flink]

github-actions[bot] closed pull request #20639: [WIP][FLINK-28838] Avoid to notify the elementQueue consumer when the fetc… URL: https://github.com/apache/flink/pull/20639 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] [FLINK-31606][docs-zh] Translate 'sqlClient.md' pages into chinese [flink]

github-actions[bot] commented on PR #22264: URL: https://github.com/apache/flink/pull/22264#issuecomment-2768307515 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] [Commented] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-34992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939864#comment-17939864 ] Shengkai Fang commented on FLINK-34992: --- [~lihaosky] Do you have plan to finish th

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022514025 ## flink-python/pyflink/table/model_descriptor.py: ## @@ -0,0 +1,140 @@ + +# Licensed

[jira] [Resolved] (FLINK-37472) flink zh docs bugfix

[ https://issues.apache.org/jira/browse/FLINK-37472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu resolved FLINK-37472. -- Resolution: Implemented > flink zh docs bugfix > > > Key:

[jira] [Created] (FLINK-37598) Support ListView and MapView in PTFs

Timo Walther created FLINK-37598: Summary: Support ListView and MapView in PTFs Key: FLINK-37598 URL: https://issues.apache.org/jira/browse/FLINK-37598 Project: Flink Issue Type: Sub-task

Re: [PR] [FLINK-37484][cdc-connector] unevenly chunk split also enables unbounded-chunk-first.enabled. [flink-cdc]

loserwang1024 commented on code in PR #3954: URL: https://github.com/apache/flink-cdc/pull/3954#discussion_r2022252129 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceITCase.java: ##

Re: [PR] [FLINK-19059]: Add NonTimeRangeUnboundedPrecedingFunction for OverAggregate [flink]

twalthr merged PR #25753: URL: https://github.com/apache/flink/pull/25753 -- 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

[jira] [Closed] (FLINK-19059) Support to consume retractions for OVER WINDOW operator

[ https://issues.apache.org/jira/browse/FLINK-19059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-19059. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: e06fddc95541cb10df1b605087acc4b4925

[jira] [Resolved] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest

[ https://issues.apache.org/jira/browse/FLINK-37356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-37356. - Fix Version/s: kafka-4.0.0 Resolution: Fixed Merged into main as ad3ef745153b6f58bf4a548

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

davidradl commented on code in PR #26385: URL: https://github.com/apache/flink/pull/26385#discussion_r2022542816 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java: ## @@ -1647,6 +1675,8 @@ private void execute(

Re: [PR] Add GraalSystems [flink]

github-actions[bot] closed pull request #21054: Add GraalSystems URL: https://github.com/apache/flink/pull/21054 -- 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,

Re: [PR] [FLINK-28643][runtime-web] HistoryServer support lazy unzip [flink]

github-actions[bot] closed pull request #21185: [FLINK-28643][runtime-web] HistoryServer support lazy unzip URL: https://github.com/apache/flink/pull/21185 -- 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] Update datastream_tutorial.md [flink]

github-actions[bot] closed pull request #21043: Update datastream_tutorial.md URL: https://github.com/apache/flink/pull/21043 -- 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] [FLINK-28575] [connectors/hbase] support hbase connector 2.2 write to 2.4.9 [flink]

github-actions[bot] commented on PR #20288: URL: https://github.com/apache/flink/pull/20288#issuecomment-2768299010 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-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.13. [flink]

github-actions[bot] commented on PR #20681: URL: https://github.com/apache/flink/pull/20681#issuecomment-2768301911 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-27291][docs-zh] Translate the "List of Data Types" section of "Data Types" into Chinese' [flink]

github-actions[bot] commented on PR #20724: URL: https://github.com/apache/flink/pull/20724#issuecomment-2768302826 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-28697][table] MapDataSerializer doesn't declare a serialVersionUID [flink]

github-actions[bot] closed pull request #20369: [FLINK-28697][table] MapDataSerializer doesn't declare a serialVersionUID URL: https://github.com/apache/flink/pull/20369 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Assigned] (FLINK-37597) Use ResourceGuard to make sure snapshot quit before ForSt dispose

[ https://issues.apache.org/jira/browse/FLINK-37597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-37597: --- Assignee: Yanfei Lei (was: Zakelly Lan) > Use ResourceGuard to make sure snapshot quit bef

[jira] [Created] (FLINK-37597) Use ResourceGuard to make sure snapshot quit before ForSt dispose

Zakelly Lan created FLINK-37597: --- Summary: Use ResourceGuard to make sure snapshot quit before ForSt dispose Key: FLINK-37597 URL: https://issues.apache.org/jira/browse/FLINK-37597 Project: Flink

[jira] [Assigned] (FLINK-37596) Close metric groups for finished splits

[ https://issues.apache.org/jira/browse/FLINK-37596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37596: -- Assignee: Efrat Levitan > Close metric groups for finished splits > -

Re: [PR] [hotfix][docs] flink docs zh content fix [flink]

klion26 commented on PR #26294: URL: https://github.com/apache/flink/pull/26294#issuecomment-2768304934 There is no more comments here, merging it. -- 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-26945][table] Add built-in DATE_SUB function. [flink]

github-actions[bot] commented on PR #22250: URL: https://github.com/apache/flink/pull/22250#issuecomment-2768307355 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

[PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

yanand0909 opened a new pull request, #26385: URL: https://github.com/apache/flink/pull/26385 ## What is the purpose of the change Adding model DDL support to the Table API, enabling a seamless development experience where users can define, manage, and utilize ML models entire

Re: [PR] [FLINK-37508][cdc-connector][postgres] Postgres CDC Jdbc query should… [flink-cdc]

loserwang1024 commented on PR #3963: URL: https://github.com/apache/flink-cdc/pull/3963#issuecomment-2768405542 Add test waiting for https://github.com/apache/flink-cdc/pull/3964 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-24943][Connectors / Kinesis] Explicitly create KryoSerializer for SequenceNumber class in Kinesis Consumer [flink]

github-actions[bot] closed pull request #20257: [FLINK-24943][Connectors / Kinesis] Explicitly create KryoSerializer for SequenceNumber class in Kinesis Consumer URL: https://github.com/apache/flink/pull/20257 -- This is an automated message from the Apache Git Service. To respond to the mes

Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]

flinkbot commented on PR #26385: URL: https://github.com/apache/flink/pull/26385#issuecomment-2768421931 ## CI report: * d14529518f7431bcdd8106938a8c5df59caff991 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-37597) Use ResourceGuard to make sure snapshot quit before ForSt disposal

[ https://issues.apache.org/jira/browse/FLINK-37597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37597: Summary: Use ResourceGuard to make sure snapshot quit before ForSt disposal (was: Use ResourceGua

Re: [PR] [FLINK-37332] Support any column as chunk key column (postgres, orcale, db2, sqlserver) #3922 [flink-cdc]

SML0127 commented on PR #3928: URL: https://github.com/apache/flink-cdc/pull/3928#issuecomment-2768325181 Even based on the recent commit of the master branch, below error occasionally occurs on my mac🥲 https://github.com/user-attachments/assets/e2c63405-c265-4c7a-ae94-31c4828e0549";

[jira] [Updated] (FLINK-37380) Change TransactionalIdPrefix to a required option if Exactly once in Kafka Connector

[ https://issues.apache.org/jira/browse/FLINK-37380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-37380: Release Note: The transactional id prefix is now mandatory for all exactly once KafkaSinks. > Cha

  1   2   3   >