issues@flink.apache.org, 2025-09

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

- Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] - posted by "morazow (via GitHub)" <gi...@apache.org> on 2025/09/01 07:17:26 UTC, 1 replies.
- Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] - posted by "mielientiev (via GitHub)" <gi...@apache.org> on 2025/09/01 07:45:36 UTC, 5 replies.
- [PR] [hotfix] Fix sun.rmi.registry is not visible [flink] - posted by "CuteShaos (via GitHub)" <gi...@apache.org> on 2025/09/01 07:50:47 UTC, 2 replies.
- Re: [PR] FLINK-32695 Migrated SavepointReaderITTestBase to SourceV2. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/01 08:35:33 UTC, 5 replies.
- [PR] [WIP] Kafka 4.x Queue Semantics support in Flink Connector Kafka [flink-connector-kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2025/09/01 09:16:19 UTC, 5 replies.
- [PR] [FLINK-17224] Support precision of TIME type [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/09/01 10:22:11 UTC, 0 replies.
- Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/09/01 10:26:19 UTC, 4 replies.
- Re: [PR] [FLINK-38293] Update Checkstyle version and related rules in Kubernetes Operator [flink-kubernetes-operator] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/01 12:01:59 UTC, 17 replies.
- [jira] [Updated] (FLINK-38293) Update Checkstyle version and related rules in Kubernetes Operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/01 12:03:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38308) Prevent excessive logging from parsing SQL timestamps/dates - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/01 13:47:00 UTC, 0 replies.
- [PR] [FLINK-38308] Reduce logging of date parse errors in DateTimeUtils [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/09/01 13:49:34 UTC, 5 replies.
- [jira] [Updated] (FLINK-38308) Prevent excessive logging from parsing SQL timestamps/dates - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/01 13:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2025/09/01 14:04:00 UTC, 4 replies.
- [PR] [hotfix] [docs] Ververica URL and Product Name has been updated [flink] - posted by "nacisimsek (via GitHub)" <gi...@apache.org> on 2025/09/01 15:49:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2025/09/02 05:32:00 UTC, 1 replies.
- Re: [PR] [WIP] Kafka 4.x Queue Semantics support [flink-connector-kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2025/09/02 05:37:56 UTC, 2 replies.
- Re: [PR] [FLINK-37799][model] support deepseek、qwen [flink] - posted by "qining-mj (via GitHub)" <gi...@apache.org> on 2025/09/02 06:12:36 UTC, 0 replies.
- [jira] [Closed] (FLINK-38308) Prevent excessive logging from parsing SQL timestamps/dates - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/02 08:04:00 UTC, 0 replies.
- Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] - posted by "Biasqo (via GitHub)" <gi...@apache.org> on 2025/09/02 09:57:40 UTC, 0 replies.
- [jira] [Created] (FLINK-38309) Add Basic Authentication Support to OpenTelemetry HTTP Metrics Reporter - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/09/02 09:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38309) Add Basic Authentication Support to OpenTelemetry HTTP Metrics Reporter - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2025/09/02 09:59:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38309) Add Basic Authentication Support to OpenTelemetry HTTP Metrics Reporter - posted by "Doguscan Namal (Jira)" <ji...@apache.org> on 2025/09/02 10:27:00 UTC, 3 replies.
- Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/09/02 11:22:05 UTC, 7 replies.
- [PR] [FLINK-38193] Cherry-pick Bump commons-lang3 to version 3.18.0 into release-2.1 [flink] - posted by "Frawless (via GitHub)" <gi...@apache.org> on 2025/09/02 13:28:52 UTC, 9 replies.
- [PR] [integration][python] Anthropic Chat Model APIs Integration [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/02 18:44:21 UTC, 10 replies.
- [jira] [Created] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/09/02 19:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/09/02 19:49:00 UTC, 1 replies.
- [PR] FLINK-38310: Fix handling binary boundaries in FinishedSnapshotSplitInfo [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/09/02 19:49:14 UTC, 0 replies.
- [jira] [Created] (FLINK-38311) FLIP-542: Make materialized table DDL consistent with regular tables - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/02 20:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38311) FLIP-542: Make materialized table DDL consistent with regular tables - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/02 20:27:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38312) Add support for SHOW CREATE MATERIALIZED TABLES - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/02 20:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/02 20:29:00 UTC, 0 replies.
- [PR] [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/02 20:43:02 UTC, 7 replies.
- [jira] [Updated] (FLINK-38312) Add support for SHOW CREATE MATERIALIZED TABLES - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/02 20:44:00 UTC, 0 replies.
- [PR] [FLINK-38124][docs] Add README for Autoscaling example [flink-kubernetes-operator] - posted by "kaygorodov (via GitHub)" <gi...@apache.org> on 2025/09/02 20:48:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-38124) The autoscaling example misses README - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/02 20:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38124) The autoscaling example misses README - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/09/02 20:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38314) Flink dashboard incorrectly shows units for RocksDB `live-sst-files-size` metric for timer state - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/09/02 21:54:00 UTC, 0 replies.
- Re: [PR] FLINK-37774: SQL Server CDC connector incorrectly handles special characters in database and table names [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/09/02 23:00:09 UTC, 0 replies.
- Re: [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 00:04:37 UTC, 3 replies.
- Re: [PR] [FLINK-37254] Add OceanBaseDefaultValueConverter to fix table schema validation [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 00:04:39 UTC, 1 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/09/03 00:04:41 UTC, 2 replies.
- Re: [PR] [FLINK-36024][source-connector][mysql] Throw the exception encountered when searching for the starting binlog [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 00:04:44 UTC, 1 replies.
- Re: [PR] [FLINK-38291][REST] Reduce thread lock overhead for REST handlers [flink] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/03 03:17:15 UTC, 5 replies.
- Re: [PR] [integration][python] Integrate OpenAI chat model. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/03 06:51:30 UTC, 1 replies.
- Re: [I] [Feature] [integration][python] Integrate built-in openai chat model. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/03 06:52:03 UTC, 0 replies.
- Re: [PR] [api][python] Introduce built-in ReAct Agent. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/03 07:21:33 UTC, 3 replies.
- [jira] [Commented] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/03 08:09:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/03 08:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/03 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38315) Performance regression since August 21 - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/03 08:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38315) Performance regression since August 21 - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/03 08:21:00 UTC, 2 replies.
- Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] - posted by "echauchot (via GitHub)" <gi...@apache.org> on 2025/09/03 08:38:53 UTC, 70 replies.
- Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] - posted by "echauchot (via GitHub)" <gi...@apache.org> on 2025/09/03 08:39:11 UTC, 34 replies.
- [PR] [build] Improve the building process to favor uv and pyproject [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/03 08:47:21 UTC, 1 replies.
- [jira] [Created] (FLINK-38316) Clarify on some of the names in the source - posted by "Marton Greber (Jira)" <ji...@apache.org> on 2025/09/03 09:44:00 UTC, 0 replies.
- [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/09/03 12:56:05 UTC, 8 replies.
- Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/09/03 13:11:32 UTC, 1 replies.
- Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] - posted by "eric-nascimento-nubank (via GitHub)" <gi...@apache.org> on 2025/09/03 14:20:48 UTC, 9 replies.
- Re: [PR] [FLINK-38258][model] support model args in ptf and add ml_predict builtin ptf [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/09/03 14:47:27 UTC, 11 replies.
- [PR] [WIP][FLINK-XXX][table] potential fix for PushCalcPastChangelogNormalizeRule [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/03 16:17:13 UTC, 1 replies.
- [PR] Backport of https://github.com/apache/flink/pull/26518 [flink] - posted by "dieggoluis (via GitHub)" <gi...@apache.org> on 2025/09/03 16:45:20 UTC, 2 replies.
- Re: [PR] [FLINK-37332] Support any column as chunk key column (postgres, orcale, db2, sqlserver) #3922 [flink-cdc] - posted by "xxntti3n (via GitHub)" <gi...@apache.org> on 2025/09/03 16:59:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38312) Add support for SHOW CREATE MATERIALIZED TABLES - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/03 19:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38317) PushCalcPastChangelogNormalizeRule fails in case of partial push down and trimmed fields - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/03 19:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-38317][table] PushCalcPastChangelogNormalizeRule fails in case of partial push down and trimmed fields [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/03 19:31:33 UTC, 1 replies.
- [jira] [Updated] (FLINK-38317) PushCalcPastChangelogNormalizeRule fails in case of partial push down and trimmed fields - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/03 19:32:00 UTC, 0 replies.
- [PR] [hotfix] Fix ollama chat model test failure. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/04 02:21:04 UTC, 1 replies.
- Re: [PR] Feature: [api][runtime] Introduce configuration mechanism [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/04 02:30:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/09/04 03:25:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/09/04 03:26:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38318) Add python autoformatter to pyflink - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/04 05:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38318) Add python autoformatter to pyflink - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/04 05:23:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/09/04 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38320) Upgrade Pekko to 1.2.0 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/09/04 05:55:00 UTC, 0 replies.
- Re: [PR] [api][python] mcp definition and interfaces [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/04 06:00:24 UTC, 10 replies.
- Re: [I] [Feature] README should stick with the recommended way to build the project [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/04 06:09:55 UTC, 0 replies.
- Re: [I] [Tech Debt] Remove legacy requirements folder [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/04 06:10:04 UTC, 0 replies.
- [PR] [hotfix] Fix tongyi chat model test failure. [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/04 06:17:08 UTC, 1 replies.
- Re: [I] [Feature][api][runtime] Introduce configuration mechanism [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/04 07:20:52 UTC, 0 replies.
- [PR] [hotfix] Use `simplifiedCondition` to check for `isAlwaysTrue` in `PushCalcPastChangelogNormalizeRule` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/04 09:19:20 UTC, 2 replies.
- [jira] [Created] (FLINK-38321) Optimize the timer registration logic n window early/late firing scenarios - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/09/04 09:25:00 UTC, 0 replies.
- [PR] [FLINK-38321][table] Optimize the timer registration logic n window e… [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2025/09/04 09:30:15 UTC, 1 replies.
- [jira] [Updated] (FLINK-38321) Optimize the timer registration logic n window early/late firing scenarios - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/04 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38322) Update to Kafka Client 4.1.0 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/09/04 10:57:00 UTC, 0 replies.
- Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/09/04 10:58:20 UTC, 15 replies.
- [PR] [FLINK-38322] Update to Kafka client 4.1.0 [flink-connector-kafka] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/09/04 11:01:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-38322) Update to Kafka Client 4.1.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/04 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38323) Global Scale Factor Mode - posted by "Salva (Jira)" <ji...@apache.org> on 2025/09/04 11:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38323) Global Scale Factor Mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/09/04 11:21:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-38323) Global Scale Factor Mode - posted by "Salva (Jira)" <ji...@apache.org> on 2025/09/04 11:25:00 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-38323) Global Scale Factor Mode - posted by "Salva (Jira)" <ji...@apache.org> on 2025/09/04 11:43:00 UTC, 4 replies.
- Re: [PR] [FLINK-38079] Add Pipeline support for DateType and TimeType [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/09/04 11:44:57 UTC, 1 replies.
- [jira] [Commented] (FLINK-38049) UpgradeMode falls back to last-state mode on HA resubmission even for stateless - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2025/09/04 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38324) Job fails to restore keyed state backend when using Forst state backend on S3 - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2025/09/04 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38325) Checkpoints are hanging and timing out frequently - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2025/09/04 12:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38324) Job fails to restore keyed state backend when using Forst state backend on S3: FileNotFoundException - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2025/09/04 13:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38190) Support async function in Python DataStream API - posted by "Andrew Otto (Jira)" <ji...@apache.org> on 2025/09/04 13:29:00 UTC, 2 replies.
- Re: [PR] [FLINK-38321][table] Optimize the timer registration logic in window e… [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/04 15:00:02 UTC, 0 replies.
- Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/04 15:12:30 UTC, 5 replies.
- Re: [PR] [FLINK-38253] Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/04 15:17:59 UTC, 2 replies.
- Re: [PR] [DOCS] List 3rd Party connector for NATS [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/04 15:27:21 UTC, 1 replies.
- Re: [PR] [hotfix] Add Postgresql UUID catalog support [flink-connector-jdbc] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/04 15:51:14 UTC, 0 replies.
- [D] Vector Store Integration for Flink Agents [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/04 17:23:43 UTC, 8 replies.
- [jira] [Updated] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/09/04 19:37:00 UTC, 2 replies.
- Re: [PR] WIP: [Feature][API] Introduce ChatModel,Tool and Prompt in Java [flink-agents] - posted by "AmenAdem (via GitHub)" <gi...@apache.org> on 2025/09/04 19:54:05 UTC, 2 replies.
- Re: [PR] [FLINK-37739][cli] fix flink-conf is not obtained in local mode [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/05 00:04:44 UTC, 0 replies.
- [jira] [Created] (FLINK-38326) Kubernetes support oAuthToken authentication - posted by "melin (Jira)" <ji...@apache.org> on 2025/09/05 00:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/05 01:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/05 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/05 02:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38325) Checkpoints are hanging and timing out frequently - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/05 03:01:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38324) Job fails to restore keyed state backend when using Forst state backend on S3: FileNotFoundException - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/05 03:03:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38326) Kubernetes support oAuthToken authentication - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/09/05 05:57:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-38180) Race condition between failing Task and cancelation hiding the real exception - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/09/05 06:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication - posted by "melin (Jira)" <ji...@apache.org> on 2025/09/05 06:08:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/09/05 06:14:00 UTC, 2 replies.
- Re: [I] [Feature] [integration][python] Integrate built-in Anthropic chat model. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/05 07:03:22 UTC, 0 replies.
- Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/09/05 07:22:40 UTC, 10 replies.
- [jira] [Updated] (FLINK-38305) amend the prefix to not include gid and move to http - posted by "david radley (Jira)" <ji...@apache.org> on 2025/09/05 08:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38299) amend push github action to go against v1 snapshot - posted by "david radley (Jira)" <ji...@apache.org> on 2025/09/05 08:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38320) Upgrade Pekko to 1.2.0 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/05 09:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38139) Schema changes still caused issues after enabling scan.parse.online.schema.changes.enabled - posted by "TemiChan (Jira)" <ji...@apache.org> on 2025/09/05 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38328) Community review acting strangely messages in PRs should adding and removing labels - posted by "david radley (Jira)" <ji...@apache.org> on 2025/09/05 10:42:00 UTC, 0 replies.
- Re: [PR] [FLINK-38050][UI] Correct Flink UI Dropdown Width [flink] - posted by "nishita-09 (via GitHub)" <gi...@apache.org> on 2025/09/05 10:44:26 UTC, 0 replies.
- [jira] [Created] (FLINK-38329) Add labels to PRs showing the targeted version - posted by "david radley (Jira)" <ji...@apache.org> on 2025/09/05 10:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38281) Schema changes still caused column size does not match the data size after enabling scan.parse.online.schema.changes.enabled(pt-osc,gh-ost) - posted by "TemiChan (Jira)" <ji...@apache.org> on 2025/09/05 11:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38281) Schema changes still caused column size does not match the data size after enabling scan.parse.online.schema.changes.enabled(pt-osc,gh-ost) - posted by "TemiChan (Jira)" <ji...@apache.org> on 2025/09/05 11:16:00 UTC, 0 replies.
- [PR] Bump commons-lang3 to version 3.18.0 [flink] - posted by "Frawless (via GitHub)" <gi...@apache.org> on 2025/09/05 13:53:23 UTC, 0 replies.
- Re: [PR] [FLINK-38193] Cherry-pick Bump commons-lang3 to version 3.18.0 into release-2.0 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/05 13:57:29 UTC, 1 replies.
- [PR] FLINK38328 [GithubAction] Remove redundant label mutations [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/05 15:14:39 UTC, 0 replies.
- Re: [PR] FLINK38328 [GithubAction] Remove redundant label mutations in Flink community review Github action script [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/05 15:18:48 UTC, 1 replies.
- [I] [Feature] Support built-in RAG agent [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/06 05:29:58 UTC, 0 replies.
- Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 06:25:12 UTC, 1 replies.
- Re: [PR] [FLINK-38328][GithubAction] Remove redundant label mutations in Flink community review Github action script [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/09/06 10:37:55 UTC, 0 replies.
- [jira] [Updated] (FLINK-38328) Community review acting strangely messages in PRs should adding and removing labels - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/06 10:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38328) Community review acting strangely messages in PRs should adding and removing labels - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/06 10:39:00 UTC, 0 replies.
- [PR] fix(backporting): fix on commiter operator [flink] - posted by "ericsnx (via GitHub)" <gi...@apache.org> on 2025/09/06 13:04:11 UTC, 2 replies.
- [jira] [Closed] (FLINK-38079) Add Pipeline support for DateType and TimeType - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/06 14:56:00 UTC, 0 replies.
- Re: [PR] [FLINK-38275][Pipeline-connectors][doris]Cannot create a table when the upstream has no primary key and the first column is String [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/06 15:11:19 UTC, 0 replies.
- [jira] [Closed] (FLINK-38275) Cannot create a table when the upstream has no primary key and the first column is String - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/06 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38330) Updating state-size in status increases the number of 409's to K8s - posted by "vikasap (Jira)" <ji...@apache.org> on 2025/09/07 03:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38330) Updating state-size in status increases the number of 409's to K8s - posted by "vikasap (Jira)" <ji...@apache.org> on 2025/09/07 03:16:00 UTC, 2 replies.
- [I] [Feature][api][java] Support ReAct Agent in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/07 08:52:01 UTC, 1 replies.
- Re: [I] [Feature][api][python] Support ReAct Agent in Python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/07 08:54:29 UTC, 0 replies.
- Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/07 08:55:50 UTC, 37 replies.
- Re: [PR] [FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN [flink] - posted by "liyude-tw (via GitHub)" <gi...@apache.org> on 2025/09/07 09:29:07 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] Migrate Common Test cases away from legacy Source/Sink [flink] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/09/07 17:10:57 UTC, 4 replies.
- Re: [I] [Tech Debt][Java] Enrich test cases of Short-Term Memory in java [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/08 01:46:59 UTC, 0 replies.
- Re: [PR] [FLINK-37126] Add Validator for Autoscaler [flink-kubernetes-operator] - posted by "huyuanfeng2018 (via GitHub)" <gi...@apache.org> on 2025/09/08 03:03:26 UTC, 1 replies.
- Re: [D] Vector Store and Embedding Model Integration for Flink Agents [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/08 05:16:05 UTC, 1 replies.
- Re: [D] Community Sync [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/08 07:37:44 UTC, 3 replies.
- [I] [Feature] Change default value of extract_reasoning in OllamaChatModelSetup to true [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/08 07:58:05 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/08 08:12:00 UTC, 0 replies.
- [PR] [FLINK-37936][flink-table] Support STATE TTL hints for MultiJoin [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/09/08 08:28:36 UTC, 18 replies.
- [jira] [Updated] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/08 08:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37647) Add support for NonTimeRowsUnboundedPrecedingFunction for OverAggregate - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2025/09/08 08:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38317) PushCalcPastChangelogNormalizeRule fails in case of partial push down and trimmed fields - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/08 08:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-38232] [docs] updates the connector documentation to reflect the new features in Flink CDC 3.4.0 [flink-cdc] - posted by "suhwan-cheon (via GitHub)" <gi...@apache.org> on 2025/09/08 11:42:03 UTC, 4 replies.
- [jira] [Created] (FLINK-38331) Support displaying the hash keys on edges in web ui - posted by "yisha zhou (Jira)" <ji...@apache.org> on 2025/09/08 12:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38331) Support displaying the hash keys on edges in web ui - posted by "yisha zhou (Jira)" <ji...@apache.org> on 2025/09/08 12:23:00 UTC, 1 replies.
- Re: [PR] [hotfix] Check for GNU tar [flink-connector-shared-utils] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/09/08 13:59:36 UTC, 0 replies.
- [jira] [Updated] (FLINK-37813) SlotManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2025/09/08 14:20:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37813) SlotManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2025/09/08 14:24:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37813) SlotManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2025/09/08 14:36:00 UTC, 0 replies.
- [PR] [FLINK-38329][GithubAction] Add target release label for back port PRs [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/08 16:05:39 UTC, 6 replies.
- [jira] [Updated] (FLINK-38329) Add labels to PRs showing the targeted version - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/08 16:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated - posted by "Urs Schoenenberger (Jira)" <ji...@apache.org> on 2025/09/08 18:50:00 UTC, 0 replies.
- Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/09/08 20:24:44 UTC, 32 replies.
- Re: [PR] [FLINK-37991][python] Upgrade pemja to 0.5.4 [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/09/09 01:23:38 UTC, 0 replies.
- [I] [Feature] Create a troubleshooting section for common problems [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/09 01:39:08 UTC, 1 replies.
- [jira] [Created] (FLINK-38332) Upgrade pemja to 0.6.1 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/09 02:48:00 UTC, 0 replies.
- [PR] [FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/09/09 03:01:38 UTC, 5 replies.
- [jira] [Updated] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/09 03:02:00 UTC, 1 replies.
- Re: [PR] [FLINK-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream. [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/09/09 07:23:48 UTC, 3 replies.
- [jira] [Commented] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink - posted by "Kaiqi Dong (Jira)" <ji...@apache.org> on 2025/09/09 09:02:00 UTC, 2 replies.
- [PR] [BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] - posted by "dieggoluis (via GitHub)" <gi...@apache.org> on 2025/09/09 09:44:42 UTC, 2 replies.
- [PR] [hotfix][table] Fix incorrect state ttl setting in KeyedLookupJoinWrapper [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/09/09 09:49:55 UTC, 2 replies.
- Re: [PR] [WIP][BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/09 09:51:31 UTC, 4 replies.
- [PR] [BP-1.20][FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/09/09 10:18:02 UTC, 3 replies.
- [PR] [BP-2.0][FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/09/09 10:19:58 UTC, 3 replies.
- [PR] [BP-2.1][FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/09/09 10:21:36 UTC, 3 replies.
- [jira] [Created] (FLINK-38333) UMBRELLA: FLIP-495: Support AdaptiveScheduler record and query the rescale history - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/09 11:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38333) Umbrella: FLIP-495: Support AdaptiveScheduler record and query the rescale history - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/09 11:00:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-22258) Adaptive Scheduler: Show history of rescales in the Web UI - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/09 11:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-38109] [flink-runtime] Fix BlobClient address when bindhost is set [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/09/09 15:44:32 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38109) BlobServer isn't associated with the correct bind-host - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/09 15:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/09 15:46:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-38109) BlobServer isn't associated with the correct bind-host - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/09 15:47:00 UTC, 0 replies.
- [PR] add handle chunkKeyColumn for Postgres [flink-cdc] - posted by "xxntti3n (via GitHub)" <gi...@apache.org> on 2025/09/09 15:55:22 UTC, 4 replies.
- [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1) - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/09/09 19:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/09/09 22:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/09/09 22:42:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/09/09 23:16:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/09/10 01:29:00 UTC, 0 replies.
- [PR] [hotfix] Adapt get list/map from short memory after upgrade pemja to 0.6.1. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/10 02:45:03 UTC, 2 replies.
- Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/09/10 02:50:50 UTC, 0 replies.
- Re: [PR] Flink 36798 [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/09/10 02:52:32 UTC, 0 replies.
- Re: [I] [Tech Debt] [api][python] Support Event containing Row field can be json serializable [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/10 05:47:29 UTC, 0 replies.
- [PR] [FLINK-38332][python] Bump pemja to 0.6.1 [flink] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/10 05:57:15 UTC, 1 replies.
- [jira] [Updated] (FLINK-38332) Upgrade pemja to 0.6.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/10 05:58:00 UTC, 0 replies.
- [I] [Feature] [Integration] Add built-in ollma embedding model support in python [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/10 05:59:57 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/10 06:10:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/10 06:10:00 UTC, 0 replies.
- [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/10 06:19:48 UTC, 10 replies.
- [jira] [Updated] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/09/10 06:50:00 UTC, 3 replies.
- Re: [PR] [FLINK-35725][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/09/10 06:50:31 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/09/10 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/09/10 09:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/09/10 09:27:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/10 10:00:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/10 10:00:02 UTC, 0 replies.
- Re: [PR] [FLINK-37245] Add tests for FieldGetters to test null value handling in BinaryRowData [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/10 10:00:55 UTC, 3 replies.
- [jira] [Resolved] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/10 10:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2025/09/10 10:03:00 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/09/10 10:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/10 11:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38124) The autoscaling example misses README - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/10 11:07:00 UTC, 0 replies.
- Re: [I] [Feature][api][java] Introduce Prompt, Tool and ChatModel in java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/10 11:11:12 UTC, 0 replies.
- Re: [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/10 11:11:24 UTC, 0 replies.
- [I] [Feature] Replay-based Per Action State Consistency [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/10 11:15:18 UTC, 1 replies.
- [I] [Feature] Introduce ActionState related APIs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/10 11:16:06 UTC, 1 replies.
- [I] [Feature] Provide Kafka-based implementation of ActionState [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/10 11:16:52 UTC, 1 replies.
- [jira] [Created] (FLINK-38336) Unexpected data copy during failover for ForSt statebackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/10 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38337) Chinese translation for document PR - posted by "Scott Fauerbach (Jira)" <ji...@apache.org> on 2025/09/10 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38338) Introduce the abstraction to describe a rescale event. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/10 14:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38331) Support displaying the hash keys on edges in web ui - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/09/10 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38339) Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/10 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/10 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38342) Support record rescale information - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/10 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38341) Introduce the rescale history configuration option. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/10 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38343) Support store rescale history by ExecutionGraphInfoStore and query the rescale history with statistics. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/10 14:36:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38331) Support displaying the hash keys on edges in web ui - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/09/10 14:42:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery - posted by "Lorenzo Nicora (Jira)" <ji...@apache.org> on 2025/09/10 14:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38341) Introduce the rescale history configuration option. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/10 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/10 16:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/10 16:32:00 UTC, 15 replies.
- [PR] [FLINK-35280] Migrate HBase Sink to use Async Sink API [flink-connector-hbase] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/09/10 19:15:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-35280) Migrate HBase Sink connector to use the ASync Sink API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/10 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext - posted by "Matt Cuento (Jira)" <ji...@apache.org> on 2025/09/10 21:26:00 UTC, 0 replies.
- [PR] [FLINK-38345][flink-connector-base] Unit test to replicate null previousEnumerator for HybridSource on checkpoint recovery [flink] - posted by "mattcuento (via GitHub)" <gi...@apache.org> on 2025/09/10 21:44:24 UTC, 1 replies.
- [jira] [Updated] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/10 21:45:00 UTC, 4 replies.
- [jira] [Assigned] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/09/10 22:01:00 UTC, 1 replies.
- Re: [PR] [improve] Remove repeated dependency. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/11 00:04:15 UTC, 1 replies.
- [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/09/11 01:44:04 UTC, 13 replies.
- [jira] [Created] (FLINK-38346) JSON_QUERY returns ARRAY - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/09/11 01:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38346) JSON_QUERY returns ARRAY of incorrect format - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/09/11 01:46:00 UTC, 4 replies.
- [jira] [Closed] (FLINK-38346) JSON_QUERY returns ARRAY of incorrect format - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/09/11 02:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38346) JSON_QUERY returns ARRAY of incorrect format - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/09/11 02:49:00 UTC, 0 replies.
- [I] [Feature] [Docs] Set up Flink Agents Document Website [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/11 02:54:14 UTC, 1 replies.
- [PR] [docs] Set up Flink Agents Document Website [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/11 02:58:00 UTC, 3 replies.
- [I] [Feature] Introduce new module `integrations` [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/09/11 03:12:24 UTC, 1 replies.
- [I] [Feature] [integrations][java] Add support for OllamaChatModel [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/09/11 03:14:22 UTC, 1 replies.
- [PR] [python][examples] Add quickstart workflow examples [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/11 03:25:37 UTC, 5 replies.
- Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/09/11 03:40:13 UTC, 14 replies.
- [jira] [Created] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/11 05:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/11 06:12:00 UTC, 3 replies.
- [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/09/11 06:26:18 UTC, 13 replies.
- [jira] [Updated] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/11 06:27:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/11 06:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38348) Fix flushing issue for append write with buffer sort and bounded source - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2025/09/11 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38348) Fix flushing issue for append write with buffer sort and bounded source - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2025/09/11 06:55:00 UTC, 0 replies.
- [I] [Tech Debt] Specify model to be used in ChatModelSetup. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/11 07:12:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/11 07:19:00 UTC, 2 replies.
- [I] [Tech Debt] Improve Ollama related tests(start_ollama_server.sh) in CI [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/11 08:41:19 UTC, 0 replies.
- Re: [PR] [api][python] Add Embedding Model abstraction and provide a built-in Ollama embedding model implementation [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/11 09:06:55 UTC, 2 replies.
- [PR] [hotfix] [docs] Fixed typo on Parameter name for OracleCDC Adapter [flink-cdc] - posted by "nacisimsek (via GitHub)" <gi...@apache.org> on 2025/09/11 09:29:30 UTC, 1 replies.
- [I] [Tech Debt] Refactoring CI of test cases in integration module [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/11 09:31:43 UTC, 0 replies.
- Re: [I] [Feature] [Integration] Add Embedding Model abstraction and provide a built-in Ollama embedding model implementation [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/11 10:06:04 UTC, 0 replies.
- [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/11 10:28:46 UTC, 15 replies.
- [jira] [Updated] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/11 10:29:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-38329) Add labels to PRs showing the targeted version - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/11 12:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38329) Add labels to PRs showing the targeted version - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/11 12:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-28839) Incorrect english sentence in docs/content/docs/dev/dataset/iterations.md - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/09/11 13:15:00 UTC, 0 replies.
- [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/09/11 13:54:10 UTC, 10 replies.
- [jira] [Commented] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/09/11 14:32:00 UTC, 7 replies.
- Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] - posted by "gguptp (via GitHub)" <gi...@apache.org> on 2025/09/11 15:10:36 UTC, 0 replies.
- [PR] [BP-1.20][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/09/11 15:14:49 UTC, 2 replies.
- [PR] [BP-2.0][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/09/11 15:16:25 UTC, 2 replies.
- [PR] [BP-2.1][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/09/11 15:18:05 UTC, 2 replies.
- Re: [PR] [FLINK-36296][Connectors/DynamoDB] Add support for incremental shard discovery for DynamoDB Streams Source [flink-connector-aws] - posted by "tejanshrana (via GitHub)" <gi...@apache.org> on 2025/09/11 15:39:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-29731) Protobuf-confluent format - posted by "Javad Saljooghi (Jira)" <ji...@apache.org> on 2025/09/11 17:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-36975][Connectors/AWS] Fix the AWS Config Option AWS_ROLE_CREDENTIALS_PROVIDER_OPTION to pick the right key [flink-connector-aws] - posted by "aws-nageshvh (via GitHub)" <gi...@apache.org> on 2025/09/11 21:59:44 UTC, 1 replies.
- [jira] [Created] (FLINK-38349) Bugs caused by floating-point operations - posted by "Huny (Jira)" <ji...@apache.org> on 2025/09/12 01:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38349) Bugs caused by floating-point operations - posted by "Huny (Jira)" <ji...@apache.org> on 2025/09/12 01:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:27:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38349) Incorrect calculation of scale in SpillingThread#mergeChannelList may cause divide-by-zero exception - posted by "Huny (Jira)" <ji...@apache.org> on 2025/09/12 01:30:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:35:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:35:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:36:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-38094) Introduce pyflink.__version__ - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:37:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37981) TableAsyncExecutionController does not send the watermark Long.MAX downstream - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:38:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:38:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37826) Some serde-related perfs regression since May 19th - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/12 01:39:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/12 01:39:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38007) Prepare Flink 2.1 Release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/09/12 01:43:00 UTC, 0 replies.
- [jira] [Closed] (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/09/12 01:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38165) Promote release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/09/12 01:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38172) Update japicmp configuration - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/09/12 01:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38175) Start End of Life discussion thread for now outdated Flink minor version - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/09/12 01:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38350) Update Hadoop Library to 3.4.2 - posted by "Paul Ashley (Jira)" <ji...@apache.org> on 2025/09/12 01:50:00 UTC, 0 replies.
- [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/09/12 02:20:43 UTC, 14 replies.
- [jira] [Updated] (FLINK-38338) Introduce the abstraction to describe a rescale event. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/12 02:21:00 UTC, 0 replies.
- [PR] [FLINK-38339][runtime] Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/09/12 02:44:12 UTC, 5 replies.
- [jira] [Updated] (FLINK-38339) Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/12 02:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/12 02:48:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36125) File not found exception on restoring state handles with file merging - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/12 03:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/09/12 04:10:00 UTC, 0 replies.
- [PR] [FLINK-38345][flink-connector-base] Added previousEnumerator resolution for HybridSource during checkpoint recovery [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2025/09/12 04:31:53 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/09/12 04:34:00 UTC, 0 replies.
- Re: [PR] FLINK-37953: Add OBF password obfuscation support for SSL configurations [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/12 06:25:42 UTC, 0 replies.
- [jira] [Updated] (FLINK-38265) Stream Split shouldn't finish when exception occors - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/12 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38351) Docker images support OpenJDK - posted by "melin (Jira)" <ji...@apache.org> on 2025/09/12 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38352) Expose timestamp used in DefaultWatermarkGenerator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/12 08:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37295) Update state ttl migration compatibility in docs - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/09/12 08:35:00 UTC, 5 replies.
- Re: [I] [Tech Debt][plan] Implement checkSignature for PythonFunction in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/12 09:04:15 UTC, 0 replies.
- Re: [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with java resource providers. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/12 09:07:23 UTC, 1 replies.
- [jira] [Updated] (FLINK-38350) Update Hadoop Library to 3.4.2 - posted by "Paul Ashley (Jira)" <ji...@apache.org> on 2025/09/12 09:30:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37295) Update state ttl migration compatibility in docs - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/12 09:55:00 UTC, 0 replies.
- [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/09/12 09:57:18 UTC, 21 replies.
- [jira] [Updated] (FLINK-37295) Update state ttl migration compatibility in docs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/12 09:58:00 UTC, 0 replies.
- [PR] [hotfix][connectors][CI] Replace https://archive.apache.org/ by https://dlcdn.apache.org/ for Flink release download for connectors [flink-connector-shared-utils] - posted by "echauchot (via GitHub)" <gi...@apache.org> on 2025/09/12 09:58:11 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 "mtillman-drivosity (via GitHub)" <gi...@apache.org> on 2025/09/12 10:55:03 UTC, 0 replies.
- Re: [PR] Update README.md for end-to-end tests [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/12 12:26:08 UTC, 1 replies.
- [jira] [Created] (FLINK-38353) FLIP-483: Add support for children Spans - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/09/12 14:28:00 UTC, 0 replies.
- [I] [Feature][api][java] Separate the abstraction of ChatModel to connection and setup in Java. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/12 14:32:09 UTC, 1 replies.
- [PR] [api][java] Separate the abstraction of ChatModel to connection and setup in Java. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/12 14:34:06 UTC, 2 replies.
- [PR] FLIP-483: Add support for children Spans [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/09/12 15:19:38 UTC, 0 replies.
- Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/12 15:26:29 UTC, 17 replies.
- [jira] [Updated] (FLINK-38353) FLIP-483: Add support for children Spans - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/12 15:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38351) Docker images support OpenJDK - posted by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2025/09/12 16:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-37676][cdc-common] Add caching mechanism to Selectors for improved performance [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/13 00:03:53 UTC, 2 replies.
- [jira] [Updated] (FLINK-38351) Docker images support OpenJDK - posted by "melin (Jira)" <ji...@apache.org> on 2025/09/13 03:21:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID - posted by "LiuZeshan (Jira)" <ji...@apache.org> on 2025/09/13 09:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID - posted by "LiuZeshan (Jira)" <ji...@apache.org> on 2025/09/13 09:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2025/09/13 15:55:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules - posted by "Diljeet Singh (Jira)" <ji...@apache.org> on 2025/09/13 18:04:00 UTC, 2 replies.
- [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] - posted by "suhwan-cheon (via GitHub)" <gi...@apache.org> on 2025/09/14 05:25:13 UTC, 9 replies.
- [jira] [Updated] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/14 05:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-37788] Use Java 17 instanceof pattern matching in equals() method in Flink Core… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/14 06:25:17 UTC, 1 replies.
- Re: [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/09/14 10:52:29 UTC, 3 replies.
- [PR] Reuse byte array buffer in BlobServerConnection::run [flink] - posted by "schlosna (via GitHub)" <gi...@apache.org> on 2025/09/14 11:56:26 UTC, 1 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/09/14 13:31:14 UTC, 1 replies.
- [PR] [FLINK-38319] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] - posted by "charlesdong1991 (via GitHub)" <gi...@apache.org> on 2025/09/14 18:56:44 UTC, 0 replies.
- [jira] [Updated] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/14 18:57:00 UTC, 0 replies.
- Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/14 19:03:50 UTC, 6 replies.
- [jira] [Assigned] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/15 01:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/15 01:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38354) ClassCastException occurs when submitting a task to flink cdc - posted by "hunter (Jira)" <ji...@apache.org> on 2025/09/15 03:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2025/09/15 04:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/09/15 05:23:56 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/15 05:44:00 UTC, 0 replies.
- [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/15 05:51:47 UTC, 6 replies.
- [jira] [Updated] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/15 06:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/15 06:05:00 UTC, 0 replies.
- [I] [Feature] [integration][python] OpenAI embedding model integration [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/15 06:19:44 UTC, 1 replies.
- [jira] [Updated] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/15 06:37:00 UTC, 0 replies.
- [PR] [Feature] Change default value of extract_reasoning in OllamaChatModelSetup to true [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/15 07:02:41 UTC, 1 replies.
- [jira] [Created] (FLINK-38355) [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/09/15 07:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38355) [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/09/15 07:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38350) Update Hadoop Library to 3.4.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/09/15 07:21:00 UTC, 1 replies.
- [PR] Mcp complete 1 [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/15 07:28:19 UTC, 0 replies.
- [jira] [Closed] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/15 08:08:00 UTC, 0 replies.
- [PR] [hotfix] fix reasoning extraction from Tongyi model [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/15 08:24:46 UTC, 3 replies.
- [PR] [docs] Update installation instructions for Flink Agents with PyPI and source build details [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/15 09:44:41 UTC, 2 replies.
- [jira] [Updated] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/09/15 12:09:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/09/15 12:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/09/15 12:09:00 UTC, 0 replies.
- [PR] [FLINK-38356] Respect terminating flag for test values source [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/09/15 12:21:20 UTC, 3 replies.
- [jira] [Created] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 - posted by "Xinglong Wang (Jira)" <ji...@apache.org> on 2025/09/15 13:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 - posted by "Xinglong Wang (Jira)" <ji...@apache.org> on 2025/09/15 13:41:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 - posted by "Xinglong Wang (Jira)" <ji...@apache.org> on 2025/09/15 13:55:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38350) Update Hadoop Library to 3.4.2 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/09/15 15:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36694) Update Hadoop shaded from 3.3.4 to 3.4.1 - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/09/15 16:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/15 17:34:00 UTC, 0 replies.
- [PR] now issue is resolved [flink] - posted by "1Kunalvats9 (via GitHub)" <gi...@apache.org> on 2025/09/15 18:54:55 UTC, 3 replies.
- [PR] Simple change to merge and help run automated tests afterwards [flink-kubernetes-operator] - posted by "schongloo (via GitHub)" <gi...@apache.org> on 2025/09/15 22:18:27 UTC, 0 replies.
- Re: [PR] Fixing typos in README.md files [flink-kubernetes-operator] - posted by "morhidi (via GitHub)" <gi...@apache.org> on 2025/09/15 23:30:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 05:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 06:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 06:49:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36980) Build a new introductory practice "Streaming ELT from MySQL to Kafka" - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 07:23:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/16 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38358) Ignore trailing spaces in table capturing rules - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 07:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38332) Upgrade pemja to 0.5.5 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/16 07:48:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 08:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38358) Ignore trailing spaces in table capturing rules - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 08:16:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38358) Ignore trailing spaces in table capturing rules - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38360) HadoopRecoverableWriterTest failed in test_cron_adaptive_scheduler connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/16 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/16 08:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 08:46:00 UTC, 0 replies.
- [PR] [FLINK-38359][pipeline-connector][paimon] Avoid exception when writing update event to Append only table. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/16 08:52:37 UTC, 2 replies.
- [jira] [Updated] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/16 08:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-26823) Make Cassandra Source available for Flink SQL users - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/09/16 08:56:00 UTC, 0 replies.
- Re: [PR] [docs] Adding Confluent to vendors list [flink] - posted by "gunnarmorling (via GitHub)" <gi...@apache.org> on 2025/09/16 09:15:19 UTC, 0 replies.
- [PR] [Feature] Unify the name of ResourceProvider and Resource [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/16 09:18:57 UTC, 3 replies.
- Re: [PR] [FLINK-37697][Documentation] Adding Confluent to vendors list [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/16 09:30:03 UTC, 2 replies.
- Re: [PR] [FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image [flink-cdc] - posted by "yuanoOo (via GitHub)" <gi...@apache.org> on 2025/09/16 09:50:29 UTC, 1 replies.
- [I] [Feature] ActionExecutionOperator handle watermark properly [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/16 09:53:35 UTC, 1 replies.
- [I] [Feature][examples] Showcase Table API in the quickstart example [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/16 09:58:25 UTC, 0 replies.
- Re: [PR] [api][python] Add built-in mcp support [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/16 10:08:46 UTC, 5 replies.
- Re: [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/16 10:09:13 UTC, 10 replies.
- Re: [PR] [FLINK-38352][table] Expose timestamp used in DefaultWatermarkGenerator [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/09/16 10:52:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-38352) Expose timestamp used in DefaultWatermarkGenerator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/16 10:53:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38352) Expose timestamp used in DefaultWatermarkGenerator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/16 10:54:00 UTC, 0 replies.
- Re: [PR] [Feature] [integration][python] OpenAI embedding model integration [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/16 11:15:16 UTC, 1 replies.
- Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/16 11:23:18 UTC, 5 replies.
- [jira] [Resolved] (FLINK-38265) Stream Split shouldn't finish when exception occors - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 11:50:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38362) Reduce the time cost in checkpoint when writing many tables to StarRocks sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 12:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-37979] Remove obsolete MySQL CDC snapshot split assigner code [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/16 12:32:15 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/16 12:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/16 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38363) WindowedStream.trigger supports trigger with async state - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/16 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/16 12:46:00 UTC, 0 replies.
- [PR] [hotfix] Pin rsync by hash to allow docs to be build [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/09/16 13:20:47 UTC, 2 replies.
- [jira] [Updated] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/16 13:31:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/16 13:31:00 UTC, 0 replies.
- [PR] [FLINK-38365][table] Make invalid operations with `MATERIALIZED TABLE`s returning more user friendly message [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/16 13:34:30 UTC, 5 replies.
- [jira] [Created] (FLINK-38366) Pyflink planner throws exception in batch mode when there is no limit on order_by() - posted by "Ahmad Humayun (Jira)" <ji...@apache.org> on 2025/09/16 15:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38366) Pyflink planner throws exception in batch mode when there is no limit on order_by() - posted by "Ahmad Humayun (Jira)" <ji...@apache.org> on 2025/09/16 15:12:00 UTC, 2 replies.
- [PR] Fix CI and upgrade to use Flink 1.18.1 [flink-connector-pulsar] - posted by "lhotari (via GitHub)" <gi...@apache.org> on 2025/09/16 16:50:06 UTC, 1 replies.
- [jira] [Created] (FLINK-38367) Potential Feedback Loop Between IterationHeadTask and SynchronizationSinkTask - posted by "Shangshu Qian (Jira)" <ji...@apache.org> on 2025/09/16 20:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38368) Potential Feedback Loop Involving a Heavy User Defined Aggregation Task - posted by "Shangshu Qian (Jira)" <ji...@apache.org> on 2025/09/16 20:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/16 21:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/16 21:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/16 21:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/16 21:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/16 21:23:00 UTC, 0 replies.
- Re: [PR] [FLINK-38358][pipeline-connector][mysql] Ignore trailing spaces in table capturing rules. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/17 01:33:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-38358) Ignore trailing spaces in table capturing rules - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/17 01:34:00 UTC, 0 replies.
- Re: [PR] [api][java] Support interactive interface of Agent and AgentExecutionEnvironment. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/17 01:43:16 UTC, 0 replies.
- Re: [PR] [hotfix][postgres] PostgresSourceFetchTaskContext log do not output P… [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/17 01:43:21 UTC, 0 replies.
- Re: [I] [Feature][api][java] Support interactive interface of Agent and AgentExecutionEnvironment. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/17 01:43:24 UTC, 0 replies.
- [D] Flink Agent Project Docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/17 02:19:12 UTC, 11 replies.
- Re: [I] [Feature] Use Python property to simplify the getter in RunnerContext [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/17 03:24:27 UTC, 1 replies.
- [PR] [api] Add TaskActionState API to persist task action state [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/09/17 03:26:50 UTC, 1 replies.
- Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/17 03:45:14 UTC, 5 replies.
- [jira] [Resolved] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/17 04:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38358) Ignore trailing spaces in table capturing rules - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/17 04:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-36631] add oracle read data by specific offset [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/17 05:57:06 UTC, 2 replies.
- Re: [PR] Simple test PR [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/09/17 05:57:12 UTC, 0 replies.
- Re: [PR] [FLINK-31215] [autoscaler] Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/09/17 05:59:17 UTC, 1 replies.
- Re: [PR] [FLINK-37682] Upgrade Jackson Lib to Address CVE-2023-35116 [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/09/17 05:59:23 UTC, 1 replies.
- Re: [PR] [minor][improvement] Add subdirectory scrapping to add all .jar in classpath [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/17 06:01:57 UTC, 2 replies.
- Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/17 06:06:34 UTC, 2 replies.
- [jira] [Commented] (FLINK-38360) HadoopRecoverableWriterTest failed in test_cron_adaptive_scheduler connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/17 06:27:00 UTC, 1 replies.
- [PR] Add partitioned async deserialization with ordered emission [flink-cdc] - posted by "saligia-tju (via GitHub)" <gi...@apache.org> on 2025/09/17 06:51:20 UTC, 1 replies.
- [PR] [hotfix][docs] Pull request to update documentation for Flink 2.0 support. [flink-kubernetes-operator] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2025/09/17 07:10:02 UTC, 0 replies.
- [PR] [hotfix] Adapt ollama integration after refactor chat model api. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/17 07:33:28 UTC, 1 replies.
- [PR] [hotfix][docs] Pull request to update documentation for Flink 2.0 support. (v 1.11) [flink-kubernetes-operator] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2025/09/17 07:33:36 UTC, 2 replies.
- [jira] [Created] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/17 07:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38332) Upgrade pemja to 0.5.5 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/09/17 07:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38332) Upgrade pemja to 0.5.5 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/09/17 07:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38332) Upgrade pemja to 0.5.5 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/09/17 07:47:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37295) Update state ttl migration compatibility in docs - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/09/17 08:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37295) Update state ttl migration compatibility in docs - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/09/17 08:29:00 UTC, 0 replies.
- [PR] [Feature][API][python] Use Python property to simplify the getter in RunnerContext [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/17 08:53:41 UTC, 5 replies.
- [jira] [Created] (FLINK-38370) CommitterOperator does not checkpoint all pending committables - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/17 08:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/17 08:55:00 UTC, 6 replies.
- [jira] [Created] (FLINK-38371) Add `sink.retry-on-conflicts` option to Elasticsearch Sink - posted by "Liu (Jira)" <ji...@apache.org> on 2025/09/17 09:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/09/17 09:21:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38372) Introduces whitelist to the flink-metrics-prometheus - posted by "Liu (Jira)" <ji...@apache.org> on 2025/09/17 09:30:00 UTC, 0 replies.
- [PR] Pashley/flink 38350 release 1.20 [flink] - posted by "pra91 (via GitHub)" <gi...@apache.org> on 2025/09/17 09:37:08 UTC, 1 replies.
- Re: [I] [Feature] Support MCP integration [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/17 09:41:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-37246) Delegation Token expire after enable delegation token framework - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/17 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38373) Support dynamic index generation with field value suffix - posted by "Liu (Jira)" <ji...@apache.org> on 2025/09/17 09:46:00 UTC, 0 replies.
- [PR] Support MySQL in-source parallel deserialization [flink-cdc] - posted by "saligia-tju (via GitHub)" <gi...@apache.org> on 2025/09/17 09:53:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-37246) Delegation Token expire after enable delegation token framework - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/17 09:55:00 UTC, 0 replies.
- [PR] [FLINK-37968][Connectors/Kinesis] Update netty version to v4.1.127.Final [flink-connector-aws] - posted by "Neo2308 (via GitHub)" <gi...@apache.org> on 2025/09/17 10:47:50 UTC, 2 replies.
- [PR] [FLINK-38371][Connectors / ElasticSearch] Add `sink.retry-on-conflicts` option to Elasticsearch Sink [flink-connector-elasticsearch] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2025/09/17 11:23:53 UTC, 1 replies.
- [jira] [Updated] (FLINK-38371) Add `sink.retry-on-conflicts` option to Elasticsearch Sink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/17 11:24:00 UTC, 0 replies.
- [PR] [FLINK-38373][Connectors / ElasticSearch] Support dynamic index generation with field value suffix [flink-connector-elasticsearch] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2025/09/17 11:56:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-38373) Support dynamic index generation with field value suffix - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/17 11:57:00 UTC, 0 replies.
- [PR] [FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2025/09/17 12:10:44 UTC, 3 replies.
- [jira] [Updated] (FLINK-38372) Introduces whitelist to the flink-metrics-prometheus - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/17 12:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/09/17 12:32:38 UTC, 7 replies.
- [jira] [Updated] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/17 12:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/17 12:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35229) join An error occurred when the table was empty - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/17 12:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36113) Condition 'transform instanceof PhysicalTransformation' is always 'false' - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/17 12:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36010) Duplicate Job Submission returns Succeeded on single execution even if Global state is FAILED - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/17 12:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36609) Protobuf Format not support proto3 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/17 12:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37147) The where condition run time advance caused a program error - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/17 12:47:00 UTC, 0 replies.
- [PR] Update Minikube version to 1.28.0 [flink-kubernetes-operator] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/17 14:46:29 UTC, 1 replies.
- [jira] [Created] (FLINK-38374) Add Artifact keyword as an option to create function syntax - posted by "Zander Matheson (Jira)" <ji...@apache.org> on 2025/09/17 19:54:00 UTC, 0 replies.
- [PR] [FLINK-38374][SQL API] [flink] - posted by "awmatheson (via GitHub)" <gi...@apache.org> on 2025/09/17 21:56:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-38374) Add Artifact keyword as an option to create function syntax - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/17 21:57:00 UTC, 0 replies.
- [jira] (FLINK-38374) Add Artifact keyword as an option to create function syntax - posted by "Zander Matheson (Jira)" <ji...@apache.org> on 2025/09/17 21:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38374) Add Artifact keyword as an option to create function syntax - posted by "Zander Matheson (Jira)" <ji...@apache.org> on 2025/09/17 21:58:00 UTC, 0 replies.
- Re: [PR] [FLINK-38374][SQL API] Introduce new ARTIFACT keyword as an alternative to JAR [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/17 22:00:14 UTC, 2 replies.
- [PR] [hotfix] fix the title of docs index [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/18 01:31:54 UTC, 1 replies.
- [PR] [minor] Fix potential sql connection statement issue. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/18 01:49:20 UTC, 5 replies.
- Re: [I] [Feature] support VectorStore and provide a built-in Chroma implementation [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/18 02:01:57 UTC, 0 replies.
- Re: [PR] [Feature] Remove the name field of Resource [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/18 02:07:37 UTC, 4 replies.
- Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/09/18 02:36:28 UTC, 9 replies.
- [jira] [Updated] (FLINK-38343) Support store rescale history with statistics by ExecutionGraphInfoStore. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/18 02:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38333) Umbrella: FLIP-495: Support AdaptiveScheduler record and query the rescale history - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/18 04:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38333) Umbrella: FLIP-495: Support AdaptiveScheduler record and store the rescale history - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/09/18 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38375) Flink Resouce leak on Flink k8s - posted by "xiaolong3817 (Jira)" <ji...@apache.org> on 2025/09/18 05:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s - posted by "xiaolong3817 (Jira)" <ji...@apache.org> on 2025/09/18 05:42:00 UTC, 9 replies.
- Re: [PR] [FLINK-33045][format avro-confluent] disable auto-registering schema in registry [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/18 06:25:50 UTC, 0 replies.
- [PR] [minor] Fix SQL injection vulnerabilities in OceanBase connector [flink-cdc] - posted by "yuanoOo (via GitHub)" <gi...@apache.org> on 2025/09/18 06:28:21 UTC, 1 replies.
- [PR] [FLINK-38375][runtime] fix report slot numbers error [flink] - posted by "low-bee (via GitHub)" <gi...@apache.org> on 2025/09/18 07:20:57 UTC, 3 replies.
- [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/09/18 07:50:00 UTC, 8 replies.
- [PR] feat: support avro primitive keys [flink] - posted by "parisni (via GitHub)" <gi...@apache.org> on 2025/09/18 08:05:07 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-38370) CommitterOperator does not checkpoint all pending committables - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/09/18 08:58:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38376) AsyncStateStreamingJoinOperator should not OOM due to collecting all matching records in memory - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/18 09:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38376) AsyncStateStreamingJoinOperator should not OOM due to collecting all matching records in memory - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/18 09:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38376) AsyncStateStreamingJoinOperator should not OOM due to collecting all matching records in memory - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/18 09:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/18 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38377) SQL Job Submission in the Flink Kubernetes Operator via SQL Gateway - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/09/18 10:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38377) SQL Job Submission in the Flink Kubernetes Operator via SQL Gateway - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/09/18 10:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38377) SQL Job Submission in the Flink Kubernetes Operator via SQL Gateway - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/09/18 10:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37411) Introduce the rollback mechanism for Autoscaler - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/18 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38378) Use ValidationException in CatalogManager in case of user error - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/18 11:10:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38370) CommitterOperator does not checkpoint all pending committables - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/18 11:11:00 UTC, 0 replies.
- [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error in CatalogManager [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/18 11:14:02 UTC, 1 replies.
- [jira] [Updated] (FLINK-38378) Use ValidationException in CatalogManager in case of user error - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 11:15:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:18:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:19:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38059) [docs] Add fluss pipeline connector documentation - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37736) Introduce Flink CDC metrics doc - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37095) test case that used AI model may met quota not enough exception. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35757) support read new tables when scanNewlyTableAdded is enabled - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35757) support read new tables when scanNewlyTableAdded is enabled - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37277) Add guidance for configuring different kind of catalog of Paimon Sink. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37349) Add timeout for test case that call waitForSinkSize method to avoid Infinite waiting - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37128) Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:32:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent correctly. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:34:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37065) MySQL cdc can lose/skip data during recovering from the checkpoint - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37200) Add e2e test for ElasticSearch Sink. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37331) Add comprehensive data type coverage tests for new MysqlSource implementation - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35664) Flink CDC pipeline transform supports mask function - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35713) Add sink PARALLELISM for flink-cdc - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36813) MySQLCDC supports synchronization of specified fields - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36546) Handle batch sources in DataSinkTranslator - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37630) Support flink cdc pipeline Yarn session mode - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37209) Add Embedding AI Model for Qwen - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37762) No Infomation in Overview at Flink CDC 3.4 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37641) Fix: SchemaEvolveE2eITCase.testLenientSchemaEvolution timeout - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36163) Kafka cdc pipeline source supports protobuf format. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37454) Unit Tests (mongodb6) / compile_and_test (8, generic) is not stable - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37346) [CI] Unit Tests (mysql) / compile_and_test (8, generic) (pull_request)Failing after 60m - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38232) [docs] updates the connector documentation to reflect the new features in Flink CDC 3.4.0 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 11:39:00 UTC, 0 replies.
- [PR] [FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/18 11:40:52 UTC, 3 replies.
- [jira] [Created] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/18 11:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/18 11:51:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-38293) Update Checkstyle version and related rules in Kubernetes Operator - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/18 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38380) MySQL cdc may skip data in the GTID disordered scenario even after GTID merged - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 12:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38380) MySQL cdc may skip data in the GTID disordered scenario even after GTID merged - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/18 12:17:00 UTC, 0 replies.
- [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/09/18 12:21:37 UTC, 9 replies.
- [jira] [Updated] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 12:22:00 UTC, 0 replies.
- [PR] [FLINK-38280][Build/Shaded] Update ASM to 9.8. [flink-shaded] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/18 12:48:35 UTC, 1 replies.
- [jira] [Updated] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 12:49:00 UTC, 1 replies.
- [PR] Add Kubernetes Operator 1.13.0 release [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/09/18 12:49:58 UTC, 2 replies.
- [jira] [Created] (FLINK-38381) Autoscaler does not enumerate partitions across kafka clusters - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/18 13:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/09/18 13:46:01 UTC, 7 replies.
- [PR] [FLINK-38381] Enumerate Kafka partitions across Kafka clusters [flink-kubernetes-operator] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/18 13:51:51 UTC, 1 replies.
- [jira] [Updated] (FLINK-38381) Autoscaler does not enumerate partitions across kafka clusters - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 13:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-23426) Support changelog processing in batch mode - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/18 14:19:00 UTC, 0 replies.
- [I] [Feature] Async action properly handle checkpoint and per-action state [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/18 14:26:18 UTC, 1 replies.
- [jira] [Created] (FLINK-38382) Confluent Schema Registry to support primitive types - posted by "nicolas paris (Jira)" <ji...@apache.org> on 2025/09/18 14:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-38382][kafka] Support avro primitive types in Confluent Schema Registry binding [flink] - posted by "parisni (via GitHub)" <gi...@apache.org> on 2025/09/18 14:45:19 UTC, 0 replies.
- [jira] [Updated] (FLINK-38382) Confluent Schema Registry to support primitive types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 14:46:00 UTC, 0 replies.
- [PR] [hotfix] Bump Java setup action to version 5 [flink-shaded] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/18 14:53:09 UTC, 1 replies.
- [PR] [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/09/18 14:54:26 UTC, 5 replies.
- [jira] [Created] (FLINK-38383) Automatically republish Flink Kubernetes Operator image when base image receives security patches - posted by "Jaydeep Karia (Jira)" <ji...@apache.org> on 2025/09/18 15:13:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/18 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38384) Bump lombok to 1.18.40 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/18 15:41:00 UTC, 0 replies.
- [PR] [FLINK-38384][build] Bump lombok to 1.18.40 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/18 15:55:02 UTC, 2 replies.
- [jira] [Updated] (FLINK-38384) Bump lombok to 1.18.40 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38385) Bump byte-buddy to 1.17.6 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/18 16:36:00 UTC, 0 replies.
- [PR] [FLINK-38385][build] Bump mockito to 5.19.0 and bute-buddy to 1.17.6 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/18 16:42:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-38385) Bump byte-buddy to 1.17.6 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 16:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-38385][build] Bump mockito to 5.19.0 and byte-buddy to 1.17.6 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/18 16:50:23 UTC, 1 replies.
- [jira] [Created] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/18 16:57:00 UTC, 0 replies.
- [PR] [FLINK-38386][build] Fix attaching type annotations for jdk23+ [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/18 17:13:01 UTC, 4 replies.
- [jira] [Updated] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38387) Bump spotless - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/18 17:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38388) FLIP-541 Umbrella Issue - posted by "Zander Matheson (Jira)" <ji...@apache.org> on 2025/09/18 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38389) Add .show(), .head() and .tail() method to PyFlink Table API - posted by "Zander Matheson (Jira)" <ji...@apache.org> on 2025/09/18 18:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38390) Compiliation of flink-core and flink-table-planner fails because of annotation processors - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/18 18:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-23426) Support changelog processing in batch mode - posted by "Alexey Leonov-Vendrovskiy (Jira)" <ji...@apache.org> on 2025/09/18 19:04:00 UTC, 0 replies.
- [PR] [FLINK-38390][table] Compiliation of flink-core and flink-table-planner fails because of annotation processors [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/18 19:07:51 UTC, 9 replies.
- [jira] [Updated] (FLINK-38390) Compiliation of flink-core and flink-table-planner fails because of annotation processors - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 19:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38391) Error creating shaded jar: Problem shading JAR Unsupported class file major version 69 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/18 21:50:00 UTC, 0 replies.
- [PR] [FLINK-38391][build] Bump maven-shade-plugin to 3.6.1 to support java 25 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/18 22:00:51 UTC, 3 replies.
- [jira] [Updated] (FLINK-38391) Error creating shaded jar: Problem shading JAR Unsupported class file major version 69 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/18 22:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version - posted by "Rui Xia (Jira)" <ji...@apache.org> on 2025/09/19 03:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38363) WindowedStream.trigger supports trigger with async state - posted by "Rui Xia (Jira)" <ji...@apache.org> on 2025/09/19 03:12:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/19 03:23:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38363) WindowedStream.trigger supports trigger with async state - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/19 03:24:00 UTC, 0 replies.
- [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2025/09/19 03:50:55 UTC, 6 replies.
- [jira] [Updated] (FLINK-33115) AbstractHadoopRecoverableWriterITCase is hanging with timeout on AZP - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/19 03:51:00 UTC, 0 replies.
- [PR] [build] Update version to 3.6-SNAPSHOT. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/19 03:52:51 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/09/19 05:15:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/09/19 05:19:00 UTC, 0 replies.
- Re: [PR] Fix CVE-2022-25168 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 06:25:58 UTC, 1 replies.
- Re: [PR] [FLINK-37817] Adds bundled aggregates for group by (FLIP-491) [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 06:26:01 UTC, 1 replies.
- Re: [PR] [FLINK-37854][table] Support DATE_FORMAT with zone [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 06:26:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/19 06:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/19 06:35:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/19 07:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38277) Enhance postgresSQL slot management capabilities - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/19 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38392) StreamPandasConversionTests failing - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2025/09/19 07:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38079) Add Pipeline support for DateType and TimeType - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/19 07:43:00 UTC, 0 replies.
- [PR] [backport][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/19 07:46:08 UTC, 1 replies.
- [PR] [backport][release-2.0][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/19 08:01:08 UTC, 1 replies.
- [PR] [backport][release-2.1][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/19 08:05:44 UTC, 0 replies.
- [PR] [backport][release-1.19][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/19 08:10:32 UTC, 0 replies.
- Re: [PR] [release-2.1][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/19 08:12:47 UTC, 1 replies.
- [PR] Add FlinkCDC v3.5.0. [flink-web] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/19 08:18:28 UTC, 7 replies.
- Re: [PR] [release-1.19][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/19 08:21:25 UTC, 1 replies.
- Re: [PR] [release-1.20][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/19 08:31:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-38384) Bump lombok to 1.18.42 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/19 08:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38384) Bump lombok to 1.18.42 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/19 08:46:00 UTC, 0 replies.
- [PR] [Feature] ActionExecutionOperator handle watermark properly [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/19 09:54:57 UTC, 1 replies.
- Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2025/09/19 10:01:31 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/09/19 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/09/19 11:27:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38381) Autoscaler does not enumerate partitions across kafka clusters - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/19 11:28:00 UTC, 0 replies.
- [PR] [FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/09/19 11:41:21 UTC, 3 replies.
- [jira] [Updated] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/19 11:42:00 UTC, 0 replies.
- [PR] [FLINK-38279] Add SnapshotPendingSplitsState to MySQL checkpoint stat… [flink-cdc] - posted by "dwash96 (via GitHub)" <gi...@apache.org> on 2025/09/19 12:03:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-38279) Failed to restore job when using MySQL Source with scan.startup.mode=snapshot in streaming mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/19 12:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38352) Expose timestamp used in DefaultWatermarkGenerator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/19 12:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/09/19 13:03:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/09/19 13:03:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/09/19 13:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/09/19 13:43:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/09/19 13:45:00 UTC, 0 replies.
- Re: [PR] [release-2.0][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/19 14:01:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38378) Use ValidationException in CatalogManager in case of user error - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/19 14:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38378) Use ValidationException in CatalogManager in case of user error - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/19 14:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/19 14:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38385) Bump byte-buddy to 1.17.6 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/19 17:43:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38385) Bump byte-buddy to 1.17.6 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/19 17:43:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38391) Error creating shaded jar: Problem shading JAR Unsupported class file major version 69 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/19 18:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38394) Upgrade Flink CDC to Flink 2 - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/09/19 21:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments - posted by "Sergio Chong (Jira)" <ji...@apache.org> on 2025/09/19 22:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments - posted by "Sergio Chong (Jira)" <ji...@apache.org> on 2025/09/19 22:38:00 UTC, 4 replies.
- [I] [Feature] Support Chroma Cloud [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/19 23:53:52 UTC, 1 replies.
- [PR] [Feature] Support Chroma Cloud [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/19 23:58:50 UTC, 1 replies.
- Re: [PR] [Feature] [api] Introduce per action state consistency API [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/09/20 05:39:55 UTC, 6 replies.
- Re: [PR] [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/20 09:47:19 UTC, 3 replies.
- [PR] [FLINK-38268] Fix incorrect serialization of VARIANT type FLOAT [flink] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2025/09/20 11:26:48 UTC, 8 replies.
- [jira] [Updated] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/20 11:27:00 UTC, 0 replies.
- [PR] Add Flink 1.20.3 release [flink-web] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/20 16:05:14 UTC, 1 replies.
- [PR] [FLINK-38392] Fix failing test in StreamPandasConversionTests [flink] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2025/09/20 19:27:57 UTC, 5 replies.
- [jira] [Updated] (FLINK-38392) StreamPandasConversionTests failing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/20 19:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/21 09:08:00 UTC, 0 replies.
- [PR] [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/21 09:18:32 UTC, 8 replies.
- [jira] [Updated] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/21 09:19:00 UTC, 0 replies.
- [PR] [FLINK-38110] fix PostgreSQL connector reads Chinese columns with garbled charactor [flink-cdc] - posted by "qingfei1994 (via GitHub)" <gi...@apache.org> on 2025/09/21 13:00:19 UTC, 0 replies.
- [jira] [Updated] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/21 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38397) Runtime Exception in Planner - posted by "Ahmad Humayun (Jira)" <ji...@apache.org> on 2025/09/21 17:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38397) Runtime Exception in Planner - posted by "Ahmad Humayun (Jira)" <ji...@apache.org> on 2025/09/21 17:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38397) Runtime Exception in Planner - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/09/21 18:16:00 UTC, 0 replies.
- Re: [I] [Feature] Unify the name of ResourceProvider and Resource [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/22 01:59:36 UTC, 0 replies.
- Re: [PR] [FLINK-38224][table-planner] Do not convert to delta join when the sink is a retract sink [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/09/22 02:02:23 UTC, 5 replies.
- [jira] [Created] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/09/22 02:22:00 UTC, 0 replies.
- [PR] [FLINK-38398] Improve postgresSQL field Type supported precision.mode=connect [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/09/22 02:23:47 UTC, 2 replies.
- [jira] [Updated] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/22 02:24:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/09/22 02:41:00 UTC, 0 replies.
- [PR] [FLINK-38399][table-planner] Convert join to delta join if join key contains one of the indexes in the source [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/09/22 02:48:33 UTC, 3 replies.
- [jira] [Updated] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/22 02:49:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/09/22 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/22 03:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/22 03:39:00 UTC, 3 replies.
- [PR] [BP-3.5][FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/09/22 03:50:43 UTC, 1 replies.
- [PR] [FLINK-38363][Runtime] WindowedStream.trigger supports trigger with async state [flink] - posted by "jiexray (via GitHub)" <gi...@apache.org> on 2025/09/22 04:14:36 UTC, 6 replies.
- [jira] [Updated] (FLINK-38363) WindowedStream.trigger supports trigger with async state - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/22 04:15:00 UTC, 0 replies.
- [I] [Feature] [api][plan][java] Support built-in ReAct Agent in Java. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/22 05:50:33 UTC, 1 replies.
- [PR] [api][plan][java] Support built-in ReAct Agent in Java. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/22 05:51:52 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/22 06:09:00 UTC, 0 replies.
- Re: [PR] [DON"T REVIEW] Empty commit to trigger a CI test for FLINK-37892 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/22 06:25:57 UTC, 0 replies.
- [PR] [FLINK-38398][pipeline-connector][postgresql] Improve PostgresSQL temporal field type supported with debezium.time.precision.mode=connect config(#4129) [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/09/22 06:50:43 UTC, 1 replies.
- [PR] [FLINK-38398][pipeline-connector][postgresql] Improve PostgresSQL temporal field type supported with debezium.time.precision.mode=connect config [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/09/22 06:58:11 UTC, 1 replies.
- [jira] [Updated] (FLINK-37859) FLIP-516: Streaming Multi-Way Join Optimization - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/22 07:18:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/22 07:27:00 UTC, 0 replies.
- [PR] [WIP] Draft the first version of the overall project docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/22 07:28:44 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/09/22 07:37:00 UTC, 0 replies.
- [PR] [FLINK-38398][pipeline-connector][postgres] fixed Date convert adapte connect [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/09/22 07:55:40 UTC, 0 replies.
- [PR] [FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/09/22 07:59:03 UTC, 4 replies.
- [jira] [Created] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:01:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38370) CommitterOperator does not checkpoint all pending committables - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/09/22 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:08:00 UTC, 10 replies.
- [jira] [Created] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38407) GroupAggregateRestoreTest failed in test_cron_azure table - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:10:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:12:00 UTC, 14 replies.
- [jira] [Commented] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/22 08:13:00 UTC, 1 replies.
- [PR] [FLINK-38401][table] Add getUpsertKeys support for StreamPhysicalMultiJoin [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/09/22 08:25:29 UTC, 2 replies.
- [jira] [Updated] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/22 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38409) Showcase in Helm chart values.yaml that config.yaml can be used - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/09/22 08:55:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split. - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/09/22 09:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters - posted by "haiqingchen (Jira)" <ji...@apache.org> on 2025/09/22 09:20:00 UTC, 0 replies.
- Re: [PR] [Feature] Implemenet Kafka-based state store [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/22 10:16:06 UTC, 9 replies.
- Re: [PR] [FLINK-38409] Showcase in Helm chart values.yaml that config.yaml can be used [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/09/22 11:25:57 UTC, 2 replies.
- [jira] [Updated] (FLINK-38409) Showcase in Helm chart values.yaml that config.yaml can be used - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/22 11:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-38398][pipeline-connector][postgres] fixed Date convert adapt connect [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/22 11:49:28 UTC, 0 replies.
- [jira] [Created] (FLINK-38410) Log test id on failure for RestoreTestBase and SemanticTestBase suites - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/22 13:07:00 UTC, 0 replies.
- [PR] [FLINK-38410][table] Add test id to assertion message for RestoreTestBase and SemanticTestBase suites [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/09/22 13:24:27 UTC, 2 replies.
- [jira] [Updated] (FLINK-38410) Log test id on failure for RestoreTestBase and SemanticTestBase suites - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/22 13:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/22 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38411) Array index overflow in enumerator with continuous file source - posted by "Simon Frei (Jira)" <ji...@apache.org> on 2025/09/22 14:02:00 UTC, 0 replies.
- [PR] [FLINK-16686][State] Set classloader for compaction filters [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/09/22 15:35:53 UTC, 9 replies.
- [jira] [Updated] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/22 15:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/22 15:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/22 15:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/22 18:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/22 18:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38394) Upgrade Flink CDC to Flink 2 - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/09/22 20:01:00 UTC, 0 replies.
- [PR] [FLINK-33100] Implement YarnJobListFetcher [flink-kubernetes-operator] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2025/09/22 20:41:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-33100) Implement YarnJobFetcher for Standalone Autoscaler - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/22 20:42:00 UTC, 0 replies.
- [PR] Upgrade hadoop [flink] - posted by "ctrlaltdilj (via GitHub)" <gi...@apache.org> on 2025/09/23 02:11:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/23 02:13:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/23 02:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-30975] Upgrade hadoop to 3.4.X [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/23 02:17:21 UTC, 0 replies.
- [PR] [FLINK-38364][runtime] Implement async state version of ProcessingTimeoutTrigger [flink] - posted by "jiexray (via GitHub)" <gi...@apache.org> on 2025/09/23 02:18:58 UTC, 7 replies.
- [jira] [Updated] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/23 02:19: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/09/23 03:07:08 UTC, 1 replies.
- [PR] [build] Automate property replacement in pom.xml and exclude the release directory from license checks. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/23 03:59:31 UTC, 2 replies.
- Re: [PR] [FLINK-36456] Add support to pass Datadog API Key as environment variable [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 06:25:47 UTC, 0 replies.
- Re: [PR] [FLINK-37938] ml_evaluation accumulator implementation [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 06:25:51 UTC, 0 replies.
- Re: [PR] [FLINK-37921][table] Replace TableKeyedAsyncWaitOperator with new operator under new async framework [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 06:25:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-37921) Refactor current implementation to reduce code duplication - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/23 06:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/09/23 06:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/09/23 06:55:00 UTC, 0 replies.
- [PR] [docs] Add a FAQ section for common questions [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/23 07:15:37 UTC, 6 replies.
- Re: [I] [Tech Debt] PEMJA Fails to Print Error Messages When Java Throw Exceptions [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/23 07:21:31 UTC, 1 replies.
- [jira] [Closed] (FLINK-38315) Performance regression since August 21 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/23 07:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38315) Performance regression since August 21 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/23 07:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38410) Log test id on failure for RestoreTestBase and SemanticTestBase suites - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/23 07:56:00 UTC, 0 replies.
- [I] [Feature] [package] Refactor the packaging of Flink-Agents. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/23 08:55:12 UTC, 1 replies.
- [PR] [package] Refactor the packaging of Flink-Agents [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/23 08:58:26 UTC, 3 replies.
- [PR] Add AI Documentation Support [flink] - posted by "keshavpandya06 (via GitHub)" <gi...@apache.org> on 2025/09/23 09:31:12 UTC, 5 replies.
- [jira] [Created] (FLINK-38412) Refactor MultiJoin test with state ttl to avoid state expiration - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/23 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38413) Support Append Only table from MySQL Pipeline Connectors - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/09/23 10:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36684) Support read changelog as append only mode for MySQL CDC connector - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/09/23 10:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38413) Support Append Only table from MySQL Pipeline Connectors - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/09/23 10:11:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38414) Add Vitess Pipeline Connector with Parallel Shard Reading Support - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/09/23 10:25:00 UTC, 0 replies.
- [PR] [FLINK-38412][table] Adjust test to not rely on eventually expired records [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/09/23 10:39:35 UTC, 3 replies.
- [jira] [Updated] (FLINK-38412) Refactor MultiJoin test with state ttl to avoid state expiration - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/23 10:40:00 UTC, 0 replies.
- [PR] [minor][doc] Correct type name in postgres.md. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/09/23 11:43:04 UTC, 1 replies.
- [jira] [Created] (FLINK-38415) IndexOutOfBoundsException occasionally occursIndexOutOfBoundsException in rocksdb.use-ingest-db-restore-mode after rocksdb.use-ingest-db-restore-mode is enabled - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/09/23 11:55:00 UTC, 0 replies.
- [PR] Adding support for append only tables to MySQL Pipeline connector [flink-cdc] - posted by "junmuz (via GitHub)" <gi...@apache.org> on 2025/09/23 12:52:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-38415) IndexOutOfBoundsException occasionally occurs after rocksdb.use-ingest-db-restore-mode is enabled - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/09/23 13:17:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-38415) IndexOutOfBoundsException occasionally occurs in rocksdb.use-ingest-db-restore-mode after rocksdb.use-ingest-db-restore-mode is enabled - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/09/23 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38416) Wrong constructor argument order for NestedMapConstraint - posted by "Ryan Murray (Jira)" <ji...@apache.org> on 2025/09/23 13:22:00 UTC, 0 replies.
- [PR] [FLINK-38416] bugfix correct constructor arg order [flink] - posted by "rymurr (via GitHub)" <gi...@apache.org> on 2025/09/23 13:23:10 UTC, 4 replies.
- [jira] [Updated] (FLINK-38416) Wrong constructor argument order for NestedMapConstraint - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/23 13:24:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38416) Wrong constructor argument order for NestedMapConstraint - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/09/23 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38417) Ensure attribute ordering when managing join attributes in JoinKeyExtractor - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/23 13:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38414) Add Vitess Pipeline Connector with Parallel Shard Reading Support - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/09/23 15:17:00 UTC, 3 replies.
- [PR] [FLINK-38100] [feat] bump iceberg to 1.10.0 [flink-cdc] - posted by "locchipinti (via GitHub)" <gi...@apache.org> on 2025/09/23 15:28:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-38100) Add BigQuery catalog support for iceberg pipeline sink connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/23 15:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38363) WindowedStream.trigger supports trigger with async state - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/23 15:33:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38353) FLIP-483: Add support for children Spans - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/09/23 16:12:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38412) Refactor MultiJoin test with state ttl to avoid state expiration - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/23 16:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24636) Move cluster deletion operation cache into ResourceManager - posted by "Nishita Pattanayak (Jira)" <ji...@apache.org> on 2025/09/23 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38418) Collecting TIMESTAMP_LTZ values in PyFlink fails with pickling error - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/09/23 17:32:00 UTC, 0 replies.
- [PR] feat: Add non-keyed stream timer examples [flink] - posted by "tejanshrana (via GitHub)" <gi...@apache.org> on 2025/09/23 17:48:39 UTC, 1 replies.
- [PR] [FLINK-38417] Ensure attribute ordering when managing join attributes in JoinKeyExtractor [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/09/23 19:13:22 UTC, 4 replies.
- [jira] [Updated] (FLINK-38417) Ensure attribute ordering when managing join attributes in JoinKeyExtractor - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/23 19:14:00 UTC, 0 replies.
- [PR] [DRAFT][IN_PROGRESS][FLINK-37504] [flink] - posted by "JTaky (via GitHub)" <gi...@apache.org> on 2025/09/23 19:33:40 UTC, 1 replies.
- [jira] [Created] (FLINK-38419) Update official Flink docker images - posted by "Derek Chen-Becker (Jira)" <ji...@apache.org> on 2025/09/23 20:00:00 UTC, 0 replies.
- Re: [PR] [FLINK-37292] [cdc] Remove the flink-kubernetes dependencies during the packaging of flink-cdc-dist [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 00:04:18 UTC, 0 replies.
- Re: [PR] [FLINK-37199][doc] Update configuration in quickstart. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 00:04:23 UTC, 1 replies.
- [PR] [Improvement] Add inherited parameters to ChatModelSetup/EmbeddingModelSetup docstrings [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/24 03:01:11 UTC, 5 replies.
- Re: [I] [Feature] Avoid manually adding the framework jars in user code [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/24 03:43:44 UTC, 0 replies.
- [I] [Feature] Flink-Agents MVP version project docs umbrella [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:00:27 UTC, 0 replies.
- [I] [Feature][docs] Get Started - Overview docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:02:00 UTC, 0 replies.
- [I] [Feature] Get Started - Installation docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:02:27 UTC, 0 replies.
- [I] [Feature] Get Started - Quickstart - ReAct Agent docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:02:56 UTC, 0 replies.
- [I] [Feature] Get Started - Quickstart - Workflow Agent docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:03:09 UTC, 0 replies.
- [I] [Feature][docs] How to build an agent - ReAct Agent docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:03:42 UTC, 1 replies.
- [I] [Feature][dosc] How to build an agent - Workflow Agent docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:05:28 UTC, 1 replies.
- [I] [Feature][docs] How to build an agent - Chat with LLM docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:05:53 UTC, 0 replies.
- [I] [Feature][docs] How to build an agent - Embedding and Vector Store docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:06:14 UTC, 1 replies.
- [I] [Feature][docs] How to build an agent - Use a Tool docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:06:31 UTC, 0 replies.
- [I] [Feature][docs] How to build an agent - Integrate with Flink docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:06:46 UTC, 1 replies.
- [I] [Feature][docs] How to run an agent - Deployment docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:07:08 UTC, 0 replies.
- [I] [Feature][docs] How to run an agent - Configuration docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:07:26 UTC, 0 replies.
- [I] [Feature][docs] How to run an agent - Monitoring docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 04:07:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-38417) Ensure attribute ordering when managing join attributes in JoinKeyExtractor - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/24 04:56:00 UTC, 0 replies.
- Re: [PR] [Docs] Draft the barebones of project docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 06:08:42 UTC, 0 replies.
- [I] [Feature] [example] Implement ReAct Agent quick start example [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/24 06:36:35 UTC, 1 replies.
- [PR] [hotfix][docs] Fix some error in postgres yaml document. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/09/24 07:02:20 UTC, 4 replies.
- [jira] [Assigned] (FLINK-37795) Physical rewrite for ml_evaluate - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/24 07:24:00 UTC, 0 replies.
- [PR] [Bp][minor][hotfix][docs] Fix some error in postgres yaml document. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/09/24 07:30:43 UTC, 1 replies.
- [PR] [BP][minor][hotfix][docs] Fix some error in postgres yaml document. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/09/24 07:31:41 UTC, 1 replies.
- [PR] [bp][minor][hotfix][docs] Fix some error in postgres yaml document. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/09/24 07:32:26 UTC, 1 replies.
- [PR] [FLINK-38415][refactor] Extract single state handle processing logic for testability [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/09/24 08:30:29 UTC, 1 replies.
- [PR] [example] Add React Agent quick start example [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/24 08:52:45 UTC, 3 replies.
- [jira] [Created] (FLINK-38420) Initial BlueGreenDeployment code contribution - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/09/24 09:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38420) Initial BlueGreenDeployment code contribution - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/09/24 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38421) BlueGreen Deployment Documentation - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/09/24 09:25:00 UTC, 0 replies.
- [I] [Feature] Support short-type configuration [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/24 09:28:15 UTC, 1 replies.
- [PR] [Feature] Support short-type configuration [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/24 10:05:08 UTC, 0 replies.
- Re: [PR] [Feature][Runtime] ActionExecutionOperator handle watermark properly [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/24 10:08:18 UTC, 5 replies.
- Re: [PR] [FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/09/24 12:15:22 UTC, 0 replies.
- [jira] [Created] (FLINK-38422) FLIP-540: Support VECTOR_SEARCH in Flink SQL - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/24 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38423) Add vector search connector API - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/24 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38425) Add rule to convert correlate node to vector search node in physical phase - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/24 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38424) Support to parse VECTOR_SEARCH table function - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/24 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38427) Support to serde vector search execnode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/24 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38426) Reuse Lookup Join operator to build search operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/24 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38428) Support to call vector search with literal value - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/24 12:25:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-34697) Finalize release 1.19.0 - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/09/24 14:39:00 UTC, 0 replies.
- [PR] [FLINK-37932] Add UserAgent in GCS requests [flink] - posted by "shrutisinghania (via GitHub)" <gi...@apache.org> on 2025/09/24 16:40:41 UTC, 2 replies.
- [jira] [Updated] (FLINK-37932) Set a Default User Agent for GCS FileSystem Connector for Better Observability - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/24 16:41:00 UTC, 0 replies.
- [PR] [hotfix] Correct menu titles [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/24 17:32:16 UTC, 8 replies.
- [jira] [Assigned] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2025/09/24 20:30:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/24 20:43:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/24 20:43:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37711) Remove unused getJobGraph from PipelineExecutorUtils - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/24 20:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37711) Remove unused getJobGraph from PipelineExecutorUtils - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/24 20:48:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37711) Remove unused getJobGraph from PipelineExecutorUtils - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/24 20:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 00:04:14 UTC, 0 replies.
- Re: [PR] [FLINK-36958][pipeline-connector][kafka] Support csv/json/debezium-json/canal-json format options [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 00:04:17 UTC, 1 replies.
- [I] [Feature] Bump Flink version to 1.20.3 [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/25 01:41:56 UTC, 1 replies.
- [jira] [Created] (FLINK-38429) Improve perf for Elasticsearch 8 connector - posted by "Jiaan Geng (Jira)" <ji...@apache.org> on 2025/09/25 03:03:00 UTC, 0 replies.
- [PR] [FLINK-38429] Improve perf for Elasticsearch 8 connector [flink-connector-elasticsearch] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/09/25 03:12:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-38429) Improve perf for Elasticsearch 8 connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/25 03:13:00 UTC, 0 replies.
- [PR] [FLINK-38423][table-api] Add VECTOR_SEARCH connector API [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/09/25 03:20:38 UTC, 1 replies.
- [jira] [Updated] (FLINK-38423) Add vector search connector API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/25 03:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38424) Support to parse VECTOR_SEARCH table function - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/25 03:25:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38423) Add vector search connector API - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/25 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38430) Support runtime config for VECTOR_SEARCH - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/25 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38431) Support VECTOR_SEARCH in batch mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/25 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38432) Missing finish/reset for keyWriter/valueWriter in ArrowMapWriter - posted by "Frank Wong (Jira)" <ji...@apache.org> on 2025/09/25 04:04:00 UTC, 0 replies.
- [PR] [FLINK-38432][python] Fix missing finish/reset for keyWriter/valueWriter in ArrowMapWriter [flink] - posted by "wzx140 (via GitHub)" <gi...@apache.org> on 2025/09/25 04:12:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-38432) Missing finish/reset for keyWriter/valueWriter in ArrowMapWriter - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/25 04:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38418) Collecting TIMESTAMP_LTZ values in PyFlink fails with pickling error - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/09/25 05:21:00 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/09/25 06:25:52 UTC, 1 replies.
- [jira] [Created] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/25 06:42:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38414) Add Vitess Pipeline Connector with Parallel Shard Reading Support - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/25 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38434) Avoid delete ForSt's directory when there happened to be an existing one - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/25 06:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38434) Avoid delete ForSt's directory when there happened to be an existing one - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/25 06:45:00 UTC, 0 replies.
- [PR] [FLINK-38424][planner] Support to parse VECTOR_SEARCH function [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/09/25 07:12:12 UTC, 5 replies.
- [jira] [Updated] (FLINK-38424) Support to parse VECTOR_SEARCH table function - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/25 07:13:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38435) Refactor codegen and runner for MLPredict and LookupJoin - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/25 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38435) Refactor codegen and runner for MLPredict and LookupJoin - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/25 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38436) Add document for VECTOR_SEARCH function - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/09/25 07:23:00 UTC, 0 replies.
- [PR] [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one. [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/09/25 07:37:20 UTC, 10 replies.
- [jira] [Updated] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/25 07:38:00 UTC, 1 replies.
- [I] [Feature] [api] Combine add methods of Agent and Environment in Java [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/25 08:05:40 UTC, 1 replies.
- [jira] (FLINK-38360) HadoopRecoverableWriterTest failed in test_cron_adaptive_scheduler connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/25 08:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38360) HadoopRecoverableWriterTest#testRecoverWithState failed in test_cron_adaptive_scheduler connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/25 08:09:00 UTC, 0 replies.
- [PR] [api] Combine add methods to add_resource. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/25 08:09:25 UTC, 0 replies.
- [PR] [minor][hotfix][docs] Fluss use STRING rather than VARCHAR. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/09/25 08:23:52 UTC, 1 replies.
- Re: [PR] [FLINK-38100] bump iceberg to 1.10.0 for iceberg-pipeline-connector [flink-cdc] - posted by "locchipinti (via GitHub)" <gi...@apache.org> on 2025/09/25 08:27:28 UTC, 2 replies.
- [jira] [Commented] (FLINK-38360) HadoopRecoverableWriterTest#testRecoverWithState failed in test_cron_adaptive_scheduler connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/25 08:29:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/25 08:40:00 UTC, 3 replies.
- [PR] [FLINK-38100] Bump Iceberg dependency to 1.10.0 in iceberg-pipeline-sink connector [flink-cdc] - posted by "locchipinti (via GitHub)" <gi...@apache.org> on 2025/09/25 08:48:54 UTC, 0 replies.
- [jira] (FLINK-38360) HadoopRecoverableWriterTest#testRecoverWithState failed in test_cron_adaptive_scheduler connect - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/25 08:54:00 UTC, 0 replies.
- [PR] bump josdk version to 5.1.3 [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/09/25 08:55:31 UTC, 0 replies.
- [jira] [Created] (FLINK-38437) Bump Java Operator SDK version to 5.1.3 in Flink Kubernetes Operator - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/09/25 08:59:00 UTC, 0 replies.
- [PR] [runtime] Bump flink version to 1.20.3 [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/25 10:00:38 UTC, 4 replies.
- [PR] [runtime] Only persist memory changes to flink state when action is finished [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/25 10:23:50 UTC, 4 replies.
- Re: [PR] [api][java] Combine add methods to add_resource. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/25 10:50:55 UTC, 1 replies.
- [PR] [FLINK-38435][table] Refactor codegen and runner for MLPredict and Lo… [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/09/25 12:05:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-38435) Refactor codegen and runner for MLPredict and LookupJoin - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/25 12:06:00 UTC, 0 replies.
- Re: [PR] [hotfix] Fix the unsupported short type configuration option [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/25 12:11:02 UTC, 0 replies.
- [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/09/25 12:54:27 UTC, 3 replies.
- [jira] [Updated] (FLINK-38336) Unexpected data copy during failover for ForSt statebackend - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/25 12:55:00 UTC, 0 replies.
- Re: [I] [Feature] Improve the docstring of public facing API [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/25 13:05:14 UTC, 0 replies.
- [PR] [docs] Typo fix [flink] - posted by "gunnarmorling (via GitHub)" <gi...@apache.org> on 2025/09/25 13:10:59 UTC, 2 replies.
- [PR] Add GPG key for 1.20.3 release [flink-docker] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/25 16:01:46 UTC, 1 replies.
- [PR] Update Dockerfiles for 1.20.3 release [flink-docker] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/25 16:08:10 UTC, 1 replies.
- Re: [PR] [FLINK-36546] Handle batch sources in DataSinkTranslator [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/09/25 17:41:24 UTC, 0 replies.
- Re: [PR] [FLINK-37710] Use schemas from the state in SchemaOperator [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/09/25 17:41:37 UTC, 0 replies.
- Re: [PR] [FLINK-35500][Connectors/DynamoDB] DynamoDb Table API Sink fails to delete elements due to key not found [flink-connector-aws] - posted by "bradodarb (via GitHub)" <gi...@apache.org> on 2025/09/25 22:59:07 UTC, 0 replies.
- [PR] Debugging the Blue/Green e2e tests [flink-kubernetes-operator] - posted by "schongloo (via GitHub)" <gi...@apache.org> on 2025/09/26 00:17:01 UTC, 0 replies.
- Re: [PR] [hotfix] [docs] Refine Chinese translation for page /zh/dev/table/dat… [flink] - posted by "hayden520 (via GitHub)" <gi...@apache.org> on 2025/09/26 00:54:02 UTC, 0 replies.
- Re: [PR] Change base image from jre-jammy to jre-noble for security improvements [flink-docker] - posted by "ravivaar (via GitHub)" <gi...@apache.org> on 2025/09/26 01:35:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-38271) PostgresSQL pipeline supports table schema evolution. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/09/26 01:37:00 UTC, 2 replies.
- Re: [I] [Tech Debt] Pemja Bug Tracking [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/09/26 02:14:38 UTC, 0 replies.
- [PR] [hotfix] [docs] Fix Typo in Stateful Stream Processing introduction [flink] - posted by "Pactum7 (via GitHub)" <gi...@apache.org> on 2025/09/26 02:39:41 UTC, 1 replies.
- [jira] [Created] (FLINK-38438) Support session mini cluster when use local executor. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/09/26 02:41:00 UTC, 0 replies.
- [PR] [FLINK-38438][Runtime] Support session mini cluster when use local ex… [flink] - posted by "wwj6591812 (via GitHub)" <gi...@apache.org> on 2025/09/26 02:43:31 UTC, 1 replies.
- [jira] [Updated] (FLINK-38438) Support session mini cluster when use local executor. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/26 02:44:00 UTC, 0 replies.
- [I] [Feature] Separate messages and arguments for prompt of chat method in BaseChatModelSetup [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/26 03:09:47 UTC, 0 replies.
- [jira] [Created] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/26 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/26 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38440) flink-cdc sink iceberg write SMALLINT/TINYINT data wrong - posted by "ChaoFang (Jira)" <ji...@apache.org> on 2025/09/26 03:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/26 03:42:00 UTC, 0 replies.
- Re: [I] [Tech Debt] Refactor Agent resource declaration in python. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/26 05:14:22 UTC, 0 replies.
- [PR] [FLINK-38440][pipeline-connector][iceberg] fixed iceberg write SMALLINT/TINYINT data wrong [flink-cdc] - posted by "fcfangcc (via GitHub)" <gi...@apache.org> on 2025/09/26 06:07:49 UTC, 1 replies.
- [jira] [Updated] (FLINK-38440) flink-cdc sink iceberg write SMALLINT/TINYINT data wrong - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/26 06:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/09/26 06:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-37575] Simplify the code for creating Netty shuffle environment. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 06:25:45 UTC, 1 replies.
- Re: [PR] Run ci [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 06:25:49 UTC, 0 replies.
- [PR] [Feature][docs] add docs for introducing embedding models and vector stores [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/26 07:03:54 UTC, 10 replies.
- [PR] Fix to table [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/26 07:14:14 UTC, 1 replies.
- [PR] [BP-2.1][FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/09/26 07:38:20 UTC, 2 replies.
- Re: [PR] [FLINK-38415][checkpoint] Disable auto compaction to prevent Index OutOfBounds Exception [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/09/26 08:07:27 UTC, 11 replies.
- [jira] [Resolved] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/26 08:23:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/09/26 08:38:00 UTC, 0 replies.
- [PR] Rebuild website [flink-web] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/09/26 09:20:54 UTC, 1 replies.
- [I] [Tech Debt] Configure the model name uniformly in ChatModelSetup. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/26 09:46:33 UTC, 1 replies.
- [PR] [integration] Configure the model name uniformly in ChatModelSetup. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/26 09:47:04 UTC, 1 replies.
- [jira] [Created] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/26 09:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/26 09:57:00 UTC, 0 replies.
- [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/26 10:01:50 UTC, 3 replies.
- [jira] [Updated] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/26 10:02:00 UTC, 0 replies.
- Re: [PR] Support skip verify ssl certificate and hostname [flink-connector-elasticsearch] - posted by "mpv945 (via GitHub)" <gi...@apache.org> on 2025/09/26 10:06:12 UTC, 1 replies.
- Re: [PR] [FLINK-38437] Bump Java Operator SDK version to 5.1.3 in Flink Kubernetes Operator [flink-kubernetes-operator] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/09/26 10:20:43 UTC, 0 replies.
- [jira] [Updated] (FLINK-38437) Bump Java Operator SDK version to 5.1.3 in Flink Kubernetes Operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/26 10:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/09/26 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38443) Adapt TIDB CDC Connector to FLIP-27 API - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/26 11:39:00 UTC, 0 replies.
- [PR] [FLINK-38320] Upgrade Netty version to 4.2.4.Final [flink-shaded] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/09/26 12:46:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-38320) Upgrade Pekko to 1.2.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/26 12:47:00 UTC, 0 replies.
- [PR] [FLINK-38418][python] Support pickling Instants when collecting TIMESTAMP_LTZ types in PyFlink [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/09/26 13:05:51 UTC, 2 replies.
- [jira] [Updated] (FLINK-38418) Collecting TIMESTAMP_LTZ values in PyFlink fails with pickling error - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/26 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38444) Join calculates upsert keys with null keys for left join - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/26 13:30:00 UTC, 0 replies.
- [jira] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown - posted by "Jon Cavallie Mester (Jira)" <ji...@apache.org> on 2025/09/26 14:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown - posted by "Jon Cavallie Mester (Jira)" <ji...@apache.org> on 2025/09/26 14:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-31244) OffHeapUnsafeMemorySegmentTest.testCallCleanerOnceOnConcurrentFree prints IllegalStateException - posted by "Jon Cavallie Mester (Jira)" <ji...@apache.org> on 2025/09/26 14:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38444) Join calculates upsert keys with null keys for left join - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/26 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38445) Create test plans to validate upsert keys - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/26 14:39:00 UTC, 0 replies.
- [PR] [FLINK-38445][table] Add test plans for MultiJoin that preserve upsertKeys [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/09/26 15:03:59 UTC, 2 replies.
- [jira] [Updated] (FLINK-38445) Create test plans to validate upsert keys - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/26 15:05:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/09/26 15:15:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38445) Create test plans to validate upsert keys - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/09/26 15:26:00 UTC, 0 replies.
- [PR] [FLINK-38408][checkpoint] Complete the checkpoint CompletableFuture after updating statistics to ensures semantic correctness and prevent test failure [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/09/26 15:27:02 UTC, 1 replies.
- [jira] [Updated] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/26 15:28:00 UTC, 0 replies.
- [PR] [BP-to-2.1][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/09/26 16:39:42 UTC, 2 replies.
- Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka] - posted by "amitvc (via GitHub)" <gi...@apache.org> on 2025/09/26 16:40:28 UTC, 2 replies.
- [PR] [BP-to-1.20][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/09/26 16:40:58 UTC, 2 replies.
- [PR] [BP-to-2.0][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/09/26 16:41:41 UTC, 2 replies.
- Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/09/26 17:12:54 UTC, 0 replies.
- [PR] [example][java] Add single agent example [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/09/26 22:04:16 UTC, 8 replies.
- [jira] [Updated] (FLINK-38232) [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 - posted by "suhwan (Jira)" <ji...@apache.org> on 2025/09/27 01:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-38232] [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 [flink-cdc] - posted by "suhwan-cheon (via GitHub)" <gi...@apache.org> on 2025/09/27 01:52:04 UTC, 3 replies.
- [jira] [Created] (FLINK-38446) Pyflink explain() crashes with Index Out Of Bounds - posted by "Ahmad Humayun (Jira)" <ji...@apache.org> on 2025/09/27 04:11:00 UTC, 0 replies.
- Re: [PR] [runtime] Fix exception when integrate agent from datastream to table. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/27 07:02:12 UTC, 0 replies.
- Re: [I] [Bug] [api][runtime] Call from_datastream and then to_table will cause exception. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/27 07:02:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/27 09:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/27 09:54:00 UTC, 0 replies.
- [PR] [flink-table-planner] Optimize RemoveUnreachableCoalesceArgumentsRule rule [flink] - posted by "ChengJie1053 (via GitHub)" <gi...@apache.org> on 2025/09/27 13:22:45 UTC, 6 replies.
- [PR] upgrade maven-shade-plugin [flink-kubernetes-operator] - posted by "hboutemy (via GitHub)" <gi...@apache.org> on 2025/09/27 14:56:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-38314) Flink dashboard incorrectly shows units for RocksDB `live-sst-files-size` metric for timer state - posted by "Jon Cavallie Mester (Jira)" <ji...@apache.org> on 2025/09/27 16:41:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38314) Flink dashboard incorrectly shows units for RocksDB `live-sst-files-size` metric for timer state - posted by "Jon Cavallie Mester (Jira)" <ji...@apache.org> on 2025/09/27 16:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38447) Add table sink support for Elasticsearch 8 connector - posted by "lwn (Jira)" <ji...@apache.org> on 2025/09/27 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38448) Fix doc CI rsync logic - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/27 18:15:00 UTC, 0 replies.
- [PR] [FLINK-38447] Add table sink support for Elasticsearch 8 connector [flink-connector-elasticsearch] - posted by "lwn3148 (via GitHub)" <gi...@apache.org> on 2025/09/27 18:22:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-38447) Add table sink support for Elasticsearch 8 connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/27 18:23:00 UTC, 2 replies.
- [PR] [FLINK-38448] Replace `burnett01/rsync-deployments` with a custom `rsync-deploy` action in `docs.yaml` [flink-kubernetes-operator] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/09/27 18:40:20 UTC, 6 replies.
- [jira] [Updated] (FLINK-38448) Fix doc CI rsync logic - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/27 18:41:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38449) Makes error message for fractional values for MemorySize explicit - posted by "Navin Viswanath (Jira)" <ji...@apache.org> on 2025/09/27 20:23:00 UTC, 0 replies.
- [PR] FLINK-38449: Makes error message for fractional values for MemorySize explicit [flink] - posted by "navinvishy (via GitHub)" <gi...@apache.org> on 2025/09/27 20:26:44 UTC, 3 replies.
- [jira] [Updated] (FLINK-38449) Makes error message for fractional values for MemorySize explicit - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/27 20:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/28 02:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/28 02:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/28 02:20:00 UTC, 0 replies.
- [PR] [docs] Update installation section. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/28 03:01:56 UTC, 8 replies.
- [jira] [Commented] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/09/28 03:13:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/09/28 03:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/09/28 03:14:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38440) flink-cdc sink iceberg write SMALLINT/TINYINT data wrong - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/28 03:58:00 UTC, 0 replies.
- [PR] [FLINK-38272][runtime] Fix unstable BatchJobRecoveryTest [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2025/09/28 04:49:07 UTC, 4 replies.
- [jira] [Updated] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/28 04:50:00 UTC, 0 replies.
- [I] [Feature] Introduce built-in CONTEXT_RETRIEVAL_ACTION to enable context retrieval (e.g., RAG) [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/28 05:53:28 UTC, 1 replies.
- [PR] [Feature] Introduce built-in CONTEXT_RETRIEVAL_ACTION to enable context retrieval [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/28 05:54:58 UTC, 6 replies.
- Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/09/28 06:09:04 UTC, 0 replies.
- [PR] [docs] Update react agent quickstart section. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/28 06:24:16 UTC, 14 replies.
- [jira] [Created] (FLINK-38450) flink-cdc sink to iceberg table record duplication - posted by "ChaoFang (Jira)" <ji...@apache.org> on 2025/09/28 06:46:00 UTC, 0 replies.
- [I] [Tech Debt] Simplify the vector store setup process [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/28 06:52:56 UTC, 3 replies.
- [PR] Simplify the vector store setup process [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/28 07:52:19 UTC, 0 replies.
- Re: [PR] [Runtime] Simplify the vector store setup process [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/28 07:55:29 UTC, 1 replies.
- [PR] [docs] Update the configuration introduction for Flink agents [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/28 09:22:30 UTC, 1 replies.
- [PR] [docs] Update workflow agent development doc. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/28 09:42:48 UTC, 2 replies.
- [PR] [FLINK-34015] fix setting execution.savepoint.ignore-unclaimed-state … [flink] - posted by "xiangforever2014 (via GitHub)" <gi...@apache.org> on 2025/09/28 12:57:03 UTC, 4 replies.
- [jira] [Commented] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties - posted by "Renxiang Zhou (Jira)" <ji...@apache.org> on 2025/09/28 12:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties - posted by "Renxiang Zhou (Jira)" <ji...@apache.org> on 2025/09/28 12:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-31499) Move SqlCreateTable conversion logic to SqlCreateTableConverter - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/28 13:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-31499) Move SqlCreateTable conversion logic to SqlCreateTableConverter - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/28 13:17:00 UTC, 0 replies.
- [PR] [FLINK-31499][table] Move SqlCreateTable conversion logic to SqlCreateTableConverter and make it more generic [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/28 13:22:52 UTC, 5 replies.
- [PR] [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/09/28 16:32:46 UTC, 2 replies.
- [jira] [Updated] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/28 16:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/09/28 16:34:00 UTC, 0 replies.
- [PR] [FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/09/28 16:48:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/09/28 16:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/28 16:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37813) SlotManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2025/09/29 02:44:00 UTC, 0 replies.
- [PR] [hotfix] Fix typos [flink] - posted by "zcoo (via GitHub)" <gi...@apache.org> on 2025/09/29 03:00:36 UTC, 2 replies.
- [jira] [Commented] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/29 03:15:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/29 03:17:00 UTC, 0 replies.
- [PR] [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/09/29 03:35:45 UTC, 5 replies.
- [PR] [FLINK-38369][runtime] Fix flaky RestClientTest [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/09/29 04:26:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/29 04:27:00 UTC, 0 replies.
- Re: [PR] [FLINK-33387][runtime] Introduce the abstraction and the interface about loading [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/09/29 06:23:34 UTC, 0 replies.
- [PR] [hotfix ] add homepage link [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/29 07:00:56 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38445) Create test plans to validate upsert keys - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/09/29 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38451) KafkaCommitter logs ERRORs unnecessarily during cancellation - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/09/29 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38452) MongoDB CDC connector could not read from collections named with dots - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/09/29 08:19:00 UTC, 0 replies.
- [PR] [hotfix][ci] Run MongoDB tests with supported 7.0.x and 8.0.x images [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/09/29 08:38:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-31499) Move SqlCreateTable conversion logic to SqlCreateTableConverter - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/29 08:51:00 UTC, 0 replies.
- [PR] [hotfix] Fix the inconsistency of the MemoryObject get method in Local and Flink modes [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/29 08:52:52 UTC, 3 replies.
- [PR] [FLINK-38451] Stop logging interrupts as ERROR [flink-connector-kafka] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/09/29 09:05:53 UTC, 8 replies.
- [jira] [Updated] (FLINK-38451) KafkaCommitter logs ERRORs unnecessarily during cancellation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/29 09:06:00 UTC, 0 replies.
- [PR] [FLINK-38452] Fix unable to read incremental data from MongoDB collections with dots [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/09/29 09:11:17 UTC, 1 replies.
- [jira] [Updated] (FLINK-38452) MongoDB CDC connector could not read from collections named with dots - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/29 09:12:00 UTC, 0 replies.
- [PR] [docs] Update react agent development doc. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/29 09:30:25 UTC, 4 replies.
- [jira] [Commented] (FLINK-28736) Add APPROX_PERCENTILE function - posted by "zhisheng (Jira)" <ji...@apache.org> on 2025/09/29 09:40:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/29 10:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38324) Job fails to restore keyed state backend when using Forst state backend on S3: FileNotFoundException - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/09/29 10:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-38211][table-planner] Refactor explain for MultiJoin [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/09/29 10:20:20 UTC, 6 replies.
- [PR] [docs] Update the deployment introduction for Flink agents [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/09/29 10:58:47 UTC, 1 replies.
- [jira] [Created] (FLINK-38453) KafkaEnumerator doesn't restore offsets of owned split - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/09/29 11:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31501) Move SqlCreateView conversion logic to SqlCreateViewConverter - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/29 13:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-31501) Move SqlCreateView conversion logic to SqlCreateViewConverter - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/29 13:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-31501) Move SqlCreateView conversion logic to SqlCreateViewConverter - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/29 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38454) Inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/29 14:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38454) Inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/29 14:40:00 UTC, 1 replies.
- [PR] [hotfix] Refactor codes with latest API changes [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/09/29 18:38:36 UTC, 4 replies.
- [jira] [Closed] (FLINK-38448) Fix doc CI rsync logic - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/29 20:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38448) Rework doc build and doc deployment - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/29 20:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38448) Rework doc build and doc deployment - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/09/29 20:45:00 UTC, 0 replies.
- Re: [PR] [example][java] Add multiple agent integration example [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/09/29 22:55:56 UTC, 1 replies.
- [I] [Feature] Support submit the example in installed python package to flink cluster. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/30 02:37:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37963) Unstable MongoDB unit test cases that triggers JM failover - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/30 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38455) MySQL CDC to ES8 pipeline connector cannot work - posted by "li yong (Jira)" <ji...@apache.org> on 2025/09/30 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38456) support hive connector for flink 2.x - posted by "Jihoon Lee (Jira)" <ji...@apache.org> on 2025/09/30 04:50:00 UTC, 0 replies.
- [PR] [FLINK-26820] Cassandra Sink V2 Implementation (FLIP-533) (Phase-1) [flink-connector-cassandra] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/09/30 05:23:36 UTC, 0 replies.
- [jira] [Updated] (FLINK-26820) Improve Cassandra connector by adding missing features and refactoring to latest standards - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/30 05:24:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38452) MongoDB CDC connector could not read from collections named with dots - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/09/30 06:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34112) JavaCodeSplitter OOM - posted by "Chunhui Yang (Jira)" <ji...@apache.org> on 2025/09/30 07:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38453) KafkaEnumerator doesn't restore offsets of owned split - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/09/30 07:52:00 UTC, 1 replies.
- [PR] [FLINK-38454][core] Fix inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/09/30 08:29:01 UTC, 3 replies.
- [jira] [Created] (FLINK-38457) Add AWS Glue Catalog Support - posted by "melin (Jira)" <ji...@apache.org> on 2025/09/30 08:58:00 UTC, 0 replies.
- Re: [I] [Feature][docs] Get Started - Quickstart - ReAct Agent docs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/30 09:18:09 UTC, 0 replies.
- [jira] [Created] (FLINK-38458) Extract SchemaConverter and ReferenceManager to make them reusable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/30 09:43:00 UTC, 0 replies.
- [PR] [FLINK-38458][table] Extract SchemaConverter and ReferenceManager to make them reusable [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/09/30 09:48:49 UTC, 13 replies.
- [jira] [Updated] (FLINK-38458) Extract SchemaConverter and ReferenceManager to make them reusable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/30 09:49:00 UTC, 0 replies.
- [PR] [docs] Update integrate with flink doc. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/09/30 09:50:41 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/09/30 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/30 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38460) Improve test coverage for SinkUpsertMaterializer - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/30 11:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38199) Add a benchmark for SinkUpsertMaterializer - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/30 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38461) Introduce SinkUpsertMaterializerV2 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/30 11:30:00 UTC, 0 replies.
- [PR] F38460 [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/09/30 11:58:52 UTC, 0 replies.
- Re: [PR] [FLINK-38460][tests] Improve test coverage for SinkUpsertMaterializer [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/09/30 12:08:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-38460) Improve test coverage for SinkUpsertMaterializer - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/30 12:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38258) Enable model param for PTF - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/30 13:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38258) Enable model param for PTF - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/30 13:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38258) Enable model arguments for PTFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/09/30 13:20:00 UTC, 0 replies.
- [PR] [FLINK-38453] Add full splits to KafkaSourceEnumState [flink-connector-kafka] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/09/30 13:50:52 UTC, 1 replies.
- [jira] [Updated] (FLINK-38453) KafkaEnumerator doesn't restore offsets of owned split - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/30 13:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38453) KafkaEnumerator doesn't restore offsets of owned split - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/09/30 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38462) Introduce state backend type identifier - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/30 14:35:00 UTC, 0 replies.
- [PR] [FLINK-38462] Introduce state backend type identifier [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/09/30 14:38:21 UTC, 4 replies.
- [jira] [Updated] (FLINK-38462) Introduce state backend type identifier - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/30 14:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38458) Extract SchemaConverter and ReferenceManager to make them reusable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/30 14:42:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38458) Extract SchemaConverter and ReferenceManager to make them reusable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/30 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/30 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38464) Introduce OrderedMultiSetState (view) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/09/30 15:03:00 UTC, 0 replies.
- [PR] [DRAFT][FLINK-38461] Introduce SinkUpsertMaterializerV2 [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/09/30 15:22:32 UTC, 1 replies.
- [jira] [Updated] (FLINK-38461) Introduce SinkUpsertMaterializerV2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/30 15:23:00 UTC, 0 replies.
- [PR] [FLINK-38464] Introduce OrderedMultiSetState [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/09/30 15:24:31 UTC, 1 replies.
- [jira] [Updated] (FLINK-38464) Introduce OrderedMultiSetState (view) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/30 15:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38465) Continue on error and metadata column support for HTTP connector - posted by "david radley (Jira)" <ji...@apache.org> on 2025/09/30 15:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24493) Introduce DemultiplexingSink to Support Dynamic Sink Routing - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/09/30 17:44:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38390) Compiliation of flink-core and flink-table-planner fails because of annotation processors - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/30 18:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38390) Compiliation of flink-core and flink-table-planner fails because of annotation processors - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/09/30 18:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38466) Bump derby version to 10.17.1.0 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2025/09/30 18:47:00 UTC, 0 replies.
- [PR] [FLINK-38466] Bump derby from 10.15.2.0 to 10.17.1.0 [flink-kubernetes-operator] - posted by "r-sidd (via GitHub)" <gi...@apache.org> on 2025/09/30 19:12:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-38466) Bump derby version to 10.17.1.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/30 19:13:00 UTC, 0 replies.
- Re: [PR] [FLINK-38289] Update to Flink 2.1 [flink-connector-kafka] - posted by "raphaelauv (via GitHub)" <gi...@apache.org> on 2025/09/30 19:51:26 UTC, 0 replies.
- Re: [I] [Feature][docs] Get Started - Installation docs [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/09/30 20:38:35 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-24493) Introduce DemultiplexingSink to Support Dynamic Sink Routing - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/09/30 20:47:00 UTC, 0 replies.