issues@flink.apache.org, 2025-06

You are viewing a plain text version of this content. The canonical link for it is here.

- Re: [PR] [FLINK-36442][postgres-cdc] Add insert-only change stream option [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/01 00:06:06 UTC, 1 replies.
- Re: [PR] [FLINK-37791][6/N] model sql to rel converter [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/01 05:10:54 UTC, 2 replies.
- [PR] FLINK-37881: Drop gosu in favour of Dockerfile USER [flink-docker] - posted by "avi-sanwal (via GitHub)" <gi...@apache.org> on 2025/06/01 06:23:51 UTC, 0 replies.
- [jira] [Updated] (FLINK-37881) Drop gosu in favour of Dockerfile's USER - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/01 06:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-25521][docs] Fix the composition description of 'INTERVAL DAY TO SECOND' in the data type [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/01 06:25:23 UTC, 1 replies.
- Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/01 06:25:31 UTC, 0 replies.
- Re: [PR] [FLINK-37851][state] Migrate state processor API from source API v1 to source API v2 [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/06/01 09:57:42 UTC, 21 replies.
- [jira] [Commented] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry - posted by "Bjarke Tornager (Jira)" <ji...@apache.org> on 2025/06/01 13:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/06/01 18:09:29 UTC, 6 replies.
- Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] - posted by "lajith2006 (via GitHub)" <gi...@apache.org> on 2025/06/01 19:11:34 UTC, 4 replies.
- [jira] [Created] (FLINK-37882) Add tests for queries where LITERAL_AGG will appear after upgrade to Calcite 1.35 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/01 22:44:00 UTC, 0 replies.
- [PR] [FLINK-37882][table] Add tests for queries where LITERAL_AGG will appear after upgrade to Calcite 1.35 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/01 22:47:23 UTC, 3 replies.
- [jira] [Updated] (FLINK-37882) Add tests for queries where LITERAL_AGG will appear after upgrade to Calcite 1.35 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/01 22:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-37724] Adds AsyncTableFunction as a fully supported UDF type [flink] - posted by "becketqin (via GitHub)" <gi...@apache.org> on 2025/06/02 02:19:33 UTC, 30 replies.
- [jira] [Commented] (FLINK-37811) Flink Job stuck in suspend state after losing leadership in Zookeeper HA - posted by "Arun Lakshman (Jira)" <ji...@apache.org> on 2025/06/02 05:42:00 UTC, 0 replies.
- [PR] [FLINK-37811][Build/Shaded] Update Curator to 5.4.0 [flink-shaded] - posted by "arunlakshman (via GitHub)" <gi...@apache.org> on 2025/06/02 05:45:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-37811) Flink Job stuck in suspend state after losing leadership in Zookeeper HA - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/02 05:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [2.0] [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/06/02 07:02:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37856) Sink option hints are not present in compiled plan - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/06/02 07:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37856) Sink option hints are not present in compiled plan - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/06/02 07:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-37870][checkpoint] Fix the bug that unaligned checkpoint is disabled for all connections unexpectedly [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/06/02 07:10:30 UTC, 15 replies.
- Re: [PR] [FLINK-37730] Improve exception recording ts initialization + 2.0 compatibility [flink-kubernetes-operator] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/06/02 07:33:52 UTC, 2 replies.
- [jira] [Created] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/02 07:34:00 UTC, 0 replies.
- Re: [PR] Plugin for custom evaluator for scaling metric evaluation [flink-kubernetes-operator] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/06/02 07:36:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/02 07:39:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37879) transform concat function don't support utf-8 and cast don't support STRING - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2025/06/02 08:06:00 UTC, 0 replies.
- Re: [PR] Upgrade to JOSDK 5.1 [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/06/02 09:15:29 UTC, 2 replies.
- [jira] [Commented] (FLINK-37882) Add tests for queries where LITERAL_AGG will appear after upgrade to Calcite 1.35 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/02 10:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37882) Add tests for queries where LITERAL_AGG will appear after upgrade to Calcite 1.35 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/02 10:46:00 UTC, 0 replies.
- [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] - posted by "Sukang1002 (via GitHub)" <gi...@apache.org> on 2025/06/02 11:09:07 UTC, 2 replies.
- Re: [PR] [FLINK-37096][cdc-connect] fix The purpose of the issue is to change the value of the delay curve from 20098d to -1ms in the full phase. [flink-cdc] - posted by "Sukang1002 (via GitHub)" <gi...@apache.org> on 2025/06/02 11:32:14 UTC, 0 replies.
- [PR] [FLINK-37096][cdc-connect] fix The purpose of the issue is to change the value of the delay curve from 20098d to -1ms in the full phase. [flink-cdc] - posted by "Sukang1002 (via GitHub)" <gi...@apache.org> on 2025/06/02 11:39:43 UTC, 2 replies.
- Re: [PR] [FLINK-33045][format avro-confluent] disable auto-registering schema in registry [flink] - posted by "HenkvanDyk (via GitHub)" <gi...@apache.org> on 2025/06/02 12:27:01 UTC, 5 replies.
- Re: [PR] [FLIP-516][FLINK-37481] Add new multi way join operator [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/06/02 12:41:56 UTC, 6 replies.
- [jira] [Closed] (FLINK-37481) FLIP-516: Multi way join operator - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/06/02 12:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/06/02 13:00:27 UTC, 21 replies.
- Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] - posted by "uce (via GitHub)" <gi...@apache.org> on 2025/06/02 13:11:28 UTC, 2 replies.
- [PR] [hotfix] [docs] Fix broken link to data-type-mapping section [flink] - posted by "martyav (via GitHub)" <gi...@apache.org> on 2025/06/02 19:17:45 UTC, 4 replies.
- Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] - posted by "Biasqo (via GitHub)" <gi...@apache.org> on 2025/06/02 19:50:21 UTC, 9 replies.
- Re: [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/02 21:57:36 UTC, 1 replies.
- [PR] Model run [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/03 01:52:51 UTC, 2 replies.
- Re: [PR] [hotfix] Fix invalid comments in Committer [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/06/03 02:20:55 UTC, 0 replies.
- Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc] - posted by "yzeng1618 (via GitHub)" <gi...@apache.org> on 2025/06/03 02:47:17 UTC, 0 replies.
- Re: [PR] [FLINK-37855-][cdc-connector-mysql] Reduce the time cost in MySqlSchemaUtils#listTables [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/06/03 02:53:48 UTC, 2 replies.
- Re: [PR] [FLINK-37634][pipeline-connector/mysql]When the table name of mysql s… [flink-cdc] - posted by "linjianchang (via GitHub)" <gi...@apache.org> on 2025/06/03 03:31:23 UTC, 2 replies.
- [jira] [Commented] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability. - posted by "Matt Cuento (Jira)" <ji...@apache.org> on 2025/06/03 03:52:00 UTC, 0 replies.
- Re: [PR] [FLINK-37875][table] Introduce key ordered async lookup join in planner [flink] - posted by "xishuaidelin (via GitHub)" <gi...@apache.org> on 2025/06/03 05:49:09 UTC, 19 replies.
- Re: [PR] Bump org.apache.hive:hive-exec from 2.3.10 to 4.0.1 in /flink-connectors/flink-sql-connector-hive-2.3.10 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/03 06:25:45 UTC, 0 replies.
- Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/03 06:25:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/03 06:34:00 UTC, 11 replies.
- [jira] [Updated] (FLINK-37870) Unaligned checkpoint is disabled for all connections unexpectedly - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/06/03 09:45:00 UTC, 3 replies.
- [jira] [Created] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/03 09:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/03 09:47:00 UTC, 0 replies.
- [PR] [FLINK-37884][tests] Re-generate violations for CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/06/03 10:07:42 UTC, 5 replies.
- [jira] [Updated] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/03 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37885) Update Flink Operator to Java Operator Version 5.1.1 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/06/03 10:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-37885] Upgrade to JOSDK 5.1 [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/06/03 11:48:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-37885) Update Flink Operator to Java Operator Version 5.1.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/03 11:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37885) Update Flink Operator to Java Operator Version 5.1.1 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/06/03 11:51:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37886) Introduce the ITCase to check whether unaligned checkpoint works well for jobs with sink writer and committer - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/03 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37886) Introduce the ITCase to check whether unaligned checkpoint works well for jobs with sink writer and committer - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/03 12:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37870) Unaligned checkpoint is disabled for all connections unexpectedly - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/03 12:10:00 UTC, 0 replies.
- [PR] [FLINK-37814][table-planner] Add FlinkRightJoinToLeftJoinRule [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2025/06/03 12:52:42 UTC, 18 replies.
- [jira] [Updated] (FLINK-37814) FLIP-516: Add RIGHT JOIN to LEFT JOIN rule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/03 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37887) Watched namespaces not picked up automatically by the operator - posted by "Igor Milavec (Jira)" <ji...@apache.org> on 2025/06/03 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37888) Flink CDC data format conversion error when writing to Iceberg - posted by "r0y4d3v (Jira)" <ji...@apache.org> on 2025/06/03 13:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37888) Flink CDC data format conversion error when writing to Iceberg - posted by "r0y4d3v (Jira)" <ji...@apache.org> on 2025/06/03 14:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37888) Flink CDC data format conversion error when writing to Iceberg - posted by "r0y4d3v (Jira)" <ji...@apache.org> on 2025/06/03 14:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese - posted by "wangzhe (Jira)" <ji...@apache.org> on 2025/06/03 14:19:00 UTC, 0 replies.
- Re: [PR] [FLINK-20625] Implement V2 Google Cloud PubSub Source in accordance with FLIP-27 [flink-connector-gcp-pubsub] - posted by "rob-apella (via GitHub)" <gi...@apache.org> on 2025/06/03 14:46:46 UTC, 1 replies.
- Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] - posted by "FranMorilloAWS (via GitHub)" <gi...@apache.org> on 2025/06/03 15:02:14 UTC, 1 replies.
- [jira] [Created] (FLINK-37889) FLIP-516: Add new FlinkLogicalMultiJoin rule - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/03 15:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2025/06/03 15:45:31 UTC, 0 replies.
- [jira] [Created] (FLINK-37890) FLIP-516: Extend FlinkLogicalMultiJoin to check for common join key - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/03 15:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37773) Extra TMs are started when Jobmanger is OOM killed in some FlinkDeployment runs - posted by "Nishant More (Jira)" <ji...@apache.org> on 2025/06/03 19:58:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37773) Extra TMs are started when Jobmanger is OOM killed in some FlinkDeployment runs - posted by "Nishant More (Jira)" <ji...@apache.org> on 2025/06/03 19:58:00 UTC, 1 replies.
- Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/03 20:34:34 UTC, 30 replies.
- [jira] [Created] (FLINK-37891) SQL Server CDC mistakenly document scan.startup.mode=initial-only as supported - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/06/03 23:01:00 UTC, 0 replies.
- [PR] FLINK-37891: Remove SQL Server CDC documentation for initial-only [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/06/03 23:04:50 UTC, 1 replies.
- [jira] [Updated] (FLINK-37891) SQL Server CDC mistakenly document scan.startup.mode=initial-only as supported - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/03 23:05:00 UTC, 0 replies.
- Re: [PR] [FLINK-36852][pipeline-connector-paimon] Set independent MemoryPoolFactory for each table to avoid StackOverflow error. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 00:05:09 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37891) SQL Server CDC mistakenly document scan.startup.mode=initial-only as supported - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/06/04 01:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-37595][table] Add Join Remove Rules [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/06/04 03:04:25 UTC, 4 replies.
- [jira] [Updated] (FLINK-37595) Add Join Remove rules. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/04 03:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37791) Integrate with sql to rel converter - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/04 06:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37791) Integrate with sql to rel converter - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/04 06:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37792) Reuse LookupJoin Operator to run ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/04 06:18:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37792) Reuse LookupJoin Operator to run ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/04 06:18:00 UTC, 0 replies.
- [PR] [FLINK-37792][table] Reuse LookupJoin operator to run ML_PREDICT [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/06/04 06:26:13 UTC, 20 replies.
- Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/06/04 08:03:49 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-37870) Unaligned checkpoint is disabled for all connections unexpectedly - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/04 08:28:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37870) Unaligned checkpoint is disabled for all connections unexpectedly - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/04 08:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2025/06/04 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/04 08:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/04 08:41:00 UTC, 11 replies.
- [jira] [Created] (FLINK-37893) Rest Port Name should be made configurable - posted by "Mayur Dhingra (Jira)" <ji...@apache.org> on 2025/06/04 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37894) Introduce new Join Operator with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2025/06/04 08:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37893) Kuberenetes Rest service's Port Name should be made configurable - posted by "Mayur Dhingra (Jira)" <ji...@apache.org> on 2025/06/04 08:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37894) Introduce Index in CatalogTable - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2025/06/04 08:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17 - posted by "牛一凡 (Jira)" <ji...@apache.org> on 2025/06/04 08:58:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17 - posted by "牛一凡 (Jira)" <ji...@apache.org> on 2025/06/04 09:04:00 UTC, 0 replies.
- [PR] [FLINK-37894][table] Introduce Index in CatalogTable [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2025/06/04 09:06:08 UTC, 49 replies.
- [jira] [Assigned] (FLINK-37894) Introduce Index in CatalogTable - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/04 09:26:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37877) Add the key ordered operator in table runtime - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/04 09:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37876) Introduce key ordered component in runtime - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/04 09:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-37245] Prevent masking null values in BinaryRowData [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/06/04 12:38:35 UTC, 7 replies.
- Re: [PR] [FLINK-36805][cdc-common] Add ConfigShade interface to support encryption of sensitive configuration items and provide a base64 encoding implementation [flink-cdc] - posted by "Jzjsnow (via GitHub)" <gi...@apache.org> on 2025/06/04 12:58:18 UTC, 0 replies.
- [jira] [Created] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs - posted by "Sebastian Struß (Jira)" <ji...@apache.org> on 2025/06/04 14:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/06/04 15:06:00 UTC, 2 replies.
- Re: [PR] [FLINK-37876][table] Introduce async execution controller framework in table runtime [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/06/04 16:07:07 UTC, 12 replies.
- Re: [PR] [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions [flink] - posted by "RyanSkraba (via GitHub)" <gi...@apache.org> on 2025/06/04 16:47:23 UTC, 1 replies.
- Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] - posted by "gguptp (via GitHub)" <gi...@apache.org> on 2025/06/04 19:24:18 UTC, 7 replies.
- Re: [PR] [FLINK-35713][common] Support set parallelism in source and sink [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/06/05 01:39:25 UTC, 0 replies.
- [PR] [Flink-37703][UnitTest]The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline [flink] - posted by "liangyu-1 (via GitHub)" <gi...@apache.org> on 2025/06/05 01:53:08 UTC, 10 replies.
- Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/05 01:59:37 UTC, 1 replies.
- [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/05 02:03:16 UTC, 2 replies.
- Re: [PR] [hotfix] Fix typo in ElasticsearchEmitter [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/05 02:07:20 UTC, 2 replies.
- [jira] [Created] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/05 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37898) Implement delta join operator - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/05 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/05 02:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/05 02:19:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/05 03:15:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37899) Unstable JoinRestoreTest - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 03:21:00 UTC, 0 replies.
- Re: [PR] [4.0][FLINK-36595][docs] Explicitly set connector compatibility as string [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/05 03:21:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-37899) Unstable JoinRestoreTest - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 03:22:00 UTC, 7 replies.
- [jira] [Updated] (FLINK-37899) Unstable JoinRestoreTest - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 03:23:00 UTC, 2 replies.
- Re: [PR] [FLINK-37830] V3.1 restore checkpoint arraylist NPE [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/05 03:27:33 UTC, 0 replies.
- Re: [PR] [FLINK-37831] V3.1 do not retry failed index operations [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/05 03:28:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-37848) After timestamp mode is enabled, newly added tables will not have all their data synchronized. - posted by "Darcy Lin (Jira)" <ji...@apache.org> on 2025/06/05 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37900) Support configurable jitter in rocksdb checkpoint file uploader - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/06/05 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37902) Support batch execution for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37901) Support to serde ExecNode for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37903) Support runtime config for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 05:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/05 06:15:00 UTC, 5 replies.
- Re: [PR] [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 06:25:59 UTC, 0 replies.
- Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 06:26:19 UTC, 0 replies.
- Re: [PR] [FLINK-37422][docs] Fix typo in streaming analytics zh document [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 06:26:40 UTC, 0 replies.
- Re: [PR] [FLINK-37427] Fix incorrect NPE message in StandaloneHaServices constructor [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 06:27:01 UTC, 0 replies.
- [jira] [Created] (FLINK-37904) Support state ttl for async ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 06:56:00 UTC, 0 replies.
- Re: [PR] [FLINK-37833] [table-runtime] Fix BatchExecExchange codegen for BINARY type by evaluating Unsafe.arrayBaseOffset(byte[].class) in TM rather than in JM [flink] - posted by "venkata91 (via GitHub)" <gi...@apache.org> on 2025/06/05 07:01:01 UTC, 2 replies.
- [PR] Bump webpack-dev-server and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 07:09:46 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/06/05 07:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37900) Support configurable jitter in rocksdb checkpoint file uploader - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/06/05 07:46:00 UTC, 2 replies.
- Re: [PR] [FLINK-36303] PostgreSQL timestamp precision 0 not supported [flink-connector-jdbc] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/06/05 07:46:37 UTC, 9 replies.
- [jira] [Resolved] (FLINK-36303) PostgreSQL timestamp precision 0 not supported - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/05 07:48:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36303) PostgreSQL timestamp precision 0 not supported - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/05 07:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36303) PostgreSQL timestamp precision 0 not supported - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/05 07:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36303) PostgreSQL timestamp precision 0 not supported - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/05 07:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/06/05 07:52:24 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37512) SlidingEventTimeWindows causes OOM - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/05 07:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-28847] Removed Extraneous Semicolon [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/06/05 08:00:16 UTC, 1 replies.
- [jira] [Created] (FLINK-37905) Transform will throw exceptions when handling chinese characters - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/06/05 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/06/05 09:14:00 UTC, 0 replies.
- [PR] [FLINK-37906][doc] Bump kafka version to 4.0 for doc [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/05 09:17:54 UTC, 2 replies.
- [jira] [Updated] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/05 09:18:00 UTC, 0 replies.
- [PR] [FLINK-37906] Fix flink_compatibility parsing issue [flink-connector-kafka] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/05 09:25:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-37889) FLIP-516: Add new FlinkJoinToFlinkMultiJoinRule rule + FlinkLogicalMultiJoin - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/05 09:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/06/05 09:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37905) Transform will throw exceptions when handling chinese characters - posted by "yux (Jira)" <ji...@apache.org> on 2025/06/05 09:42:00 UTC, 0 replies.
- Re: [PR] [BP-2.0][FLINK-37906][doc] Bump kafka version to 4.0 for doc [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/06/05 09:45:24 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37814) FLIP-516: Add RIGHT JOIN to LEFT JOIN rule - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/06/05 09:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37905) Transform will throw exceptions when handling chinese characters - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/06/05 09:59:00 UTC, 2 replies.
- Re: [PR] [hotfix][core] Minor polish for CliFrontend.java [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/06/05 10:17:49 UTC, 2 replies.
- Re: [PR] [FLINK-37860][pipeline-connector/paimon]Fix Committer.createContext not passing OperatorStateStore correctly [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/06/05 10:35:18 UTC, 2 replies.
- [jira] [Created] (FLINK-37907) Allow to access memberExecNodes in BatchExecMultipleInput - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/05 10:53:00 UTC, 0 replies.
- [PR] [FLINK37907][table] Allow to access memberExecNodes in BatchExecMultipleInput [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/05 10:57:16 UTC, 1 replies.
- Re: [PR] [FLINK-37776][python] Drop python 3.8 support [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/06/05 11:38:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-37776) Drop support for Python 3.8 - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/05 11:40:00 UTC, 0 replies.
- Re: [PR] [hotfix] Removed Extraneous Semicolon [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2025/06/05 12:34:09 UTC, 2 replies.
- [PR] [FLINK-37862][table] Support inline structured types in SQL [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/06/05 13:24:50 UTC, 12 replies.
- [jira] [Updated] (FLINK-37862) Implement data type improvements for StructuredType - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/05 13:25:00 UTC, 0 replies.
- [PR] [FLINK-37905] Fix transform failure with non-ascii string literals [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/06/05 13:32:40 UTC, 0 replies.
- [PR] [FLINK-37898][table] Implement delta join operator in Runtime [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2025/06/05 13:33:28 UTC, 2 replies.
- [jira] [Updated] (FLINK-37898) Implement delta join operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/05 13:34:00 UTC, 0 replies.
- [PR] [FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader [flink] - posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org> on 2025/06/05 14:42:26 UTC, 35 replies.
- [jira] [Updated] (FLINK-37900) Support configurable jitter in rocksdb checkpoint file uploader - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/05 14:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-37907][table] Allow to access memberExecNodes in BatchExecMultipleInput [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/05 15:30:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-37907) Allow to access memberExecNodes in BatchExecMultipleInput - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/05 15:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37907) Allow to access memberExecNodes in BatchExecMultipleInput - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/05 15:31:00 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37907) Allow to access memberExecNodes in BatchExecMultipleInput - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/05 15:32:00 UTC, 0 replies.
- [PR] [FLINK-37901][table] Support to serde for StreamExecMLPredictTableFunction [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/06/05 15:53:13 UTC, 16 replies.
- [jira] [Updated] (FLINK-37901) Support to serde ExecNode for ML_PREDICT - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/05 15:54:00 UTC, 0 replies.
- [PR] [FLINK-37775][python] Manage python development/test dependencies in pyproject.yaml [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/06/05 18:44:15 UTC, 1 replies.
- [jira] [Updated] (FLINK-37775) Consolidate PyFlink development dependencies in pyproject.toml - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/05 18:45:00 UTC, 0 replies.
- Re: [PR] [FLINK-36520] CDC Supports MySQL 8.x and above [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/06/05 20:40:08 UTC, 7 replies.
- [PR] [FLINK-37899][table] Stabilize JoinRestoreTest [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/05 21:28:12 UTC, 6 replies.
- [jira] [Assigned] (FLINK-37899) Unstable JoinRestoreTest - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/05 21:44:00 UTC, 0 replies.
- [PR] [FLINK-37794] ml_evaluate function [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/05 23:55:15 UTC, 19 replies.
- [jira] [Updated] (FLINK-37794) ml_evaluate sql function skeleton - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/05 23:56:00 UTC, 0 replies.
- Re: [PR] Model physical [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/05 23:56:56 UTC, 0 replies.
- [jira] [Created] (FLINK-37908) KinesisStreamsSource connector de/registration strategy fails on automated restarts - posted by "Jonathan Du (Jira)" <ji...@apache.org> on 2025/06/06 01:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37792) Reuse LookupJoin Operator to run ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/06 01:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37792) Reuse LookupJoin Operator to run ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/06 01:37:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37793) Codegen for ml_predict - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/06 01:38:00 UTC, 0 replies.
- [PR] FLINK-37908 Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts [flink-connector-aws] - posted by "digitalpoetry (via GitHub)" <gi...@apache.org> on 2025/06/06 01:51:36 UTC, 1 replies.
- [jira] [Updated] (FLINK-37908) KinesisStreamsSource connector de/registration strategy fails on automated restarts - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/06 01:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37905) Transform will throw exceptions when handling chinese characters - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/06/06 02:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37786) Infer schema information from the state of Source and emit it to avoid maintaining state in PreTransform - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/06/06 02:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37786) Infer schema information from the state of Source and emit it to avoid maintaining state in PreTransform - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/06/06 02:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37901) Support to serde ExecNode for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/06 02:58:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37791) Integrate with sql to rel converter - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/06 02:58:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37903) Support runtime config for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/06 02:58:00 UTC, 0 replies.
- Re: [PR] [hotfix] [docs] Fix documentation hyperlink to table formats [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/06 03:29:54 UTC, 0 replies.
- [jira] [Updated] (FLINK-37909) Flink CDC source connector for mongodb repeatedly failing in streaming mode with ChangeStreamHistoryLost error - posted by "Sachin Mittal (Jira)" <ji...@apache.org> on 2025/06/06 03:55:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37909) Flink CDC source connector for mongodb repeatedly failing in streaming mode with ChangeStreamHistoryLost error - posted by "Sachin Mittal (Jira)" <ji...@apache.org> on 2025/06/06 03:55:00 UTC, 0 replies.
- [PR] [FLINK-37909-][cdc-connector-mongodb] Update MongoDBStreamFetchTask to renew heartbeatManager [flink-cdc] - posted by "sjmittal (via GitHub)" <gi...@apache.org> on 2025/06/06 04:31:51 UTC, 6 replies.
- Re: [PR] [FLINK-36992][table] Migrate DecomposeGroupingSetsRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 06:25:46 UTC, 1 replies.
- Re: [PR] [FLINK-37009][table] Migrate PruneAggregateCallRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 06:25:49 UTC, 1 replies.
- Re: [PR] [FLINK-37246] add tokens acquired by current user for token refresh [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 06:25:52 UTC, 1 replies.
- [jira] [Created] (FLINK-37910) FLIP-516: Add StreamExecMultiJoin exec node - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/06 07:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-37906][doc] Bump flink-connector-kafka to 4.0 for doc [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/06 07:38:05 UTC, 0 replies.
- Re: [PR] [BP-2.0][FLINK-37906][doc] Bump flink-connector-kafka to 4.0 for doc [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/06/06 07:38:23 UTC, 0 replies.
- [PR] Fix documentation issue regarding to createTemporalTableFunction params [flink] - posted by "ahmadm9212 (via GitHub)" <gi...@apache.org> on 2025/06/06 07:40:02 UTC, 3 replies.
- [jira] [Resolved] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/06/06 07:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/06 07:53:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/06/06 07:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37853) FLIP-530: Dynamic job configuration - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/06 08:09:00 UTC, 1 replies.
- [PR] [FLIP-516][FLINK-37910][table] Add StreamExecMultiJoin [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/06/06 08:28:43 UTC, 48 replies.
- [jira] [Assigned] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/06 08:32:00 UTC, 0 replies.
- [PR] [FLINK-37896][table-planner] Introduce a new trait derived from sink to source to check whether the downstream operators can accept duplicate data [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/06/06 08:34:08 UTC, 9 replies.
- Re: [PR] [FLINK-37591][table] Add some PruneEmptyRules [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/06/06 08:45:54 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2025/06/06 09:09:00 UTC, 0 replies.
- [PR] [FLINK-37898][table] Implement delta join operator [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2025/06/06 09:23:41 UTC, 25 replies.
- Re: [PR] [FLINK-37249] Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/06/06 11:53:01 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/06/06 14:16:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/06/06 14:21:00 UTC, 0 replies.
- [PR] [FLINK-37822][tests] Fix flaky test: OpenTelemetryMetricReporterITCase.testReport [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2025/06/06 15:13:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/06 15:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/06/06 16:26:59 UTC, 4 replies.
- [jira] [Created] (FLINK-37911) [Helm] Reorganize Helm chart templates - posted by "Yi Chen (Jira)" <ji...@apache.org> on 2025/06/06 16:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37669) [HELM] Add Helm chart unit tests to flink kubernetes operator - posted by "Yi Chen (Jira)" <ji...@apache.org> on 2025/06/06 16:31:00 UTC, 0 replies.
- [PR] [FLINK-37911][Helm] Reorganize Helm chart templates [flink-kubernetes-operator] - posted by "ChenYi015 (via GitHub)" <gi...@apache.org> on 2025/06/06 16:50:19 UTC, 2 replies.
- [jira] [Updated] (FLINK-37911) [Helm] Reorganize Helm chart templates - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/06 16:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-37669][HELM] Add Helm chart unit tests to flink kubernetes operator [flink-kubernetes-operator] - posted by "ChenYi015 (via GitHub)" <gi...@apache.org> on 2025/06/06 17:05:52 UTC, 2 replies.
- [jira] [Created] (FLINK-37912) Typing the DataStream interfaces - posted by "Joey Pereira (Jira)" <ji...@apache.org> on 2025/06/06 22:05:00 UTC, 0 replies.
- Re: [PR] [FLINK-37863] add DynamicKafkaSource interface [flink-connector-kafka] - posted by "lgo (via GitHub)" <gi...@apache.org> on 2025/06/06 22:10:34 UTC, 2 replies.
- [jira] [Created] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/06/07 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/06/07 07:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/06/07 13:37:58 UTC, 1 replies.
- [PR] Update MongoDBStreamFetchTask.java [flink-cdc] - posted by "sjmittal (via GitHub)" <gi...@apache.org> on 2025/06/07 15:19:38 UTC, 1 replies.
- [PR] Add Turkish Translation for Apache Flink Website [flink-web] - posted by "aligoren (via GitHub)" <gi...@apache.org> on 2025/06/07 16:45:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/07 17:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/07 17:33:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/07 17:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-31070][Table SQL/Client] Update jline from 3.21.0 to 3.22.0 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/08 06:25:28 UTC, 0 replies.
- [jira] [Created] (FLINK-37915) Migrate Firehose and Kinesis Stream IT Test to E2E test package - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2025/06/08 07:56:00 UTC, 0 replies.
- [PR] [FLINK-37915] Migrate KDS and KDF IT test to E2E test package [flink-connector-aws] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/06/08 07:57:56 UTC, 2 replies.
- [jira] [Updated] (FLINK-37915) Migrate Firehose and Kinesis Stream IT Test to E2E test package - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/08 07:58:00 UTC, 0 replies.
- [PR] [FLINK-37294][state] Support state migration between disabling and enabling ttl in RocksDBKeyedStateBackend [flink] - posted by "hejufang (via GitHub)" <gi...@apache.org> on 2025/06/08 09:17:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/08 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37916) FLIP-516: Add StreamPhysicalMultiJoin physical node - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/08 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37917) Add support for MultiJoinedRowData - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/08 14:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37917) Add support for MultiJoinedRowData - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/08 14:43:00 UTC, 3 replies.
- [jira] (FLINK-36188) HBase disable buffer flush lose efficacy - posted by "Xin Chen (Jira)" <ji...@apache.org> on 2025/06/09 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37918) Restore the ability to set an interval for GetRecords calls to Kinesis shards. - posted by "hajimeni (Jira)" <ji...@apache.org> on 2025/06/09 02:39:00 UTC, 0 replies.
- [PR] [FLINK-37799][model] Support OpenAI Model Function [flink] - posted by "yunfengzhou-hub (via GitHub)" <gi...@apache.org> on 2025/06/09 03:44:14 UTC, 25 replies.
- [jira] [Updated] (FLINK-37799) Flink native model predict runtime implementation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/09 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37919) Logback | Not applied - posted by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2025/06/09 05:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37919) Logback | Not applied - posted by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2025/06/09 05:40:00 UTC, 1 replies.
- [jira] (FLINK-37899) Unstable JoinRestoreTest - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/09 05:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/09 06:06:00 UTC, 7 replies.
- [jira] [Updated] (FLINK-37920) Reuse same utils for AsyncCalc, AsyncLookupJoin and AsyncMLPredict - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/09 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37920) Reuse same utils for AsyncScalar, AsyncLookupJoin and AsyncMLPredict - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/09 06:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37920) Reuse same util for AsyncCalc, AsyncLookupJoin and AsyncMLPredict - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/09 06:21:00 UTC, 1 replies.
- [PR] [FLINK-37920][table] Reuse same util for AsyncCalc, AsyncLookupJoin a… [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/06/09 06:24:31 UTC, 11 replies.
- Re: [PR] FLINK-25029: Hadoop Caller Context Setting in Flink [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 06:25:47 UTC, 1 replies.
- Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 06:26:29 UTC, 1 replies.
- Re: [PR] [hotfix] [docs] Edit Docs link location [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 06:27:10 UTC, 1 replies.
- Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 06:27:11 UTC, 0 replies.
- Re: [PR] [FLINK-37357][table-planner]Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 06:27:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-37919) Logback | Not applied - posted by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2025/06/09 06:47:00 UTC, 0 replies.
- [PR] Adds pyproject.toml [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/09 07:11:34 UTC, 1 replies.
- [PR] Adds license checker in GHA [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/09 07:25:35 UTC, 1 replies.
- Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/06/09 07:35:40 UTC, 29 replies.
- [jira] [Closed] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/06/09 08:47:00 UTC, 0 replies.
- [PR] Adds lint ci in GHA [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/09 08:55:31 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37920) Reuse same util for AsyncCalc, AsyncLookupJoin and AsyncMLPredict - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/09 09:38:00 UTC, 0 replies.
- [PR] Adds ci tests in GHA [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/09 09:38:28 UTC, 1 replies.
- [PR] [FLINK-37903][table] Support to use runtime config in ML_PREDICT [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/06/09 09:40:39 UTC, 7 replies.
- [jira] [Updated] (FLINK-37903) Support runtime config for ML_PREDICT - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/09 09:41:00 UTC, 0 replies.
- Re: [PR] [FLINK-37866] Migrate glue schema registry e2e test to use aws-kinesis-streams connector [flink-connector-aws] - posted by "hlteoh37 (via GitHub)" <gi...@apache.org> on 2025/06/09 11:29:35 UTC, 3 replies.
- Re: [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] - posted by "hlteoh37 (via GitHub)" <gi...@apache.org> on 2025/06/09 11:31:40 UTC, 10 replies.
- Re: [PR] [FLINK-37217][mysql] Fix `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/06/09 11:46:44 UTC, 1 replies.
- Re: [PR] [FLINK-37772] Bump connector version to 5.1.0 [flink-connector-aws] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/06/09 12:15:52 UTC, 1 replies.
- [jira] [Created] (FLINK-37921) Refactor current implementation with implementation in FLIP-425 - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/06/09 12:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33288) Empty directory residue with appid name in HA(highly-available) related directory of hdfs, not cleaned - posted by "Xin Chen (Jira)" <ji...@apache.org> on 2025/06/09 12:35:00 UTC, 3 replies.
- Re: [PR] [Flink-37703][hadoop] Add more log info to locate the root cause of failed HadoopRecoverableWriterTest#testRecoverFromIntermWithoutAdditionalState in azure cron pipeline [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/06/09 13:59:17 UTC, 1 replies.
- [jira] [Created] (FLINK-37922) Integrating Variant Type into Flink - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37925) Support type casting between variant and primitive type - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37924) Support variant field accessing - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37926) Support type casting between variant and constructed type - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37814) FLIP-516: Add RIGHT JOIN to LEFT JOIN rule - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/06/09 14:46:00 UTC, 0 replies.
- [PR] [FLINK-37923][sql] Patch calcite to support variant type [flink] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/06/09 15:00:29 UTC, 1 replies.
- [jira] [Updated] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/09 15:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37919) Logback Configuration | Not applied correctly for JMs and TMs - posted by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2025/06/09 17:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37927) Add batch mode support for AsyncTableFunction - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/06/09 18:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37928) Support only insert only stream for ml_predict - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/09 19:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37929) Support cdc stream for ml_predict - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/09 19:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-37841][Connectors/DynamoDB] Using standard retry strategy instead of adaptive retry strategy to build ddb streams client [flink-connector-aws] - posted by "gguptp (via GitHub)" <gi...@apache.org> on 2025/06/09 20:13:39 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37899) Unstable JoinRestoreTest - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/09 21:07:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37341) FLIP-508: Add support for Smile format for Compiled plans - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/10 02:38:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37385) Add support for smile format in flink main repo - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/10 02:39:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37385) Add support for smile format in flink main repo - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/10 02:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37861) FLIP-520: Simplify StructuredType handling - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/10 02:55:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/10 03:04:00 UTC, 3 replies.
- [jira] [Created] (FLINK-37930) Generalize the AsyncExecutionController - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/10 03:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/10 03:10:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37875) Introduce the option and the support of planner - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/10 03:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37875) Introduce the option and the support of planner - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/10 03:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37799) Flink native model predict runtime implementation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/10 05:23:00 UTC, 1 replies.
- [PR] Improves the usability of lint/ut scripts [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/10 05:25:35 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37891) SQL Server CDC mistakenly document scan.startup.mode=initial-only as supported - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2025/06/10 05:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37860) [paimon-connector]Fix Committer.createContext not passing OperatorStateStore correctly - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/06/10 05:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37909) Flink CDC source connector for mongodb repeatedly failing in streaming mode with ChangeStreamHistoryLost error - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/06/10 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37931) LookupJoinUtil failed to compile - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/10 06:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37931) LookupJoinUtil failed to compile - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/10 06:04:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37931) LookupJoinUtil failed to compile - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/10 06:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/10 06:10:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37634) When the table name of mysql supports size sensitive, an error occurred when the table name of alter capitalization will not be found. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/06/10 06:43:00 UTC, 0 replies.
- [PR] [python][plan][api] Init Event, Action, Function and WorkflowPlan. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/06/10 07:42:54 UTC, 14 replies.
- [jira] [Created] (FLINK-37932) Set a Default User Agent for GCS FileSystem Connector for Better Observability - posted by "Shruti Singhania (Jira)" <ji...@apache.org> on 2025/06/10 08:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37921) Refactor current implementation with implementation in FLIP-425 - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/06/10 08:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37921) Refactor current implementation to reduce code duplication - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/06/10 08:21:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37862) Implement data type improvements for StructuredType - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 08:22:00 UTC, 0 replies.
- Re: [PR] [FLINK-37876][table] Introduce async execution controller for key ordered in table runtime [flink] - posted by "xishuaidelin (via GitHub)" <gi...@apache.org> on 2025/06/10 08:23:50 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37341) FLIP-508: Add support for Smile format for Compiled plans - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/10 08:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37931) LookupJoinUtil failed to compile - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/10 08:48:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37931) LookupJoinUtil failed to compile - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/10 08:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37901) Support to serde ExecNode for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/10 08:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37901) Support to serde ExecNode for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/10 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37933) Move TransformationScan/SinkProvider out of planner - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/06/10 09:09:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37931) LookupJoinUtil failed to compile - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/10 09:12:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-37899) Unstable JoinRestoreTest - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/10 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37934) Get the case-sensitive variable names and method names of mysql are not standardized, and need to be adjusted - posted by "林健昌 (Jira)" <ji...@apache.org> on 2025/06/10 09:32:00 UTC, 0 replies.
- [PR] [FLINK-37933] Move TransformationScan/SinkProvider out of planner [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/06/10 09:40:06 UTC, 1 replies.
- [jira] [Updated] (FLINK-37933) Move TransformationScan/SinkProvider out of planner - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/10 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37935) Allow to read WindowingStrategy by downstream projects - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/10 10:10:00 UTC, 0 replies.
- [PR] [FLINK-37935][table] Allow to read WindowingStrategy by downstream projects [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/10 10:12:27 UTC, 7 replies.
- [jira] [Updated] (FLINK-37935) Allow to read WindowingStrategy by downstream projects - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/10 10:13:00 UTC, 0 replies.
- Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator] - posted by "chenyuzhi459 (via GitHub)" <gi...@apache.org> on 2025/06/10 10:22:28 UTC, 0 replies.
- Re: [PR] [FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/06/10 10:26:35 UTC, 15 replies.
- Re: [PR] [FLINK-37513] CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP fix [flink-connector-cassandra] - posted by "echauchot (via GitHub)" <gi...@apache.org> on 2025/06/10 10:40:50 UTC, 6 replies.
- [jira] [Updated] (FLINK-37513) CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP invalid regex - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/10 10:41:00 UTC, 0 replies.
- [PR] [FLINK-37934][cdc-source-connectors] Get the case-sensitive variable names and method names of table id are not standardized, and need to be adjusted [flink-cdc] - posted by "linjianchang (via GitHub)" <gi...@apache.org> on 2025/06/10 11:01:16 UTC, 0 replies.
- [jira] [Updated] (FLINK-37934) Get the case-sensitive variable names and method names of mysql are not standardized, and need to be adjusted - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/10 11:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/06/10 11:10:27 UTC, 23 replies.
- [jira] [Created] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/10 11:33:00 UTC, 0 replies.
- [PR] [FLINK-37899][table] Use only `producedBeforeRestore` in `CorrelateTestPrograms#CORRELATE_WITH_LITERAL_AGG` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/10 11:34:13 UTC, 4 replies.
- [jira] [Updated] (FLINK-37928) Forbid cdc-stream for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/10 11:44:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37928) Support only insert only stream for ml_predict - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/10 11:44:00 UTC, 0 replies.
- [PR] [FLINK-37928][table] Forbid cdc-stream for ML_PREDICT [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/06/10 11:47:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-37920) Reuse same util for AsyncCalc, AsyncLookupJoin and AsyncMLPredict - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/10 12:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37920) Reuse same util for AsyncCalc, AsyncLookupJoin and AsyncMLPredict - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/10 12:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/06/10 13:05:00 UTC, 1 replies.
- [PR] [improvement] adding runtime converter array [flink-cdc] - posted by "iundarigun (via GitHub)" <gi...@apache.org> on 2025/06/10 13:55:54 UTC, 1 replies.
- [jira] [Created] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split. - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/06/10 13:57:00 UTC, 0 replies.
- Re: [PR] [hotfix] split number is not calculated correctly in CassandraSource [flink-connector-cassandra] - posted by "echauchot (via GitHub)" <gi...@apache.org> on 2025/06/10 14:06:55 UTC, 0 replies.
- [PR] [FLINK-35051][checkpoint] Treat handling of unaligned checkpoint barrier as the high priority mail [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/06/10 14:12:11 UTC, 9 replies.
- [jira] [Updated] (FLINK-35051) Weird priorities when processing unaligned checkpoints - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/10 14:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/06/10 15:49:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37935) Allow to read WindowingStrategy by downstream projects - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/10 16:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37935) Allow to read WindowingStrategy by downstream projects - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/10 16:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-36546] Handle batch sources in DataSinkTranslator [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/06/10 16:10:35 UTC, 0 replies.
- [jira] [Closed] (FLINK-37910) FLIP-516: Add StreamExecMultiJoin exec node - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 16:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37910) Add StreamExecMultiJoin exec node - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 16:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37916) Add StreamPhysicalMultiJoin physical node - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 16:16:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37814) Add RIGHT JOIN to LEFT JOIN rule - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 16:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37481) Multi way join operator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 16:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37890) Extend FlinkLogicalMultiJoin to check for common join key - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 16:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37859) FLIP-516: Streaming Multi-Way Join Optimization - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 16:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37844) Push down projections for StreamingMultiJoinOperator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 16:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule + FlinkLogicalMultiJoin - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/10 16:17:00 UTC, 0 replies.
- [PR] [hotfix] Use correct `FlinkVersion.v2_1` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/10 16:37:01 UTC, 3 replies.
- [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/06/10 16:55:27 UTC, 23 replies.
- [PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2025/06/10 18:25:56 UTC, 44 replies.
- [jira] [Updated] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/10 18:26:00 UTC, 1 replies.
- Re: [PR] [FLINK-37933][table] Move TransformationScan/SinkProvider out of planner [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/06/10 18:39:34 UTC, 4 replies.
- [PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/06/10 20:10:51 UTC, 16 replies.
- [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 3.9.1 in /flink-end-to-end-tests/flink-sql-client-test [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/10 20:43:17 UTC, 1 replies.
- [PR] Bump org.apache.kafka:kafka-clients from 3.9.0 to 3.9.1 [flink-connector-kafka] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/10 20:48:01 UTC, 2 replies.
- Re: [PR] Bump org.apache.kafka:kafka-clients from 3.4.0 to 3.7.1 [flink-connector-kafka] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/10 20:48:03 UTC, 1 replies.
- [PR] [hotfix] Remove isUnalignedCheckpointsInterruptibleTimersEnabled config [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2025/06/10 20:52:24 UTC, 8 replies.
- Re: [PR] [hotfix] Fix typo in StreamingJobGraphGenerator config [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2025/06/10 20:54:47 UTC, 1 replies.
- [PR] [FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/10 21:44:52 UTC, 1 replies.
- [jira] [Updated] (FLINK-37795) Physical rewrite for ml_evaluate - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/10 21:45:00 UTC, 0 replies.
- Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/10 21:59:58 UTC, 0 replies.
- Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/10 22:02:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch - posted by "Matt Cuento (Jira)" <ji...@apache.org> on 2025/06/10 23:01:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37938) ml evaluate implementation for different task types - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/11 00:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37939) Metrics for ml predict function - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/11 00:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37940) Support retry for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/11 01:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/11 01:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/11 02:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/11 02:40:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/11 02:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2025/06/11 02:44:00 UTC, 4 replies.
- [jira] [Assigned] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2025/06/11 02:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2025/06/11 02:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2025/06/11 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/11 02:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/11 02:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/11 03:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version - posted by "牛一凡 (Jira)" <ji...@apache.org> on 2025/06/11 03:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version - posted by "牛一凡 (Jira)" <ji...@apache.org> on 2025/06/11 03:19:00 UTC, 0 replies.
- [jira] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17 - posted by "牛一凡 (Jira)" <ji...@apache.org> on 2025/06/11 03:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37876) Introduce key ordered component in runtime - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/11 05:34:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37876) Introduce key ordered component in runtime - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/11 05:35:00 UTC, 0 replies.
- Re: [PR] Aec pr for diff [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 06:25:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-37903) Support runtime config for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/11 06:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37903) Support runtime config for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/11 06:37:00 UTC, 0 replies.
- [PR] [FLINK-37877][table] Add the key ordered operator in table runtime for key ordered async lookup join [flink] - posted by "xishuaidelin (via GitHub)" <gi...@apache.org> on 2025/06/11 07:58:47 UTC, 9 replies.
- [jira] [Updated] (FLINK-37877) Add the key ordered operator in table runtime - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/11 07:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws] - posted by "leekeiabstraction (via GitHub)" <gi...@apache.org> on 2025/06/11 08:00:39 UTC, 0 replies.
- [jira] [Created] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:2.0-scala_2.12-java11 - posted by "guoqinglong (Jira)" <ji...@apache.org> on 2025/06/11 08:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:1.20.1-scala_2.12-java8 - posted by "guoqinglong (Jira)" <ji...@apache.org> on 2025/06/11 08:05:00 UTC, 3 replies.
- [jira] [Created] (FLINK-37943) mongo cdc bug can not read stream data - posted by "sunshuxian (Jira)" <ji...@apache.org> on 2025/06/11 08:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37943) mongo cdc bug can not read stream data - posted by "sunshuxian (Jira)" <ji...@apache.org> on 2025/06/11 08:25:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-37943) mongo cdc bug can not read stream data - posted by "sunshuxian (Jira)" <ji...@apache.org> on 2025/06/11 08:31:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/11 08:34:00 UTC, 0 replies.
- [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/06/11 08:43:30 UTC, 0 replies.
- Re: [PR] [FLINK-34071][Connectors/Kinesis] Decouple NettyEventLoop thread's onNext() by handing over blocking queue put to a separate executor. Using a shared executor across shards to execute processing of event received by NettyEventLoop. [flink-connector-aws] - posted by "leekeiabstraction (via GitHub)" <gi...@apache.org> on 2025/06/11 09:34:18 UTC, 3 replies.
- [jira] [Created] (FLINK-37944) New test harness for KeyedProcessFunction using State V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/11 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/11 10:16:00 UTC, 0 replies.
- [PR] Add templates for Github Issues and PRs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/11 11:03:14 UTC, 1 replies.
- [jira] [Closed] (FLINK-37928) Forbid cdc-stream for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/11 11:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37928) Forbid cdc-stream for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/11 11:17:00 UTC, 0 replies.
- [PR] [hotfix][table] Fix StreamExecMLPredictTableFunction doesn't respect … [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/06/11 12:42:46 UTC, 2 replies.
- [jira] [Commented] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend - posted by "Jufang He (Jira)" <ji...@apache.org> on 2025/06/11 13:06:00 UTC, 2 replies.
- [jira] [Created] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN - posted by "slankka (Jira)" <ji...@apache.org> on 2025/06/11 13:45:00 UTC, 0 replies.
- [PR] [FLINK-37946][doc] fix sql syntax of page Table API & SQL EXPLAIN [flink] - posted by "slankka (via GitHub)" <gi...@apache.org> on 2025/06/11 13:51:20 UTC, 4 replies.
- [jira] [Updated] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/11 13:52:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-35020) Model Catalog implementation in Hive etc - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/11 16:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35017) ML_PREDICT function - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/11 16:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35018) ML_EVALUATE function - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/11 16:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33536) Flink Table API CSV streaming sink fails with "IOException: Stream closed" - posted by "sigalit (Jira)" <ji...@apache.org> on 2025/06/11 17:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-37737] Add support for GaussDB database type [flink-connector-jdbc] - posted by "eskabetxe (via GitHub)" <gi...@apache.org> on 2025/06/11 21:22:31 UTC, 3 replies.
- [jira] [Updated] (FLINK-37737) Add support for GaussDB database type - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/11 21:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner - posted by "CaoZhen (Jira)" <ji...@apache.org> on 2025/06/11 22:49:00 UTC, 2 replies.
- Re: [PR] [FLINK-37156] [cdc-composer/cli] pipeline supports collecting data once and writing it to multiple sinks. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/12 00:08:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/12 01:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/12 01:36:00 UTC, 0 replies.
- Re: [PR] [FLINK-37660] Reenable Kryo serializer upgrade tests [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/06/12 01:54:20 UTC, 1 replies.
- Re: [PR] [FLINK-35458][test][type] Add serializer upgrade test for set serializer [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/06/12 01:54:35 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/12 02:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37898) Implement delta join operator - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/12 07:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37933) Move TransformationScan/SinkProvider out of planner - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/06/12 07:04:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37933) Move TransformationScan/SinkProvider out of planner - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/06/12 07:04:00 UTC, 0 replies.
- [PR] [FLINK-37799][model][docs] Add document for OpenAI Model Function [flink] - posted by "yunfengzhou-hub (via GitHub)" <gi...@apache.org> on 2025/06/12 07:05:46 UTC, 20 replies.
- [jira] [Closed] (FLINK-37916) Add StreamPhysicalMultiJoin physical node - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/12 08:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37916) Add StreamPhysicalMultiJoin physical node - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/12 08:41:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36303) PostgreSQL timestamp precision 0 not supported - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/12 08:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37770) FLIP-518: Introduce a community review process - posted by "david radley (Jira)" <ji...@apache.org> on 2025/06/12 09:18:00 UTC, 5 replies.
- [jira] [Created] (FLINK-37947) Add sql hint to enable this optimization - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/06/12 09:27:00 UTC, 0 replies.
- [PR] [FLINK-12130][clients] : Allow dynamic loading of kerberos keytab from client end [flink] - posted by "gvijay452 (via GitHub)" <gi...@apache.org> on 2025/06/12 09:41:12 UTC, 3 replies.
- [jira] [Created] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/12 09:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/12 09:51:00 UTC, 4 replies.
- [PR] [FLINK-37945][table] Add StreamPhysicalMultiJoin to inference program [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/06/12 10:09:21 UTC, 3 replies.
- [jira] [Assigned] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/12 10:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/12 10:10:00 UTC, 0 replies.
- Re: [PR] [FLINK-37738][cdc-connector][postgres] Support read changelog as append only mode [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/06/12 10:17:57 UTC, 1 replies.
- [jira] [Created] (FLINK-37949) FlinkKinesisConsumer on EFO mode runs into Netty deadlock on client close during stop-with-savepoint - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2025/06/12 10:44:00 UTC, 0 replies.
- [D] Time Plan for the first MVP version of Flink Agents [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:11:01 UTC, 7 replies.
- Re: [PR] [FLINK-37536] [TABLE-SQL] Improve SQL Gateway documentation [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/06/12 11:39:52 UTC, 0 replies.
- [D] MVP Design Doc - (WIP, incrementally updating) [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:40:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-37536) Improve SQL gateway documentation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/12 11:41:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37536) Improve SQL gateway documentation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/12 11:42:00 UTC, 0 replies.
- [I] [Tech Debt] Document how-to-contribute in README [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:45:38 UTC, 1 replies.
- [I] [Feature] Introduce the fundamental concepts: Workflow, Event, Action & Callable [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:47:20 UTC, 0 replies.
- [I] [Feature] Introduce Workflow, Event, Action & Callable in the Python Workflow Plan [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:48:27 UTC, 0 replies.
- [I] [Feature] Introduce Workflow, Event, Action & Callable in the Java Workflow Plan [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:49:51 UTC, 0 replies.
- [I] [Feature] Support converting between Java & Python Workflow Plans [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:52:18 UTC, 0 replies.
- [I] [Feature] Introduce Python API for Workflow, Event and Action [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:54:04 UTC, 0 replies.
- [I] [Feature] Introduce Java API for Workflow, Event and Action [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:54:23 UTC, 0 replies.
- [I] [Feature] Introduce API for Workflow, Event and Action [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:55:10 UTC, 0 replies.
- [I] [Feature] Support DataStream / Table as input / output of Flink Agents [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:57:43 UTC, 0 replies.
- [I] [Feature] Support DataStream / Table as input / output of Flink Agents in Python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:58:14 UTC, 0 replies.
- [I] [Feature] Support DataStream / Table as input / output of Flink Agents in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:58:30 UTC, 0 replies.
- [I] [Feature][runtime] Implement a Flink operator that executes the given workflow plan [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:59:09 UTC, 0 replies.
- [I] [Feature][runtime] Deploy workflow as a Flink job into a Flink cluster [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/12 11:59:48 UTC, 0 replies.
- [jira] [Updated] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/12 12:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37894) Introduce Index in CatalogTable - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/12 12:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37894) Introduce Index in CatalogTable - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/12 12:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/12 12:49:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/12 12:52:00 UTC, 4 replies.
- [jira] [Created] (FLINK-37950) MongoDB connector should support ordered option - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2025/06/12 13:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37950) MongoDB connector should support ordered option - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2025/06/12 13:16:00 UTC, 2 replies.
- [jira] [Created] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/12 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/06/12 17:10:00 UTC, 0 replies.
- Re: [PR] [FLINK-20628] RabbitMQ Connector using FLIP-27 Source API [flink-connector-rabbitmq] - posted by "pscls (via GitHub)" <gi...@apache.org> on 2025/06/12 19:14:55 UTC, 0 replies.
- [PR] [FLINK-37952] Skip compressing built python wheels by hand in Nightly workflow [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/06/12 19:50:53 UTC, 2 replies.
- [jira] [Updated] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/12 19:51:00 UTC, 5 replies.
- Re: [PR] [FLINK-34944] Use Incremental Source Framework in Flink CDC OceanBase Source Connector [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/13 00:05:14 UTC, 0 replies.
- [PR] [FLINK-37938] ml_evaluation accumulator implementation [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/13 00:30:50 UTC, 1 replies.
- [jira] [Updated] (FLINK-37938) ml evaluate implementation for different task types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/13 00:31:00 UTC, 0 replies.
- Re: [I] [Feature][plan] Introduce Workflow, Event, Action & Callable in the Workflow Plan [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/06/13 02:17:41 UTC, 0 replies.
- Re: [PR] [FLINK-37478] Adding service labels to flink config [flink] - posted by "sibyv (via GitHub)" <gi...@apache.org> on 2025/06/13 04:04:46 UTC, 1 replies.
- Re: [PR] [FLINK-34587][table] Introduce MODE aggregate function [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/13 06:25:39 UTC, 0 replies.
- Re: [PR] Bump esbuild and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/13 06:25:47 UTC, 0 replies.
- [jira] [Created] (FLINK-37953) Add OBF password obfuscation support for SSL configurations - posted by "Basapuram Kumar (Jira)" <ji...@apache.org> on 2025/06/13 07:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37953) Add OBF password obfuscation support for SSL configurations - posted by "Basapuram Kumar (Jira)" <ji...@apache.org> on 2025/06/13 07:30:01 UTC, 1 replies.
- [PR] FLINK-37953: Add OBF password obfuscation support for SSL configurations [flink] - posted by "basapuram-kumar (via GitHub)" <gi...@apache.org> on 2025/06/13 07:40:35 UTC, 2 replies.
- [jira] [Updated] (FLINK-37953) Add OBF password obfuscation support for SSL configurations - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/13 07:41:01 UTC, 2 replies.
- Re: [PR] [FLINK-36580][pipeline-connector-mysql] Fix column.[in|ex]clude.list parameter causing schema inconsistency [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/06/13 07:47:43 UTC, 0 replies.
- [PR] POC removing unaligned checkpoint flag from StreamConfig [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/06/13 08:04:44 UTC, 2 replies.
- [jira] [Closed] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/13 09:00:00 UTC, 0 replies.
- [PR] [Feature][plan][java] Introduce Workflow, Event, Action & Callable in… [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/06/13 09:02:51 UTC, 13 replies.
- [jira] [Created] (FLINK-37954) Full the exception message when the regular could not be optimized into delta join while delta join strategy is FORCE - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/13 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/06/13 09:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37738) [cdc-connector][postgres] Support read changelog as append only mode - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/06/13 11:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/13 11:48:00 UTC, 0 replies.
- [PR] [FLINK-37897][table-planner] Support converting a regular join to a delta join for the simplest pattern in planner [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/06/13 11:49:40 UTC, 8 replies.
- Re: [PR] Add Flink 1.20.2 release [flink-web] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/06/13 13:59:32 UTC, 2 replies.
- [jira] [Updated] (FLINK-37891) SQL Server CDC mistakenly documents scan.startup.mode=initial-only as supported - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/06/13 17:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-28847) Typo in FileSinkProgram.java in file-sink-file-test module - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/06/13 19:16:00 UTC, 0 replies.
- Re: [PR] [FLINK-37293][pipeline-connector][oceanbase] Fix type converting and refactoring test cases [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 00:04:53 UTC, 0 replies.
- Re: [PR] [FLINK-37200]Add e2e test for ElasticSearch Sink. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 00:04:55 UTC, 0 replies.
- Re: [PR] [FLINK-36842] FlinkPipelineComposer allows injecting StreamExecutionEnvironment [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 00:05:00 UTC, 3 replies.
- Re: [PR] [hotfix][state/rocksdb] Use try-with-resources to close RocksStateKeysIterator and fix some typos. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/15 06:25:28 UTC, 1 replies.
- Re: [PR] [FLINK-37289][table] Resolve JVM bytecode size limit exceeded in method due to excessive field initializations in SQL job [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/15 06:25:30 UTC, 1 replies.
- Re: [PR] [hotfix][tests] Use Junit5 import in FileSinkTest. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/15 06:25:34 UTC, 2 replies.
- Re: [PR] [hotfix] Remove unnecessary java.io.Serializable [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/15 19:48:35 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/15 23:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/15 23:52:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/15 23:52:00 UTC, 0 replies.
- Re: [PR] [FLINK-37331][tests] Add comprehensive data type coverage tests for new MysqlSource implementation [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/16 00:05:01 UTC, 0 replies.
- [PR] [FLINK-36540][Runtime] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink] - posted by "liangyu-1 (via GitHub)" <gi...@apache.org> on 2025/06/16 01:34:17 UTC, 14 replies.
- [jira] [Updated] (FLINK-37930) Generalize the async record processing with key-ordered framework - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/16 03:16:00 UTC, 0 replies.
- [PR] [FLINK-37930] Generalize the async record processing with key-ordered framework [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/06/16 03:21:26 UTC, 8 replies.
- [jira] [Created] (FLINK-37956) Update SQL gateway for inline structured types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/16 06:18:00 UTC, 0 replies.
- Re: [PR] Bump io.netty:netty-common from 4.1.46.Final to 4.1.118.Final in /flink-end-to-end-tests/flink-end-to-end-tests-hive [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/16 06:25:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-35458) Flink 2.1: Add serializer upgrade test for set serializer - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/16 06:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35458) Flink 2.1: Add serializer upgrade test for set serializer - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/16 06:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35458) Flink 2.1: Add serializer upgrade test for set serializer - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/16 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37957) Do not write empty lists to compiled plan - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/16 06:45:00 UTC, 0 replies.
- [PR] [FLINK-37957][table] Do not write empty lists to compiled plan [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/16 06:48:59 UTC, 18 replies.
- [jira] [Created] (FLINK-37958) Flink CDC Sink connector support fluss - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/06/16 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37959) supported All postgres sql 14 field types. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/06/16 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37960) UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint test failed in azure pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/16 08:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37960) UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint test failed in azure pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/16 08:21:00 UTC, 1 replies.
- [PR] [readme] Add build and contribute instructions [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/16 10:00:09 UTC, 1 replies.
- [PR] [BP-2.0][FLINK-37952] Skip compressing built python wheels by hand in Nightly workflow [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/06/16 10:25:21 UTC, 2 replies.
- [PR] [BP-1.20][FLINK-37952] Skip compressing built python wheels by hand in Nightly workflow [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/06/16 10:26:01 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37956) Update SQL gateway for inline structured types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/16 10:52:00 UTC, 0 replies.
- [PR] FLINK-37949: Avoid netty deadlock with graceful shutdown [flink-connector-aws] - posted by "jayteej (via GitHub)" <gi...@apache.org> on 2025/06/16 11:24:55 UTC, 5 replies.
- [jira] [Created] (FLINK-37961) Support skip some state operators in TaskManager. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/06/16 12:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37919) Logback Configuration | Not applied correctly for JMs and TMs - posted by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2025/06/16 12:29:00 UTC, 0 replies.
- [jira] (FLINK-37919) Logback Configuration | Not applied correctly for JMs and TMs - posted by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2025/06/16 12:30:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37919) Logback Configuration | Not applied correctly for JMs and TMs - posted by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2025/06/16 12:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37956) Update SQL gateway for inline structured types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/16 13:53:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/06/16 14:38:00 UTC, 0 replies.
- Re: [PR] [FLINK-37098] Fix selecting time attribute from a view [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/06/16 14:40:42 UTC, 0 replies.
- [jira] [Created] (FLINK-37962) Implement visitMultiJoin for RelTimeIndicatorConverter - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/17 00:21:00 UTC, 0 replies.
- Re: [PR] [FLINK-37275][pipeline-connector/mysql] MySQL source connector supports using the base module's source metric statistics [flink-cdc] - posted by "yzeng1618 (via GitHub)" <gi...@apache.org> on 2025/06/17 00:58:17 UTC, 3 replies.
- [jira] [Updated] (FLINK-37962) Implement visitMultiJoin for RelTimeIndicatorConverter - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/17 01:14:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37794) ml_evaluate sql function skeleton - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/17 01:34:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37794) ml_evaluate sql function skeleton - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/17 01:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37794) ml_evaluate sql function skeleton - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/17 01:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37724) Add AsyncTableFunction as new UDF type - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/17 01:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34037) FLIP-398: Improve Serialization Configuration And Usage In Flink - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/06/17 03:40:00 UTC, 0 replies.
- Re: [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/06/17 03:53:21 UTC, 0 replies.
- Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/06/17 03:53:43 UTC, 0 replies.
- [I] [Feature] Add the basic components required to implement feedback [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/17 03:54:46 UTC, 1 replies.
- [I] [Feature] Implements feedback operators [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/17 03:57:34 UTC, 0 replies.
- [I] [Feature] Adds the support of executing the given workflow [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/17 04:00:13 UTC, 0 replies.
- [jira] [Created] (FLINK-37963) Unstable MongoDB unit test cases that triggers JM failover - posted by "yux (Jira)" <ji...@apache.org> on 2025/06/17 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37964) AsyncSinkWriterStateSerializer should consider the estimated size of request entry - posted by "Jiaan Geng (Jira)" <ji...@apache.org> on 2025/06/17 04:25:00 UTC, 0 replies.
- [PR] [FLINK-37964] AsyncSinkWriterStateSerializer should consider the estimated size of request entry [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/06/17 04:36:00 UTC, 3 replies.
- [PR] [FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/06/17 05:41:47 UTC, 0 replies.
- Re: [PR] [FLINK-36898][Table] Support SQL FLOOR and CEIL functions with NanoSecond and MicroSecond for TIMESTAMP_TLZ [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 06:25:43 UTC, 1 replies.
- Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] - posted by "MarijaVujcic (via GitHub)" <gi...@apache.org> on 2025/06/17 07:36:19 UTC, 1 replies.
- [jira] [Closed] (FLINK-37799) Flink native model predict runtime implementation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/17 08:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37799) Flink native model predict runtime implementation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/17 08:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-37908] Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts [flink-connector-aws] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/06/17 08:11:38 UTC, 1 replies.
- [PR] [hotfix][python] Avoids temporary LICENSE file generated during build [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/17 08:22:12 UTC, 1 replies.
- [jira] [Created] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/17 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/17 08:37:00 UTC, 0 replies.
- [PR] fix: CVE-2025-4565 [flink-statefun] - posted by "1995chen (via GitHub)" <gi...@apache.org> on 2025/06/17 08:49:06 UTC, 2 replies.
- Re: [PR] [mysql-cdc] Fix the hung up of snapshot phase when reuse binaryLogClient [flink-cdc] - posted by "suxinglee (via GitHub)" <gi...@apache.org> on 2025/06/17 08:49:15 UTC, 2 replies.
- [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule, Semantic tests and Restore tests [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/06/17 08:57:30 UTC, 1 replies.
- [jira] [Closed] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/17 11:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35573) [FLIP-447] Upgrade FRocksDB from 6.20.3 to 8.10.0 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/06/17 11:48:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37660) Reenable Kryo serializer upgrade tests - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/17 12:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37660) Reenable Kryo serializer upgrade tests - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/17 12:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37660) Reenable Kryo serializer upgrade tests - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/17 12:33:00 UTC, 0 replies.
- [PR] [hotfix][ci] Add missing Iceberg unit tests & split pipelien connector UT into stages [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/06/17 12:33:07 UTC, 0 replies.
- [PR] [docs] Adding Confluent to vendors list [flink] - posted by "gunnarmorling (via GitHub)" <gi...@apache.org> on 2025/06/17 12:58:53 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/17 13:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37890) Extend JoinToMultiJoinRule to check for common join key - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/17 13:37:00 UTC, 3 replies.
- [PR] [FLINK-37889] [table-planner] Add JoinToMultiJoinRule [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2025/06/17 14:01:38 UTC, 5 replies.
- [jira] [Created] (FLINK-37967) Add Confluent product and link to vendor solutions documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/06/17 14:08:00 UTC, 0 replies.
- [PR] [FLINK-37967] Add Confluent Cloud for Apache Flink as vendor solution in docs [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/06/17 14:17:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37967) Add Confluent product and link to vendor solutions documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/06/17 14:19:00 UTC, 0 replies.
- [PR] [FLINK-37946][backport][doc] fix sql syntax of page Table API & SQL E… [flink] - posted by "slankka (via GitHub)" <gi...@apache.org> on 2025/06/17 14:34:07 UTC, 5 replies.
- [PR] [FLINK-37946][backport][doc] fix sql syntax of page Table API & SQL EXPLAIN [flink] - posted by "slankka (via GitHub)" <gi...@apache.org> on 2025/06/17 14:49:33 UTC, 3 replies.
- Re: [PR] [FLINK-37965] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/06/17 14:58:15 UTC, 22 replies.
- [jira] [Commented] (FLINK-37957) Do not write empty lists to compiled plan - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/17 17:28:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37957) Do not write empty lists to compiled plan - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/17 17:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/17 17:31:00 UTC, 2 replies.
- Re: [PR] Update to Flink 1.20 and Pulsar 3.0.2 with callbacks [flink-connector-pulsar] - posted by "JohnBattista (via GitHub)" <gi...@apache.org> on 2025/06/17 19:43:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-37932) Set a Default User Agent for GCS FileSystem Connector for Better Observability - posted by "Chris Nauroth (Jira)" <ji...@apache.org> on 2025/06/17 22:49:00 UTC, 0 replies.
- [PR] [FLINK-37797] Model DDL documentation [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/18 00:25:02 UTC, 5 replies.
- [jira] [Commented] (FLINK-37930) Generalize the async record processing with key-ordered framework - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/18 02:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37930) Generalize the async record processing with key-ordered framework - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/18 02:29:00 UTC, 0 replies.
- Re: [PR] Update to Flink 1.20 and Pulsar 3.0.2 [flink-connector-pulsar] - posted by "JohnBattista (via GitHub)" <gi...@apache.org> on 2025/06/18 02:59:11 UTC, 0 replies.
- [PR] [hotfix] Reuse the final field barrierId [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/06/18 06:39:23 UTC, 4 replies.
- [jira] [Created] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis - posted by "Radha Krishna Peteti (Jira)" <ji...@apache.org> on 2025/06/18 06:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis - posted by "Radha Krishna Peteti (Jira)" <ji...@apache.org> on 2025/06/18 06:47:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37249) Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/06/18 06:56:00 UTC, 0 replies.
- [I] [Tech Debt] Use the modern pyproject.toml with uv setup [flink-agents] - posted by "JingGe (via GitHub)" <gi...@apache.org> on 2025/06/18 06:56:17 UTC, 4 replies.
- [PR] [FLINK-37867][state/forst] Ensure files of half-uploaded checkpoints are cleaned when using path copying. [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/06/18 07:39:44 UTC, 6 replies.
- [PR] [Feature][runtime] Adds the basic components from flink-statefun to implement feedback ability [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/18 08:07:40 UTC, 8 replies.
- [jira] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis - posted by "Xenos (Jira)" <ji...@apache.org> on 2025/06/18 08:10:00 UTC, 0 replies.
- [PR] [hotfix] Fix the ut.sh for java tests [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/18 08:27:25 UTC, 1 replies.
- Re: [I] [Feature][plan] Support converting between Java & Python Workflow Plans [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/06/18 08:50:55 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/18 10:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/18 10:00:00 UTC, 0 replies.
- Re: [PR] [FLINK-37365][pyflink] Add API stability decorators for PyFlink APIs [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/06/18 10:10:31 UTC, 1 replies.
- Re: [PR] [hotfix][ci] Add missing Iceberg unit tests & split pipeline connector UT into stages [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/06/18 10:12:09 UTC, 3 replies.
- [PR] [FLINK-37944][test] Add utils for initializing process function test harnesses with async state. [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/06/18 10:41:50 UTC, 5 replies.
- [PR] [FLINK-37921][table] Replace TableKeyedAsyncWaitOperator with new operator under new async framework [flink] - posted by "xishuaidelin (via GitHub)" <gi...@apache.org> on 2025/06/18 11:45:29 UTC, 3 replies.
- [jira] [Created] (FLINK-37969) Allow Transformation subgraphs to be merged during translation - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/06/18 12:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-37965][FLINK-37889][FLINK-37966] Add PhysicalMultiJoinRule, FlinkLogicalMultiJoin, LogicalJoinToMultiJoinRule and Semantic + Restore + relPlan + execPlan tests [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/06/18 13:14:37 UTC, 1 replies.
- [jira] [Created] (FLINK-37970) Support PLAN_TEST_FORCE_OVERWRITE for .xml artifacts - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/18 13:47:00 UTC, 0 replies.
- [PR] [FLINK-37969] Allow Transformation subgraphs to be merged during translation [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/06/18 13:50:05 UTC, 3 replies.
- [jira] [Created] (FLINK-37971) SQL hints are dropped by planner when - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/06/18 16:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37971) SQL hints are dropped by planner - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/06/18 16:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/06/18 16:25:00 UTC, 8 replies.
- [jira] [Commented] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/18 16:37:00 UTC, 3 replies.
- [jira] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/18 16:37:00 UTC, 0 replies.
- [PR] Pulsar 3.0.12 [flink-connector-pulsar] - posted by "JohnBattista (via GitHub)" <gi...@apache.org> on 2025/06/18 18:38:25 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37969) Allow Transformation subgraphs to be merged during translation - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/06/18 21:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37759) Support upload user jars by external process instead of via blobs. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/06/19 01:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37972) Support jar and UserClassLoader sharing between jobs. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/06/19 01:27:00 UTC, 0 replies.
- [PR] Init workflow api [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/06/19 02:15:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-36609) Protobuf Format not support proto3 - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/06/19 03:35:00 UTC, 1 replies.
- [PR] [FLINK-37958][cdc-sink-connectors] Flink CDC Sink connector support fluss [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/06/19 04:25:44 UTC, 2 replies.
- Re: [I] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/06/19 05:44:44 UTC, 1 replies.
- Re: [PR] [FLINK-30284][flink-metrics] Adding datacenter url property to datadog [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 06:25:38 UTC, 0 replies.
- Re: [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 06:25:41 UTC, 1 replies.
- Re: [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 3.7.1 in /flink-end-to-end-tests/flink-sql-client-test [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 06:25:43 UTC, 2 replies.
- Re: [PR] [hotfix] make previousCpuTicks and previousProcCpuTicks volatile to increase visibility for all threads [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 06:25:48 UTC, 0 replies.
- Re: [PR] [FLINK-37431]We should use guava Lists instead of curator shade Lists… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 06:25:49 UTC, 0 replies.
- Re: [PR] [FLINK-36245][FOLLOWUP] Remove the @Deprecated for ArrowSourceFunction and SinkFunction [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 06:25:50 UTC, 0 replies.
- Re: [PR] [FLINK-37501][runtime/web] Fix incorrect job ID in url for logs in history server [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 06:25:52 UTC, 0 replies.
- [PR] [FLINK-37422][state/forst] Respect the `maxTransferBytes` when using path copying in ForSt. [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/06/19 06:49:24 UTC, 4 replies.
- [jira] [Assigned] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/19 08:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/19 08:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/19 08:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/19 08:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/19 08:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/19 08:11:00 UTC, 0 replies.
- [PR] [FLINK-37890] [table-planner] Add commonJoinKey check inside JoinToMultiJoinRule [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2025/06/19 08:24:16 UTC, 35 replies.
- [jira] [Commented] (FLINK-37513) CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP invalid regex - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/06/19 08:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37513) CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP invalid regex - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/06/19 08:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split. - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/06/19 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37973) Use RightToLeftJoin Rule for MultiJoins - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/19 12:04:00 UTC, 0 replies.
- [PR] [FLINK-37962][table] Add visitMultiJoin to RelTimeIndicatorConverter [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/06/19 12:12:25 UTC, 10 replies.
- [jira] [Created] (FLINK-37974) Avoid confusion when declaring table arguments - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/19 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37975) sync a lot sharding table Post Transform failed - posted by "tongyp (Jira)" <ji...@apache.org> on 2025/06/19 13:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37975) sync a lot sharding table Post Transform failed - posted by "tongyp (Jira)" <ji...@apache.org> on 2025/06/19 13:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37975) sync a lot sharding table to doris, Post Transform failed - posted by "tongyp (Jira)" <ji...@apache.org> on 2025/06/19 13:57:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37898) Implement delta join operator - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/19 14:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37898) Implement delta join operator - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/19 14:01:00 UTC, 0 replies.
- [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/06/19 16:29:09 UTC, 67 replies.
- [jira] [Commented] (FLINK-37944) New test harness for KeyedProcessFunction using State V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/19 16:42:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37944) New test harness for KeyedProcessFunction using State V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/19 16:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/19 16:44:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/19 16:44:00 UTC, 0 replies.
- Re: [PR] [mysql] Fix issue #1944: Fix GTIDs on startup to correctly recover from checkpoint [flink-cdc] - posted by "xyw0537 (via GitHub)" <gi...@apache.org> on 2025/06/19 23:42:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-37877) Add the key ordered operator in table runtime - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/20 01:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37877) Add the key ordered operator in table runtime - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/20 01:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37975) mysql sync a lot sharding table to doris, Post Transform failed - posted by "tongyp (Jira)" <ji...@apache.org> on 2025/06/20 03:05:00 UTC, 3 replies.
- [PR] [FLINK-37854][table] Support DATE_FORMAT with zone [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2025/06/20 03:34:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/20 03:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-37797] Model documentation [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/20 05:19:21 UTC, 2 replies.
- Re: [PR] [FLINK-37630] Support flink cdc pipeline Yarn session mode [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/06/20 05:24:22 UTC, 1 replies.
- Re: [PR] [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/20 06:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-37976) DeltaJoinITCase seems to be struck in CI - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/20 06:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37976) DeltaJoinITCase seems to be struck in CI - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/20 06:34:00 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2025/06/20 06:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37962) Implement visitMultiJoin for RelTimeIndicatorConverter - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/20 07:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37890) Extend JoinToMultiJoinRule to check for common join key - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/20 07:42:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/20 07:42:00 UTC, 0 replies.
- [PR] [hotfix][docs] Fix typo in Flink Kubernetes Operator Overview [flink-kubernetes-operator] - posted by "TinyToons (via GitHub)" <gi...@apache.org> on 2025/06/20 08:30:59 UTC, 2 replies.
- [jira] [Resolved] (FLINK-35051) Weird priorities when processing unaligned checkpoints - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/20 09:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37977) Variant implements Serializable - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/20 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37977) Variant implements Serializable - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/20 12:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-36236] Fix overriding the connection provider in JdbcSourceBuilder [flink-connector-jdbc] - posted by "rajucomp (via GitHub)" <gi...@apache.org> on 2025/06/20 13:07:01 UTC, 3 replies.
- [jira] [Commented] (FLINK-36236) JdbcSourceBuilder overrides set connection provider - posted by "Raju Gupta (Jira)" <ji...@apache.org> on 2025/06/20 13:19:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37868) Respect the `maxTransferBytes` when using path copying in ForSt - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/20 15:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37868) Respect the `maxTransferBytes` when using path copying in ForSt - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/20 15:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36236) JdbcSourceBuilder overrides set connection provider - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/06/20 16:27:00 UTC, 0 replies.
- Re: [PR] [FLINK-36236] JdbcSourceBuilder overrides set connection provider [flink-connector-jdbc] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/06/20 16:33:29 UTC, 1 replies.
- [jira] [Closed] (FLINK-36236) JdbcSourceBuilder overrides set connection provider - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/06/20 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37978) Change max-buffer config to max-concurrent-operations - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/20 17:09:00 UTC, 0 replies.
- [PR] [FLINK-37978] Change max-buffer to max-concurrent-operations for ml_predict [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/06/20 17:12:52 UTC, 5 replies.
- [jira] [Commented] (FLINK-37890) Extend JoinToMultiJoinRule to check for common join key - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/06/20 18:42:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37890) Extend JoinToMultiJoinRule to check for common join key - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/20 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/06/21 00:43:00 UTC, 0 replies.
- [PR] FLINK-37979: Remove obsolete MySQL CDC snapshot split assigner code [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/06/21 00:50:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-37797) Documentation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/21 02:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37797) Documentation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/21 02:08:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37797) Documentation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/21 02:08:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37799) Flink native model predict runtime implementation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/21 07:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37976) DeltaJoinITCase seems to be struck in CI - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/21 08:08:00 UTC, 3 replies.
- Re: [PR] [FLINK-37065]: MySQL cdc fix method 'fixRestoredGtidSet' to support gt… [flink-cdc] - posted by "mielientiev (via GitHub)" <gi...@apache.org> on 2025/06/21 08:35:02 UTC, 0 replies.
- Re: [I] [Feature][plan][python] Introduce Workflow, Event, Action & Callable in the Python Workflow Plan [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/22 01:30:11 UTC, 0 replies.
- Re: [PR] [Feature][api][python] Introduce Python API for Workflow, Event and Action [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/22 03:55:48 UTC, 14 replies.
- Re: [PR] [FLINK-37327] [Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/22 06:25:25 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37365) Add API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/22 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37980) Adapt Multi-way join to higher Calcite versions (Calcite 1.35+) - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/22 21:57:00 UTC, 0 replies.
- [PR] [FLINK-37980][table] Adapt Multi-way join to higher Calcite versions [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/22 22:15:17 UTC, 6 replies.
- Re: [PR] [FLINK-37369] Add OceanBaseValueConverters to fix table schema valida… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/23 00:05:06 UTC, 0 replies.
- Re: [PR] Flink 36798 [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/23 00:05:13 UTC, 2 replies.
- [jira] [Closed] (FLINK-36933) Error using QUALIFY in rank - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/23 01:57:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36942) Unable to trigger onEventTime() when using the async state API in RowTimeSortOperator - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/23 01:58:00 UTC, 0 replies.
- [PR] [FLINK-37976][table-runtime] Fix the inconsistency between the number handled by the table async execution controller and the number in the epoch [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/06/23 02:16:40 UTC, 11 replies.
- [jira] [Assigned] (FLINK-37976) DeltaJoinITCase seems to be struck in CI - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/23 02:19:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37978) Change max-buffer config to max-concurrent-operations - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/23 02:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37978) Change max-buffer config to max-concurrent-operations - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/23 02:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37978) Change max-buffer config to max-concurrent-operations - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/23 02:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-37781][docs] Add elasticsearch lookup join document [flink-connector-elasticsearch] - posted by "liyubin117 (via GitHub)" <gi...@apache.org> on 2025/06/23 02:27:22 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/23 02:31:00 UTC, 0 replies.
- [PR] [Flink-37703][hadoop] Modify flink-hadoop-fs Unit Test to fix the bug that cron-test fails [flink] - posted by "liangyu-1 (via GitHub)" <gi...@apache.org> on 2025/06/23 03:30:17 UTC, 5 replies.
- [jira] [Created] (FLINK-37981) TableAsyncExecutionController does not send the watermark Long.MAX downstream - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/23 04:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37981) TableAsyncExecutionController does not send the watermark Long.MAX downstream - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/23 04:04:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code - posted by "Mahesh kumar gaddam (Jira)" <ji...@apache.org> on 2025/06/23 04:11:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37982) When Watermark is updated, the result output in TableAsyncExecutionController cannot be triggered - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/23 04:14:00 UTC, 7 replies.
- [jira] [Created] (FLINK-37982) When Watermark is updated, the result output in TableAsyncExecutionController cannot be triggered - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/23 04:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/06/23 04:28:00 UTC, 0 replies.
- Re: [PR] [FLINK-37525] Introduce a overload findModuleFactory to improve the performance of installModules [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/23 06:26:00 UTC, 1 replies.
- [I] [Feature] Adds support of Python Environment Manager [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/23 08:04:24 UTC, 1 replies.
- [PR] [INFRA] When on job failed in GHA do not cancel other in-progress jobs. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/23 10:56:46 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37973) Use RightToLeftJoin Rule for MultiJoins - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/23 11:22:00 UTC, 0 replies.
- [PR] [DON"T REVIEW] Empty commit to trigger a CI test for FLINK-37892 [flink] - posted by "becketqin (via GitHub)" <gi...@apache.org> on 2025/06/23 11:49:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-37982) When watermark is updated, the result that outputs in TableAsyncExecutionController cannot be triggered - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/23 12:21:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37983) Upgrade Kafka Client version to 3.9.1 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/06/23 13:19:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37982) When watermark is updated, the result that outputs in TableAsyncExecutionController cannot be triggered - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/23 13:23:00 UTC, 0 replies.
- [PR] [FLINK-37983] Update to Kafka client 3.9.1 [flink-connector-kafka] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/06/23 15:29:29 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/23 16:12:00 UTC, 0 replies.
- [PR] [FLINK-37701] Cleanup after #26663 [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2025/06/23 16:41:13 UTC, 7 replies.
- [I] [Bug] Confusing maven artifact ids [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/24 02:09:52 UTC, 1 replies.
- [PR] [build] Add 'flink-agents-' prefix to maven artifact ids. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/24 02:18:05 UTC, 1 replies.
- [jira] [Created] (FLINK-37984) Move Cassandra Sink to Sink V2 - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/06/24 05:56:00 UTC, 0 replies.
- Re: [PR] [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/06/24 05:58:37 UTC, 1 replies.
- [jira] [Commented] (FLINK-37984) Move Cassandra Sink to Sink V2 - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/06/24 06:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-25425) Make Cassandra Sink available for Flink SQL users - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/06/24 06:23:00 UTC, 0 replies.
- Re: [PR] [FLINK-36851][table] Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/24 06:25:53 UTC, 1 replies.
- Re: [PR] [FLINK-36881][table] Introduce GroupTableAggFunction in GroupTableAggregate with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/24 06:25:56 UTC, 1 replies.
- Re: [PR] Added Confluent to Vendor Solutions section [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/24 06:26:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-26823) Make Cassandra Source available for Flink SQL users - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/06/24 06:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37959) supported All postgres sql 14 field types. - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/06/24 06:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37959) supported All postgres sql 14 field types. - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/06/24 06:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-26823) Make Cassandra Source available for Flink SQL users - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/06/24 06:42:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-25425) Make Cassandra Sink available for Flink SQL users - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/06/24 06:43:00 UTC, 0 replies.
- Re: [I] [Feature][plan][java] Introduce Workflow, Event, Action & Callable in the Java Workflow Plan [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/24 07:44:45 UTC, 0 replies.
- [PR] [Feature][runtime] Adds support of Python Environment Manager [flink-agents] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/24 07:51:39 UTC, 4 replies.
- [jira] [Created] (FLINK-37985) Refactor public config options from StreamConfig to JobConfiguration - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/24 08:43:00 UTC, 0 replies.
- [PR] [FLINK-37985][conf] Refactor public config options from StreamConfig to JobConfiguration [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/06/24 09:01:38 UTC, 1 replies.
- [jira] [Updated] (FLINK-37985) Refactor public config options from StreamConfig to JobConfiguration - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/24 09:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split. - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/06/24 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/06/24 09:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/06/24 09:20:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/06/24 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37984) Move Cassandra Sink to Sink V2 - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/06/24 09:22:00 UTC, 0 replies.
- Re: [PR] [FLINK-36456] Add support to pass Datadog API Key as environment variable [flink] - posted by "pinxiu (via GitHub)" <gi...@apache.org> on 2025/06/24 09:36:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2025/06/24 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37987) Implement JdbcDynamicTableSinkV2 to use new Sink API v2 - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/06/24 12:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37987) Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API v2 - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/06/24 12:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37976) DeltaJoinITCase seems to be struck in CI - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/24 12:28:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37987) Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API v2 - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/06/24 12:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37987) Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API v2 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/06/24 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37988) Add left join support - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/06/24 22:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37988) Add left join support for AsyncTableFunction - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/06/24 22:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37989) Add condition support - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/06/24 22:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37989) Add condition support for AsyncTableFunction - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/06/24 22:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 03:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-37503] Compatibility Issue with MySQL Syntax SHOW MASTER STATUS [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/06/25 05:44:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-37960) UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint test failed in azure pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 05:56:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 06:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-36849][table] Introduce AppendOnlyFirstNFunction in Rank with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 06:25:47 UTC, 1 replies.
- Re: [PR] [FLINK-36869][table] Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 06:25:50 UTC, 1 replies.
- Re: [PR] [FLINK-36986][table] Migrate SplitRemoteConditionFromJoinRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 06:25:52 UTC, 0 replies.
- Re: [PR] [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 06:25:59 UTC, 1 replies.
- Re: [PR] [FLINK-37441] Rename `factoryHierarchy` to `typeHierarchy` for `TypeExtractor` [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 06:26:01 UTC, 1 replies.
- Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 06:26:04 UTC, 0 replies.
- Re: [PR] [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 06:26:07 UTC, 1 replies.
- Re: [PR] [FLINK-37549][table][docs]: Fix some scala and markdown syntax errors in tableApi page [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 06:26:09 UTC, 0 replies.
- Re: [PR] [FLINK-36443][table][test][bp-2.0] Improve flaky tests related to partition specs [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 06:26:11 UTC, 0 replies.
- [jira] [Created] (FLINK-37990) [Umbrella] Test Flink Release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 06:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37990) [Umbrella] Test Flink Release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 06:36:00 UTC, 3 replies.
- [PR] [Feature][runtime] Adds support for running Python workflows [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/06/25 08:59:45 UTC, 1 replies.
- [PR] Merge pull request #155 from apache/main [flink-connector-jdbc] - posted by "zm999999 (via GitHub)" <gi...@apache.org> on 2025/06/25 09:27:22 UTC, 1 replies.
- [PR] [plan][python] Support serialize/deserialize workflow plan to/from json. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/06/25 09:49:30 UTC, 0 replies.
- [jira] [Created] (FLINK-37991) Upgrade pemja to 0.6.x - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/06/25 09:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37991) Upgrade pemja to 0.6.x - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/06/25 09:56:00 UTC, 1 replies.
- [PR] [FLINK-37991][python] Upgrade pemja to 0.6.0 [flink] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/06/25 10:04:25 UTC, 1 replies.
- [D] Short-Term Memory Design [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/25 11:16:46 UTC, 0 replies.
- [jira] [Created] (FLINK-37992) Release Testing Instructions: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37993) Release Testing Instructions: Verify FLIP-486: Introduce a new DeltaJoin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37993) Release Testing Instructions: Verify FLIP-486: Introduce a new DeltaJoin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:36:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37992) Release Testing Instructions: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:40:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37994) Release Testing Instructions: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37994) Release Testing Instructions: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37995) Release Testing Instructions: Verify FLIP-520: Simplify StructuredType handling - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37995) Release Testing Instructions: Verify FLIP-520: Simplify StructuredType handling - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37996) Release Testing Instructions: Verify FLIP-437: Support ML Models in Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37996) Release Testing Instructions: Verify FLIP-437: Support ML Models in Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:45:00 UTC, 0 replies.
- [D] Resource & Resource Provider Design [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/06/25 11:46:16 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37997) Release Testing Instructions: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37997) Release Testing Instructions: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37998) Release Testing Instructions: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37998) Release Testing Instructions: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Optimization - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Optimization - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38001) Release Testing Instructions: Verify FLIP-508: Add support for Smile format for Compiled plans - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38001) Release Testing Instructions: Verify FLIP-508: Add support for Smile format for Compiled plans - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38004) Release Testing Instructions: Verify FLIP-522: Add generalized type information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38004) Release Testing Instructions: Verify FLIP-522: Add generalized type information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38005) Release Testing Instructions: Verify FLIP-509: Custom Batch Handling in AsyncSink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38005) Release Testing Instructions: Verify FLIP-509: Custom Batch Handling in AsyncSink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37958) Flink CDC Sink connector support fluss - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/25 13:08:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/25 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38006) Support Python for Flink AWS connectors in Flink 2.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/25 16:38:00 UTC, 0 replies.
- [PR] Storage partition join 1.18 [flink] - posted by "tharvey5 (via GitHub)" <gi...@apache.org> on 2025/06/25 21:00:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-37974) Avoid confusion when declaring table arguments - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/25 21:13:00 UTC, 2 replies.
- [PR] [FLINK-37974][table] Rename argument traits to ROW_SEMANTIC_TABLE/SET_SEMANTIC_TABLE [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/06/25 21:57:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-37974) Avoid confusion when declaring table arguments - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/25 21:58:00 UTC, 0 replies.
- [PR] [infra] Add Hao Li as collaborator on github [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/26 01:11:38 UTC, 1 replies.
- [PR] [Feature][runtime] Introducing the FlinkRunnerContext component to support Python workflow execution [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/06/26 02:57:30 UTC, 3 replies.
- Re: [PR] [FLINK-36936][table] Introduce UpdatableTopNFunction in Rank with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/26 06:25:49 UTC, 1 replies.
- [PR] [infra] Add Wenjin Xie, Xu Huang and Eugene as collaborators on github [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/06/26 06:49:03 UTC, 0 replies.
- [jira] [Created] (FLINK-38007) Prepare Flink 2.1 Release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38007) Prepare Flink 2.1 Release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38008) [Release-2.1] Create a new version in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38008) [Release-2.1] Create a new version in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38009) [Release-2.1] Select executing Release Manager - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38010) [Release-2.1] Create a release branch - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38008) [Release-2.1] Create a new version in JIRA - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/06/26 08:51:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38008) [Release-2.1] Create a new version in JIRA - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/06/26 08:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37687) Bump flink-connector-aws to 2.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 09:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37866) Migrate glue schema registry e2e test to use aws-kinesis-streams connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38011) [Release-2.1] Prepare RC0 release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38012) [Release-2.1] Review Release Notes in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38013) [Release-2.1] Cross team testing - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38014) [Release-2.1] Triage release-blocking issues in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38015) [Release-2.1] Review and update documentation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38017) [Release-2.1] Add release note for release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38016) [Release-2.1] Verify that no exclusions were erroneously added to the japicmp plugin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:37:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37851) Migrate state processor API from source API v1 to source API v2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/26 12:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38001) Release Testing Instructions: Verify FLIP-508: Add support for Smile format for Compiled plans - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/26 12:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37851) Migrate state processor API from source API v1 to source API v2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/26 12:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38001) Release Testing Instructions: Verify FLIP-508: Add support for Smile format for Compiled plans - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/26 12:35:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37980) Adapt Multi-way join to higher Calcite versions (Calcite 1.35+) - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/26 12:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37980) Adapt Multi-way join to higher Calcite versions (Calcite 1.35+) - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/26 12:39:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37980) Adapt Multi-way join to higher Calcite versions (Calcite 1.35+) - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/26 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38018) Migrate state processor API from sink API v1 to source API v2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/26 15:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38018) Migrate state processor API from sink API v1 to source API v2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/26 15:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38018) Migrate state processor API from sink API v1 to sink API v2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/26 15:47:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/26 15:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/26 15:53:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/26 15:56:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-35989) Document and log error on partially failed requests for AWS sinks - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36155) ByteBuf.release() was not called before it's garbage-collected in Kinesis Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37733) Externalise DynamoDB connector IT Test to E2E test package - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33167) Run IT tests against Kinesalite if AWS credentials are not present - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36432) FLIP-438: Amazon SQS Source Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32394) Init.pos is partially stored in connector state - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-10536) Flink Kinesis Consumer leading to job failure due to ProvisionedThroughputExceededException - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36205) DDB Streams connector should be able to resolve the stream ARN from given Table name - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37273) Dynamodb Streams getRecords call adaptive delay - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33068) Handle DNS errors in AWS connectors as recoverable - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16505) Document how to use the FlinkKinesisConsumer to read a CDC stream from DynamoDB - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20350) Incompatible Connectors due to Guava conflict - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36412) Retry strategies on Kinesis Sink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21441) FlinkKinesisProducer does not forward custom endpoint - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-19460) AWS Kinesis Producer EXACTLY_ONCE semantic - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36296) Add incremental shard discovery for DDB Streams source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34520) Confusing MIT language in the NOTICE file - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31872) Add Support for Configuring AIMD Ratelimiting strategy parameters by Sink users for KinesisStreamsSink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21228) Deadlock in KinesisProducer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22473) Kinesis connector options are not listed by its factory - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20294) Expose value format metadata in Kinesis table source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8542) Do not indefinitely store closed shard's state in the FlinkKinesisConsumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32097) Implement support for Kinesis deaggregation - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31988) Implement Python wrapper for new KDS source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32696) Promote Kinesis connector support to PublicEvolving - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6316) Kinesis connector docs should mention that FlinkKinesisConsumer does not provide strong ordering guarantees on resharding - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36971) Add Sqs Sink SQL connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37688) FLIP-524: Amazon CloudWatch Metric Sink Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-26933) FlinkKinesisConsumer incorrectly determines shards as newly discovered when tested against Kinesalite when consuming DynamoDB streams - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37004) Implement Multithreaded SourceReader - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33991) Custom Error Handling for Kinesis Polling Consumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36672) Kinesis Table API for new KDS source should infer region from streamARN - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35541) Introduce retry limiting for AWS connector sinks - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31942) Support Conditional Writes in DynamoDB connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-26008) Update Kinesalite docker container reference - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34071) Deadlock in AWS Kinesis Data Streams AsyncSink connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-30092) Improve Table API experience for Flink DOUBLE type - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33259) flink-connector-aws should use/extend the common connector workflow - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37563) Add additional metrics for DDB connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36359) IT case for DDB Streams connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37772) Release flink-connector-aws v5.1.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-29311) Unable to use http for Kinesis consumer when testing locally - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-18344) Avoid wrong check with shardId in DynamoDB Streams - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34023) Expose Kinesis client retry config in sink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37648) Flink Kinesis connector lost track of 1 shard. - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32116) FlinkKinesisConsumer cannot stop-with-savepoint when configured with watermark assigner and watermark tracker - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-10492) Document generic support for configuring AwsKinesisClient in the Kinesis Consumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32007) Implement Python Wrappers for DynamoDB Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-14039) Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36057) Allow specifying ARN for AWS connector resources - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34340) Implement DDB Streams Table API support - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-25779) Define ConfigOption for aws, scan and sink map in Kinesis - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37683) [Connector][AWS] SSO credentials fail because of shaded dependencies missing - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37841) Having adaptive retry strategy causing issues in DDB Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-25733) Create A migration guide for Kinesis Table API connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-29549) Add Aws Glue Catalog support in Flink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36828) Implement example for customers to perform KPL Deaggregation - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31961) Implement ExpandedQuery and OriginalQuery methods for glue in catalog - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-11942) Flink kinesis connector throws kinesis producer daemon fatalError - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-36975) Invalid ConfigOption for "aws.credentials.provider.role.provider" in AWSConfigOptions - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-36666) CI/CD should check NOTICE files for discrepancies. - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-31946) DynamoDB Sink Allow Multiple Item Writes - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-35500) DynamoDb Table API Sink fails to delete elements due to key not found - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-36671) Kinesis Table API for new KDS source does not support metadata. - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-36972) Unify AWS sink implementation - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-37343) Support for Dynamic Table Selection in DynamoDB Sink Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:35:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-33132) Flink Connector Redshift Implementation (Table-API) - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-13291) Cannot provide AWS Direct Connect ENDPOINT - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31854) FLIP-307:[Phase 1] [Sink Support] Flink Connector Redshift - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16839) Connectors Kinesis metrics can be disabled - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37687) Bump flink-connector-aws to 2.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/26 16:39:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37991) Upgrade pemja to 0.5.3 - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/06/27 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/27 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing - posted by "Thorne (Jira)" <ji...@apache.org> on 2025/06/27 04:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing - posted by "Thorne (Jira)" <ji...@apache.org> on 2025/06/27 04:32:00 UTC, 6 replies.
- [jira] [Created] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/27 05:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/27 06:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/27 06:00:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38023) State Restoration fails when using GenericRecord with new Avro schema - posted by "Keshav Kansal (Jira)" <ji...@apache.org> on 2025/06/27 06:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38023) State Restoration fails when using GenericRecord with new Avro schema - posted by "Keshav Kansal (Jira)" <ji...@apache.org> on 2025/06/27 06:43:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38024) Unify the timestamp types to use TimestampData with time zone information. - posted by "zjjiang (Jira)" <ji...@apache.org> on 2025/06/27 08:35:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38024) Unify the timestamp types to use TimestampData with time zone information. - posted by "zjjiang (Jira)" <ji...@apache.org> on 2025/06/27 08:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38010) [Release-2.1] Create a release branch - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/27 08:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37974) Avoid confusion when declaring table arguments - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/27 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38025) Update Flink Doc for aws connector v6.0.0 - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2025/06/27 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38026) Oracle CDC scanNewlyAddedTableEnabled is case-sensitive to the database name, which results in the inability to match the database tables. - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2025/06/27 15:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38026) Oracle CDC scanNewlyAddedTableEnabled is case-sensitive to the database name, which results in the inability to match the database tables. - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/06/27 16:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38026) Oracle CDC scanNewlyAddedTableEnabled is case-sensitive to the database name, which results in the inability to match the database tables. - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/06/27 16:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/27 17:58:00 UTC, 2 replies.
- Re: [PR] [plan][java] Support serializing / deserializing Java workflow plan to / from JSON [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/06/28 08:00:42 UTC, 4 replies.
- Re: [PR] [FLINK-37770][GithubAction] Community review Github Action. [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/06/28 11:18:36 UTC, 26 replies.
- Re: [PR] [FLINK-33390][runtime] Support slot balancing at TM level for Adaptive Scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/06/28 15:36:09 UTC, 0 replies.
- Re: [PR] Add Flink 1.19.3 release [flink-web] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/29 07:38:16 UTC, 0 replies.
- Re: [PR] docs: add 20 language links of README [flink-cdc] - posted by "shps951023 (via GitHub)" <gi...@apache.org> on 2025/06/29 10:12:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2025/06/29 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38027) Apply simplify for watermark expresions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/29 21:52:00 UTC, 0 replies.
- [PR] [FLINK-38027][table] Simplify watermark expressions [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/06/29 21:55:43 UTC, 2 replies.
- [jira] [Updated] (FLINK-38027) Apply simplify for watermark expressions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/29 21:57:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/29 22:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-38019] fix ml predict test [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/06/30 01:23:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/30 01:25:00 UTC, 0 replies.
- Re: [PR] [FLINK-38010] Bump flink version to 2.2-SNAPSHOT [flink-benchmarks] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/06/30 01:49:47 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38013) [Release-2.1] Cross team testing - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 01:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/30 01:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-38010][release] Build doc for release-2.1 branch [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/06/30 02:01:42 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38010) [Release-2.1] Create a release branch - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:02:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38010) [Release-2.1] Create a release branch - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38028) Rename MLPredictUtils and FunctionCallUtils - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/30 02:04:00 UTC, 0 replies.
- [PR] [FLINK-38028][table] Rename MLPredictUtils and FunctionCallUtils [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/06/30 02:04:20 UTC, 2 replies.
- [jira] [Created] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/30 02:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37993) Release Testing Instructions: Verify FLIP-486: Introduce a new DeltaJoin - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/30 02:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37995) Release Testing Instructions: Verify FLIP-520: Simplify StructuredType handling - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37992) Release Testing Instructions: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:24:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/06/30 02:27:00 UTC, 0 replies.
- Re: [PR] [FLINK-37121][docs] Fix syntax and examples in create table statement doc [flink] - posted by "jiefei30 (via GitHub)" <gi...@apache.org> on 2025/06/30 02:27:50 UTC, 0 replies.
- [jira] [Updated] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/06/30 02:28:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37998) Release Testing Instructions: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37996) Release Testing Instructions: Verify FLIP-437: Support ML Models in Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/30 02:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/30 02:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Optimization - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:42:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:43:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38004) Release Testing Instructions: Verify FLIP-522: Add generalized type information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:44:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37993) Release Testing Instructions: Verify FLIP-486: Introduce a new DeltaJoin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38005) Release Testing Instructions: Verify FLIP-509: Custom Batch Handling in AsyncSink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38005) Release Testing Instructions: Verify FLIP-509: Custom Batch Handling in AsyncSink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37997) Release Testing Instructions: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38031) Support and Release Connectors for Flink 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38031) Support and Release Connectors for Flink 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38031) Support and Release Connectors for Flink 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:58:00 UTC, 0 replies.
- [PR] Support multiple updates on a single document in ES8 client [flink-connector-elasticsearch] - posted by "TerminaCoder (via GitHub)" <gi...@apache.org> on 2025/06/30 03:06:53 UTC, 1 replies.
- [jira] [Commented] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing - posted by "Thorne (Jira)" <ji...@apache.org> on 2025/06/30 05:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/30 06:09:00 UTC, 0 replies.
- [I] [Feature] Optimize PythonFunction instantiation in `call_python_function` [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/06/30 06:09:38 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/30 06:10:00 UTC, 7 replies.
- Re: [PR] [hotfix] [docs] Fix flink-connector-kafka version in "How to use Maven.." doc of Flink master [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 06:25:55 UTC, 0 replies.
- Re: [PR] [FLINK-37579] Avoid duplicate generate ResourceProfile [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 06:25:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-38027) Apply simplify for watermark expressions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/30 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/06/30 07:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37994) Release Testing Instructions: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 07:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/06/30 07:31:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37994) Release Testing Instructions: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 07:31:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38027) Apply simplify for watermark expressions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/30 08:15:00 UTC, 0 replies.
- [PR] [WIP][Feature] Implements flink operators to execute workflow (#26) [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/06/30 08:33:56 UTC, 0 replies.
- [jira] [Updated] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/30 08:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36929) SQL connector for keyed savepoint data - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 09:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/06/30 10:35:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-37770) FLIP-518: Introduce a community review process - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/06/30 11:05:00 UTC, 0 replies.
- [PR] [FLINK-38030][table-planner] Fix cast exception for TableLineageDatasetImpl when the catalog is not a AbstractCatalog [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/06/30 12:00:58 UTC, 7 replies.
- [PR] [Fix][Docs] Quick Start mysql-to-starrocks Flink Version Incorrect [flink-cdc] - posted by "suntectec (via GitHub)" <gi...@apache.org> on 2025/06/30 12:10:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-38028) Rename MLPredictUtils and FunctionCallUtils - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/30 12:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38028) Rename MLPredictUtils and FunctionCallUtils - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/06/30 12:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38028) Rename MLPredictUtils and FunctionCallUtils - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/30 12:53:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38028) Rename MLPredictUtils and FunctionCallUtils - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/30 12:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-38018][state] Migrate state processor API from sink API v1 to sink API v2 [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/06/30 16:18:19 UTC, 0 replies.
- [PR] [hotfix] Change community review job name from test to label [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/06/30 16:34:21 UTC, 3 replies.
- Re: [PR] [hotfix] Rename executionVertexId to executionVertex [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/06/30 16:57:12 UTC, 0 replies.
- Re: [PR] [hotfix] ELEMENT should throw TableRuntimeException [flink] - posted by "pgaref (via GitHub)" <gi...@apache.org> on 2025/06/30 19:15:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-33926) Can't start a job with a jar in the system classpath in native k8s mode - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/06/30 19:48:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-33926) Can't start a job with a jar in the system classpath in native k8s mode - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/06/30 19:52:00 UTC, 0 replies.