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

---

- Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/01/01 07:31:24 UTC, 18 replies.
- [PR] [FLINK-34894][table] Migrate JoinDependentConditionDerivationRule to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/01 10:49:08 UTC, 1 replies.
- [PR] [FLINK-38804][runtime] draft fix 3.3 [flink] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/01/01 14:24:35 UTC, 4 replies.
- [jira] [Commented] (FLINK-34894) Migrate JoinDependentConditionDerivationRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/01 15:00:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34894) Migrate JoinDependentConditionDerivationRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/01 15:01:00 UTC, 0 replies.
- [PR] [FLINK-34596][table] Migrate RemoveRedundantLocalHashAggRule to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/01 18:30:19 UTC, 1 replies.
- [jira] [Resolved] (FLINK-34505) Migrate WindowGroupReorderRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/01 18:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34505) Migrate WindowGroupReorderRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/01 18:58:00 UTC, 0 replies.
- Re: [PR] [FLINK-36986][table] Migrate SplitRemoteConditionFromJoinRule to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/01 19:12:06 UTC, 5 replies.
- Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/01 20:26:17 UTC, 3 replies.
- Re: [PR] [FLINK-35856] [table] Upgrade Calcite version to 1.37.0 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/01 20:41:36 UTC, 1 replies.
- [jira] [Resolved] (FLINK-34895) Migrate FlinkRewriteSubQueryRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/01 21:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34895) Migrate FlinkRewriteSubQueryRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/01 21:30:00 UTC, 0 replies.
- [PR] Bump node-forge from 1.3.1 to 1.3.3 in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/01 21:48:27 UTC, 1 replies.
- Re: [PR] Bump node-forge from 1.3.1 to 1.3.2 in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/01 21:48:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-34596) Migrate RemoveRedundantLocalHashAggRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/01 22:03:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34596) Migrate RemoveRedundantLocalHashAggRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/01 22:03:00 UTC, 0 replies.
- [PR] [FLINK-34597][table] Migrate SimplifyFilterConditionRule to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/01 22:05:18 UTC, 2 replies.
- [jira] [Created] (FLINK-38855) Upgrade jackson to 2.20.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/02 08:42:00 UTC, 0 replies.
- [PR] [FLINK-38855] Upgrade jackson to 2.20.1 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/02 08:43:55 UTC, 5 replies.
- [jira] [Updated] (FLINK-38855) Upgrade jackson to 2.20.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/02 08:44:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34598) Migrate RemoveRedundantLocalRankRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/02 08:50:00 UTC, 0 replies.
- [PR] [DRAFT][FLINK-34637][table] Migrate JoinConditionEqualityTransferRule to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/02 09:13:16 UTC, 0 replies.
- [jira] [Updated] (FLINK-38853) Umbrella: FLIP-XXX: Enhance the standardization of the REST API JSON schema - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/02 11:04:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38853) Umbrella: FLIP-XXX: Enhance the standardization of the REST API JSON schema - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/02 11:06:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38853) Umbrella: FLIP-XXX: Enhance the standardization of the REST API JSON schema - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/02 11:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/02 11:52:00 UTC, 0 replies.
- Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc] - posted by "Fluder-Paradyne (via GitHub)" <gi...@apache.org> on 2026/01/02 17:03:49 UTC, 4 replies.
- [PR] [FLINK-38569][table-planner] Avoid generating ReadingMetadataSpec no metadata [flink] - posted by "fresh-borzoni (via GitHub)" <gi...@apache.org> on 2026/01/02 23:22:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-38569) ReadingMetadataSpec should not be generated if there are no metadataKeys to be read - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/02 23:23:00 UTC, 0 replies.
- Re: [PR] [FLINK-38569][table-planner] Avoid generating ReadingMetadataSpec when no metadata [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/02 23:29:31 UTC, 1 replies.
- Re: [PR] [plan] Support error handling strategy for built-in chat action. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/03 07:32:15 UTC, 1 replies.
- Re: [PR] [infra] Add doc-including label to indicate docs are included in the PR [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/03 07:49:23 UTC, 2 replies.
- Re: [PR] [Feature][runtime] Support Multi-Version Flink for Flink Agents [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/03 09:04:46 UTC, 0 replies.
- Re: [PR] FLINK-27934 - Improving inefficient deserialization/serialization of state variables within a batch [flink-statefun] - posted by "fransking (via GitHub)" <gi...@apache.org> on 2026/01/03 11:15:43 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38855) Upgrade jackson to 2.20.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/03 23:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38855) Upgrade jackson to 2.20.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/03 23:38:00 UTC, 0 replies.
- [PR] [FLINK-38840][postgres] Postgres YAML connector supports emitting complete Table ID [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2026/01/04 00:50:40 UTC, 8 replies.
- [jira] [Updated] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/04 00:51:00 UTC, 0 replies.
- Re: [D] Label-Based Version Control Strategy [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/04 01:35:59 UTC, 0 replies.
- Re: [PR] [FLINK-38100] Bump Iceberg dependency to 1.10.0 in iceberg-pipeline-sink connector [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/04 01:46:06 UTC, 1 replies.
- Re: [I] [Feature] Update to Flink 2.2 [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/04 01:52:35 UTC, 1 replies.
- Re: [PR] [FLINK-38847][Postgres-cdc] Fix ConnectionPoolId to use username [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/04 01:53:32 UTC, 0 replies.
- [jira] [Updated] (FLINK-38847) Incorrect construction of Postgres ConnectionPoolId - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/04 01:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38847) Incorrect construction of Postgres ConnectionPoolId - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/04 01:55:00 UTC, 0 replies.
- [PR] [FLINK-37009][table] Migrate PruneAggregateCallRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2026/01/04 02:08:50 UTC, 7 replies.
- Re: [I] [Feature] Support Multi-Version Flink for Flink Agents [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/04 02:21:47 UTC, 0 replies.
- Re: [PR] feat: Add GaussDB CDC connector with critical bug fixes [flink-cdc] - posted by "y0908105023 (via GitHub)" <gi...@apache.org> on 2026/01/04 02:35:01 UTC, 3 replies.
- Re: [PR] [FLINK-38779] Route module supports standard RegExp replacement rules [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/04 02:52:18 UTC, 2 replies.
- Re: [PR] [FLINK-38851] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/04 06:37:56 UTC, 8 replies.
- [jira] [Updated] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/04 06:38:00 UTC, 1 replies.
- Re: [PR] [FLINK-34466][LINEAGE] Support dataset type facet for Avro [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/01/04 07:03:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-38831) The route configuration supports matching the first one - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/04 09:10:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38831) The route configuration supports matching the first one - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/01/04 09:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s - posted by "xiaolong3817 (Jira)" <ji...@apache.org> on 2026/01/04 09:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38375) Flink Resouce leak on Flink k8s - posted by "xiaolong3817 (Jira)" <ji...@apache.org> on 2026/01/04 09:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-38801][benchmark] Add Spotless and checkstyle plugins with Google AOSP style for flink benchmark repository [flink-benchmarks] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/04 10:26:15 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38801) Add Spotless plugin with Google AOSP style for flink benchmark repository - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/04 10:32:00 UTC, 0 replies.
- Re: [PR] [FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator [flink] - posted by "cyan-daimao (via GitHub)" <gi...@apache.org> on 2026/01/04 12:07:56 UTC, 3 replies.
- [PR] [FLINK-3872] Bump Flink version to 2.2.0 [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/04 12:23:33 UTC, 1 replies.
- [jira] [Updated] (FLINK-3872) Add Kafka TableSource with JSON serialization - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/04 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38856) Add support for ALTER MATERIALIZED TABLE DROP schema component - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/04 15:10:00 UTC, 0 replies.
- [PR] [hotfix] Update copyright NOTICE year to 2026 [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2026/01/04 15:16:30 UTC, 2 replies.
- Re: [PR] [hotfix] Try to stabilize the flaky integration tests [flink-connector-jdbc] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/04 15:16:32 UTC, 2 replies.
- [PR] [FLINK-38856][table] Add support for `ALTER MATERIALIZED TABLE DROP` schema component [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/04 16:42:58 UTC, 22 replies.
- [jira] [Updated] (FLINK-38856) Add support for ALTER MATERIALIZED TABLE DROP schema component - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/04 16:43:00 UTC, 0 replies.
- Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] - posted by "yanand0909 (via GitHub)" <gi...@apache.org> on 2026/01/04 17:55:00 UTC, 4 replies.
- Re: [PR] [FLINK-37244] Added scylladb tests, documentation and README [flink-connector-cassandra] - posted by "andrii-kysylevskyi (via GitHub)" <gi...@apache.org> on 2026/01/04 20:41:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-38850) Support PostgreSQL uuid type - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2026/01/04 21:56:00 UTC, 1 replies.
- [PR] [Feature] Improve Python Async Execution API [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/05 01:54:29 UTC, 2 replies.
- Re: [PR] Flink Version upgrade 2.3-SNAPSHOT [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/05 02:07:40 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 "xiaolong3817 (Jira)" <ji...@apache.org> on 2026/01/05 02:18:00 UTC, 0 replies.
- [PR] [FLINK-36988][table] Migrate LogicalCorrelateToJoinFromTemporalTableF… [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2026/01/05 02:21:16 UTC, 7 replies.
- [PR] [FLINK-36992][table] Migrate SplitAggregateRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2026/01/05 02:23:07 UTC, 16 replies.
- [PR] [FLINK-36992][table] Migrate DecomposeGroupingSetsRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2026/01/05 02:24:47 UTC, 0 replies.
- Re: [PR] [FLINK-37676][cdc-common] Add caching mechanism to Selectors for improved performance [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/01/05 02:26:58 UTC, 0 replies.
- Re: [PR] [FLINK-37002][table] Migrate DecomposeGroupingSetsRule to java [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/05 02:29:52 UTC, 4 replies.
- [jira] [Updated] (FLINK-37002) Migrate DecomposeGroupingSetsRule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/01/05 02:50:00 UTC, 0 replies.
- [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models for batch-oriented AI inference [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/01/05 03:01:32 UTC, 9 replies.
- [jira] [Updated] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 03:02:00 UTC, 0 replies.
- Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2026/01/05 03:03:52 UTC, 5 replies.
- [I] [Feature][Infra] Support centralized Flink version management via script to simplify upgrades [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/05 03:13:05 UTC, 1 replies.
- [I] [Feature] Add document for Java MCP supports [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/05 03:18:30 UTC, 3 replies.
- Re: [I] [Feature] [api][Java] Add built-in mcp support for Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/05 03:18:51 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/05 05:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates [flink] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/01/05 06:15:14 UTC, 13 replies.
- [jira] [Updated] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/05 06:20:00 UTC, 3 replies.
- Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/05 06:27:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed - posted by "Hao Yu (Jira)" <ji...@apache.org> on 2026/01/05 06:49:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38858) Reuse jobid after failed submissions to guard against job duplication - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/05 06:55:00 UTC, 0 replies.
- [PR] [FLINK-38858] Reuse jobid after failed submissions to guard against job duplication [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2026/01/05 06:59:19 UTC, 1 replies.
- [jira] [Updated] (FLINK-38858) Reuse jobid after failed submissions to guard against job duplication - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38859) Do not apply minimum job vertex parallelism for whole job in native mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/05 07:02:00 UTC, 0 replies.
- [PR] [FLINK-38859] Do not apply minimum job vertex parallelism for whole job in native mode [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2026/01/05 07:03:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-38859) Do not apply minimum job vertex parallelism for whole job in native mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38860) Remove flink shaded guava usage from operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/05 07:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2026/01/05 07:12:47 UTC, 8 replies.
- Re: [PR] [FLINK-37902] batch support for ml_predict [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2026/01/05 07:50:34 UTC, 3 replies.
- [PR] [FLINK-38860] Remove flink shaded guava usage [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2026/01/05 08:03:54 UTC, 7 replies.
- [jira] [Updated] (FLINK-38860) Remove flink shaded guava usage from operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 08:04:00 UTC, 0 replies.
- Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/05 09:18:56 UTC, 2 replies.
- [jira] [Created] (FLINK-38861) Update Documentation to cover new CREATE/ALTER operations for MATERIALIZED TABLEs - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/05 10:18:00 UTC, 0 replies.
- Re: [PR] [FLINK-38826][table] Add new ArgumentStrategy to support array with specified element type [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/05 10:20:38 UTC, 0 replies.
- Re: [PR] [FLINK-38762][runtime] Introduce SingleJobApplication [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/01/05 10:49:24 UTC, 1 replies.
- Re: [PR] [FLINK-38048] Update java version and move parent pom to v2.0.0 [flink-connector-shared-utils] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2026/01/05 11:41:31 UTC, 25 replies.
- Re: [PR] [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] - posted by "ztison (via GitHub)" <gi...@apache.org> on 2026/01/05 11:55:23 UTC, 5 replies.
- [PR] [FLINK-38838] Update spotless style version to AOSP 1.24.0 & reorganize CI modules [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/01/05 11:58:34 UTC, 6 replies.
- [jira] [Updated] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38862) Partition discovery interval not configurable in upsert mode (tableAPI) - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/01/05 12:12:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38862) Partition discovery interval not configurable in upsert mode (tableAPI) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/05 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38863) flink-opensearch tests fail with "Connector production code must depend only on public API when outside of connector packages" - posted by "Roman Grebennikov (Jira)" <ji...@apache.org> on 2026/01/05 12:27:00 UTC, 0 replies.
- [PR] [FLINK-38862] Configurable partition discovery interval in upsert mode [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/01/05 12:30:03 UTC, 3 replies.
- [jira] [Updated] (FLINK-38862) Partition discovery interval not configurable in upsert mode (tableAPI) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 12:31:00 UTC, 0 replies.
- [PR] [FLINK-38863] Fix archunit violations for IndexGeneratorFactory [flink-connector-opensearch] - posted by "shuttie (via GitHub)" <gi...@apache.org> on 2026/01/05 12:42:15 UTC, 1 replies.
- [jira] [Updated] (FLINK-38863) flink-opensearch tests fail with "Connector production code must depend only on public API when outside of connector packages" - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 12:43:00 UTC, 0 replies.
- [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] - posted by "linguoxuan (via GitHub)" <gi...@apache.org> on 2026/01/05 12:46:11 UTC, 11 replies.
- [jira] [Updated] (FLINK-38831) The route configuration supports matching the first one - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 12:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38863) flink-opensearch tests fail with "Connector production code must depend only on public API when outside of connector packages" - posted by "Roman Grebennikov (Jira)" <ji...@apache.org> on 2026/01/05 12:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-38721] Support vector search for es connector. [flink-connector-elasticsearch] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2026/01/05 12:53:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-38859) Do not apply minimum job vertex parallelism for whole job in native mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/05 13:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager during reporting metrics - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/05 13:35:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager during reporting metrics - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/05 13:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38858) Reuse jobid after failed submissions to guard against job duplication - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/05 13:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38860) Remove flink shaded guava usage from operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/05 13:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-38447] Add table sink support for Elasticsearch 8 connector [flink-connector-elasticsearch] - posted by "KhairullinAR (via GitHub)" <gi...@apache.org> on 2026/01/05 14:05:16 UTC, 3 replies.
- [jira] [Created] (FLINK-38864) HTTP Connector : Add IGNORE_STATUS_CODE http-completion-state - posted by "david radley (Jira)" <ji...@apache.org> on 2026/01/05 17:01:00 UTC, 0 replies.
- Re: [PR] [FLINK-38820] Move ptf rule to rule folder [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2026/01/05 18:24:42 UTC, 1 replies.
- [jira] [Created] (FLINK-38865) Docs: Fix typos and clarify capacity scope in Async I/O documentation - posted by "Vishal Kamlapure (Jira)" <ji...@apache.org> on 2026/01/05 21:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38865) Docs: Fix typos and clarify capacity scope in Async I/O documentation - posted by "Vishal Kamlapure (Jira)" <ji...@apache.org> on 2026/01/05 21:31:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38865) Docs: Fix typos and clarify capacity scope in Async I/O documentation - posted by "Vishal Kamlapure (Jira)" <ji...@apache.org> on 2026/01/05 21:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38866) TIMESTAMP_LTZ(6) values with UNION ALL into window TVF produce incorrect results in batch mode - posted by "Matt Cuento (Jira)" <ji...@apache.org> on 2026/01/05 21:47:00 UTC, 0 replies.
- [PR] [FLINK-38866][flink-table-planner] Validating field precision for window descriptors [flink] - posted by "mattcuento (via GitHub)" <gi...@apache.org> on 2026/01/05 21:58:47 UTC, 1 replies.
- [jira] [Updated] (FLINK-38866) TIMESTAMP_LTZ(6) values with UNION ALL into window TVF produce incorrect results in batch mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 21:59:00 UTC, 0 replies.
- [PR] [FLINK-38865][doc] Fix typos and clarify Async I/O capacity scope [flink] - posted by "Khuara (via GitHub)" <gi...@apache.org> on 2026/01/05 22:34:31 UTC, 3 replies.
- [jira] [Updated] (FLINK-38865) Docs: Fix typos and clarify capacity scope in Async I/O documentation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/05 22:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38867) FlinkBlueGreenDeployment: savepointRedeployNonce does not respect user-provided initialSavepointPath - posted by "James Kan (Jira)" <ji...@apache.org> on 2026/01/05 23:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38867) FlinkBlueGreenDeployment: savepointRedeployNonce does not respect user-provided initialSavepointPath - posted by "James Kan (Jira)" <ji...@apache.org> on 2026/01/05 23:25:00 UTC, 2 replies.
- Re: [PR] [FLINK-38225] Sets proper precondition to ensure that GCS operations are retryable [flink] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/06 01:16:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2026/01/06 01:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2026/01/06 01:20:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2026/01/06 01:20:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38866) TIMESTAMP_LTZ(6) values with UNION ALL into window TVF produce incorrect results in batch mode - posted by "Matt Cuento (Jira)" <ji...@apache.org> on 2026/01/06 01:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38748) Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/06 05:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38748) Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/06 05:06:00 UTC, 2 replies.
- Re: [PR] [FLINK-38748][runtime] Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/06 05:17:19 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38748) Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/06 05:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38748) Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/06 05:19:00 UTC, 0 replies.
- Re: [PR] [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/06 05:22:33 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/06 05:26:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/06 05:26:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/06 05:26:00 UTC, 1 replies.
- Re: [D] Flink Agents Support Multi-JDK Versions [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/06 06:16:15 UTC, 0 replies.
- [I] [Bug] Failed to connect to remote mcp server [flink-agents] - posted by "qingfei1994 (via GitHub)" <gi...@apache.org> on 2026/01/06 06:42:17 UTC, 2 replies.
- [jira] [Commented] (FLINK-35618) Flink CDC add MongoDB pipeline data sink connector - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/06 07:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-38345][flink-connector-base] Annotate SourceSwitchContext#getPreviousEnumerator as nullable for recovery scenarios [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2026/01/06 07:34:39 UTC, 9 replies.
- [jira] [Commented] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/06 08:55:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/06 09:02:00 UTC, 1 replies.
- Re: [PR] [FLINK-38866][flink-table-planner] Passing timestamp precision from window strategy to window operators to support non-compact BinaryRowData timestamps [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/06 09:21:34 UTC, 9 replies.
- [jira] [Commented] (FLINK-38856) Add support for ALTER MATERIALIZED TABLE DROP schema component - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/06 09:51:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38856) Add support for ALTER MATERIALIZED TABLE DROP schema component - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/06 09:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager during reporting metrics - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/06 10:46:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager during reporting metrics - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/06 10:46:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-38820) Move ptf rules to rule folder - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2026/01/06 11:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38820) Move ptf rules to rule folder - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2026/01/06 11:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38820) Move ptf rules to rule folder - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2026/01/06 11:05:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/06 14:19:00 UTC, 0 replies.
- [PR] [FLINK-38601][mongodb] Catch throwable errors when consuming from unbounded streams [flink-cdc] - posted by "linguoxuan (via GitHub)" <gi...@apache.org> on 2026/01/06 14:35:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-38601) MongoDB CDC silently stops consuming from unbounded streams when Throwable errors occur and never recovers - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/06 14:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38601) MongoDB CDC silently stops consuming from unbounded streams when Throwable errors occur and never recovers - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/06 14:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38362) Reduce the time cost in checkpoint when writing many tables to StarRocks sink - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/06 15:13:00 UTC, 0 replies.
- [PR] [Flink-38864] Add ignore status completion state [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/06 15:54:50 UTC, 6 replies.
- Re: [PR] [FLINK-38816] use Flink 2 compatible deserialise [flink-connector-http] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/06 17:11:18 UTC, 13 replies.
- Re: [PR] [hotfix] Adapt supported Python versions to Flink 1.20 [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/06 18:29:47 UTC, 1 replies.
- [PR] Bump Flink version to 1.20.3 [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/06 18:32:54 UTC, 0 replies.
- [jira] [Created] (FLINK-38868) Bump Flink version to 1.20.3 for AWS connector v5.1 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/06 19:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-38868] Bump Flink version to 1.20.3 [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/06 19:37:48 UTC, 0 replies.
- [jira] [Updated] (FLINK-38868) Bump Flink version to 1.20.3 for AWS connector v5.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/06 19:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38868) Bump Flink version to 1.20.3 for AWS connector v5.1 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/06 19:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35180) Instant in row doesn't convert to correct type in python thread mode - posted by "Wouter Zorgdrager (Jira)" <ji...@apache.org> on 2026/01/06 20:26:00 UTC, 3 replies.
- [jira] [Resolved] (FLINK-38849) HybridSourceReader does not respect pauseOrResumeSplits implementations - posted by "Matt Cuento (Jira)" <ji...@apache.org> on 2026/01/06 23:29:00 UTC, 0 replies.
- Re: [I] [Feature] Support retry when llm response schema is not as expected. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/07 01:17:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-31655) Umbrella: FLIP-339: Adaptive Channel selection for partitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/07 01:29:00 UTC, 0 replies.
- [PR] [Feature] Support multiple jdk versions [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/07 01:30:27 UTC, 5 replies.
- Re: [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2026/01/07 02:11:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-38762) Introduce SingleJobApplication - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/07 02:18:00 UTC, 0 replies.
- [PR] [FLINK-38845][runtime] Add ArchivedApplicationStore to manage terminated applications [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/01/07 02:24:13 UTC, 7 replies.
- [I] [Tech Debt] Load integration from UserCodeClassloader. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/07 02:32:28 UTC, 2 replies.
- [PR] [api][integration] Move mcp module from api to integration. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/07 02:47:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-38842) FileSink may leave orphaned temporary files in COS after restoring from a checkpoint, due to missing cleanup logic for temporary files in the checkpointed state. - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/07 02:48:00 UTC, 0 replies.
- [PR] [FLINK-38848] Supports to pass the required privilege when catalog manager loads the table [flink] - posted by "jerqi (via GitHub)" <gi...@apache.org> on 2026/01/07 03:42:57 UTC, 0 replies.
- [jira] [Updated] (FLINK-38848) Catalog#getTable should indicate if it's for writing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/07 03:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager loads the table [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/07 03:50:07 UTC, 3 replies.
- Re: [PR] [FLINK-36158][FOLLOWUP] Replace the ZK HA path from jobgraphs to execution-plans [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/07 06:26:28 UTC, 0 replies.
- Re: [PR] [FLINK-37991][python] Upgrade pemja to 0.5.4 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/07 06:26:29 UTC, 1 replies.
- [jira] [Created] (FLINK-38869) InitializationContext for KafkaSubscriber - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/01/07 06:54:00 UTC, 0 replies.
- [PR] [api][integration][java] Enrich interface for vector store and implement these for elasticsearch. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/07 07:01:27 UTC, 2 replies.
- [PR] [Feature][runtime] Support the use of Python EembeddingModel in Java [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/07 07:18:13 UTC, 1 replies.
- [PR] [BP-2.2][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] - posted by "ztison (via GitHub)" <gi...@apache.org> on 2026/01/07 07:49:53 UTC, 2 replies.
- [PR] [BP-2.1][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] - posted by "ztison (via GitHub)" <gi...@apache.org> on 2026/01/07 07:51:28 UTC, 2 replies.
- [PR] [BP-2.0][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] - posted by "ztison (via GitHub)" <gi...@apache.org> on 2026/01/07 07:53:07 UTC, 5 replies.
- [jira] [Created] (FLINK-38870) Uninformative error message when job is suspended due to JobManager leadership loss - posted by "ConfX (Jira)" <ji...@apache.org> on 2026/01/07 08:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38870) Uninformative error message when job is suspended due to JobManager leadership loss - posted by "ConfX (Jira)" <ji...@apache.org> on 2026/01/07 08:09:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38870) Uninformative error message when job is suspended due to JobManager leadership loss - posted by "ConfX (Jira)" <ji...@apache.org> on 2026/01/07 08:09:00 UTC, 1 replies.
- Re: [I] [Feature] Improve Python Async Execution API [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/07 08:27:55 UTC, 0 replies.
- Re: [PR] [test] Use qwen3:8b in integration test to improve stability. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/07 08:54:03 UTC, 1 replies.
- [PR] [FLINK-38869] InitializationContext for KafkaSubscriber [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/01/07 09:00:09 UTC, 1 replies.
- [jira] [Updated] (FLINK-38869) InitializationContext for KafkaSubscriber - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/07 09:01:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38862) Partition discovery interval not configurable in upsert mode (tableAPI) - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2026/01/07 09:16:00 UTC, 0 replies.
- Re: [PR] [FLINK-35061][table] Migrate TemporalJoinUtil to java [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/07 09:36:22 UTC, 0 replies.
- [PR] [BP-1.20][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] - posted by "ztison (via GitHub)" <gi...@apache.org> on 2026/01/07 09:55:07 UTC, 2 replies.
- Re: [I] [Feature] Support the use of Python EmbeddingModels in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/07 10:57:09 UTC, 0 replies.
- [PR] [doc] Add doc for error handling strategy. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/07 11:02:33 UTC, 1 replies.
- Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] - posted by "jerqi (via GitHub)" <gi...@apache.org> on 2026/01/07 11:09:25 UTC, 11 replies.
- [jira] [Resolved] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager during reporting metrics - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/07 13:37:00 UTC, 0 replies.
- Re: [D] Community Sync - 2025 [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/07 15:05:23 UTC, 2 replies.
- [D] Community Sync - 2026 [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/07 15:28:42 UTC, 11 replies.
- Re: [PR] [FLINK-38689] [flink-protobuf] Add support for protobuf 4.x field name conflict resolution [flink] - posted by "khaledh (via GitHub)" <gi...@apache.org> on 2026/01/07 15:39:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-38817) Out of order data seen while running tpc-ds queries - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2026/01/07 17:04:00 UTC, 7 replies.
- [jira] [Assigned] (FLINK-38869) InitializationContext for KafkaSubscriber - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2026/01/07 17:12:00 UTC, 0 replies.
- [PR] Revert "[hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35" [flink-shaded] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/07 19:20:03 UTC, 1 replies.
- [PR] Add AWS Connectors 5.1.0 [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/07 20:10:29 UTC, 1 replies.
- [jira] [Created] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields - posted by "Vishal Kamlapure (Jira)" <ji...@apache.org> on 2026/01/07 21:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields - posted by "Vishal Kamlapure (Jira)" <ji...@apache.org> on 2026/01/07 21:42:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields - posted by "Vishal Kamlapure (Jira)" <ji...@apache.org> on 2026/01/07 21:45:00 UTC, 3 replies.
- Re: [I] [Feature] Support the use of Java MCP in Python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/08 01:16:01 UTC, 1 replies.
- Re: [I] [Feature] Support the use of Python MCP in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/08 01:23:19 UTC, 1 replies.
- Re: [PR] [FLINK-38100] Bump Iceberg dependency to 1.10.1 in iceberg-pipeline-sink connector [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/08 02:02:36 UTC, 0 replies.
- [jira] [Closed] (FLINK-38100) Add BigQuery catalog support for iceberg pipeline sink connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/08 02:05:00 UTC, 0 replies.
- [PR] [plan][hotfix] Avoid retrying chat even if response is valid. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/08 03:54:39 UTC, 1 replies.
- [PR] [doc] Add doc for JAVA MCP Server tools and prompts [flink-agents] - posted by "yanand0909 (via GitHub)" <gi...@apache.org> on 2026/01/08 04:05:12 UTC, 5 replies.
- [jira] [Created] (FLINK-38872) waitForAllTaskRunning Hang Indefinitely - posted by "ConfX (Jira)" <ji...@apache.org> on 2026/01/08 05:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38872) waitForAllTaskRunning Hang Indefinitely - posted by "ConfX (Jira)" <ji...@apache.org> on 2026/01/08 05:51:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38873) mysql pipeline error when adding the same column - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2026/01/08 06:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38873) mysql pipeline error when adding the same column - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2026/01/08 06:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38873) mysql pipeline error when adding the same column - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/08 06:11:00 UTC, 0 replies.
- Re: [PR] [hotfix] Avoid duplicate loop for configuration [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/08 06:26:25 UTC, 0 replies.
- Re: [I] [Feature] Update release infra to support multi-jdk version [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/08 06:31:42 UTC, 0 replies.
- [PR] [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/08 07:19:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-38835) When using postgresql cdc to read timestamp data with a value of 1900-01-01, abnormal data occurred - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/08 07:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34416) "Local recovery and sticky scheduling end-to-end test" still doesn't work with AdaptiveScheduler - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/08 08:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38596) The comment of the created MaxCompute table is incorrect - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/08 08:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] - posted by "yunfengzhou-hub (via GitHub)" <gi...@apache.org> on 2026/01/08 10:06:34 UTC, 20 replies.
- [jira] [Updated] (FLINK-38853) Umbrella: FLIP-352: Enhance the standardization of the REST API JSON schema - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/08 10:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38853) Umbrella: FLIP-352: Enhance the standardization of the REST API JSON schema - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/08 10:35:00 UTC, 1 replies.
- Re: [PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/08 11:06:20 UTC, 3 replies.
- Re: [I] [Tech Debt] Improve Ollama related tests(start_ollama_server.sh) in CI [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/08 11:06:32 UTC, 1 replies.
- Re: [I] [Feature] Support local execution in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/08 11:16:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/08 11:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/08 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/08 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2026/01/08 12:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2026/01/08 12:43:00 UTC, 1 replies.
- [PR] [FLINK-38875] Bump Java Operator SDK to version 5.2.2 [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2026/01/08 12:44:02 UTC, 2 replies.
- Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] - posted by "neoneo008 (via GitHub)" <gi...@apache.org> on 2026/01/08 14:28:27 UTC, 11 replies.
- Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/08 15:27:06 UTC, 11 replies.
- [PR] [FLINK-38263][table] add secret store related interfaces [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2026/01/08 23:21:40 UTC, 33 replies.
- [jira] [Updated] (FLINK-38263) Connection and secret factory - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/08 23:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/08 23:23:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/08 23:23:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/08 23:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38530) create Dynamic Kafka Source for pyflink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/08 23:27:00 UTC, 1 replies.
- Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/01/08 23:27:04 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-38817) Out of order data seen while running tpc-ds queries - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2026/01/09 00:55:00 UTC, 1 replies.
- Re: [PR] [FLINK-38808][pipeline-connector][iceberg] Support partition transforms in Iceberg sink [flink-cdc] - posted by "fcfangcc (via GitHub)" <gi...@apache.org> on 2026/01/09 01:42:24 UTC, 2 replies.
- [PR] [runtime] Introduce CallRecord to ActionState [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/09 01:44:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-37902) Support batch execution for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2026/01/09 02:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37902) Support batch execution for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2026/01/09 02:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37902) Support batch execution for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2026/01/09 02:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37902) Support batch execution for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2026/01/09 02:20:00 UTC, 0 replies.
- [I] [Feature] Support Fine-Grain Durable Execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/09 02:49:46 UTC, 2 replies.
- [jira] [Commented] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ - posted by "boxes (Jira)" <ji...@apache.org> on 2026/01/09 02:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ - posted by "boxes (Jira)" <ji...@apache.org> on 2026/01/09 02:58:00 UTC, 0 replies.
- Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/09 03:00:22 UTC, 8 replies.
- [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] - posted by "drossos (via GitHub)" <gi...@apache.org> on 2026/01/09 03:37:44 UTC, 6 replies.
- [jira] [Updated] (FLINK-38577) FlinkBlueGreenDeployment Kubernetes Networking Update / Ingress not Stable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/09 03:38:00 UTC, 0 replies.
- [I] [Feature] Simplify the custom event definition. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/09 03:48:04 UTC, 0 replies.
- [PR] [FLINK-38596][pipeline][maxcompute] Fix the column comment of CreateTableEvent and AddColumnEvent [flink-cdc] - posted by "linguoxuan (via GitHub)" <gi...@apache.org> on 2026/01/09 05:18:48 UTC, 3 replies.
- [jira] [Updated] (FLINK-38596) The comment of the created MaxCompute table is incorrect - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/09 05:19:00 UTC, 0 replies.
- Re: [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 9.37.4 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/09 06:26:34 UTC, 0 replies.
- [jira] [Created] (FLINK-38878) Add PARSE_JSON/TRY_PARSE_JSON function to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/09 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38877) Introduce VARIANT type to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/09 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38879) Add VARIANT type support in Paimon pipeline sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/09 06:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38189) Allow it to sink data to Kafka partitions based on KEY in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/09 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38880) Add async scalar function support in Python - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/09 06:34:00 UTC, 0 replies.
- [PR] [FLINK-XXXXX][postgres] Support partition table routing for PostgreSQL CDC [flink-cdc] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2026/01/09 06:55:55 UTC, 0 replies.
- [jira] [Closed] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/09 06:58:00 UTC, 0 replies.
- [PR] [FLINK-38877][common] Add variant type. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/09 07:00:31 UTC, 5 replies.
- [jira] [Updated] (FLINK-38877) Introduce VARIANT type to Flink CDC pipeline - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/09 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38881) PostgreSQL Partition Table Routing Support - posted by "tchivs (Jira)" <ji...@apache.org> on 2026/01/09 07:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38881) PostgreSQL Partition Table Routing Support - posted by "tchivs (Jira)" <ji...@apache.org> on 2026/01/09 07:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38596) The comment of the created MaxCompute table is incorrect - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/09 07:58:00 UTC, 0 replies.
- Re: [PR] [FLINK-38183] Fix the problem of data loss in the GTID disordered scenario [flink-cdc] - posted by "lzshlzsh (via GitHub)" <gi...@apache.org> on 2026/01/09 08:33:14 UTC, 0 replies.
- [jira] [Created] (FLINK-38882) Introduce rules for async python scalar function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/09 08:38:00 UTC, 0 replies.
- [PR] [FLINK-38882][table] Introduce rules for async python scalar function [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2026/01/09 08:40:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-38882) Introduce rules for async python scalar function - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/09 08:41:00 UTC, 0 replies.
- Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/09 08:46:19 UTC, 16 replies.
- [jira] [Commented] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated - posted by "Royston Tauro (Jira)" <ji...@apache.org> on 2026/01/09 09:06:00 UTC, 1 replies.
- [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/09 09:32:05 UTC, 13 replies.
- Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] - posted by "linjianchang (via GitHub)" <gi...@apache.org> on 2026/01/09 09:40:33 UTC, 19 replies.
- Re: [PR] Add async execution support for built-in actions [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/09 09:52:41 UTC, 1 replies.
- [jira] [Created] (FLINK-38883) Race condition of REST API and JRS entry might lead to inconsistent state - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/09 14:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38883) Race condition of REST API and JRS entry might lead to inconsistent state - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/09 14:22:00 UTC, 1 replies.
- [PR] [hotfix] Update copyright year to 2026 [flink-shaded] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/09 16:56:28 UTC, 1 replies.
- [PR] [FLINK-38876] Support per-cluster offset in Dynamic Kafka Source [flink-connector-kafka] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/01/09 17:17:27 UTC, 6 replies.
- [PR] Bump @angular/core from 20.1.3 to 20.3.16 in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/09 19:00:43 UTC, 1 replies.
- [PR] Bump @angular/compiler from 20.1.3 to 20.3.16 in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/09 19:00:43 UTC, 1 replies.
- Re: [PR] Bump @angular/compiler from 20.1.3 to 20.3.15 in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/09 19:00:47 UTC, 1 replies.
- Re: [PR] [FLINK-38530] create Dynamic Kafka Source for pyflink [flink-connector-kafka] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/01/10 03:34:49 UTC, 1 replies.
- Re: [PR] EDIT contributor in flink cdc 3.1.0 release notes [flink-web] - posted by "SML0127 (via GitHub)" <gi...@apache.org> on 2026/01/10 06:45:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-34597) Migrate SimplifyFilterConditionRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 10:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34597) Migrate SimplifyFilterConditionRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 10:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37009) Migrate PruneAggregateCallRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 11:18:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37009) Migrate PruneAggregateCallRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 11:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37009) Migrate PruneAggregateCallRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38884) Migrate IncrementalAggregateRule - posted by "Roman Rybak (Jira)" <ji...@apache.org> on 2026/01/10 13:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38884) Migrate IncrementalAggregateRule java - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 13:52:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38884) Migrate IncrementalAggregateRule java - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 13:53:00 UTC, 0 replies.
- [PR] [FLINK-38884][table] Migrate IncrementalAggregateRule to java [flink] - posted by "RVRhub (via GitHub)" <gi...@apache.org> on 2026/01/10 14:06:42 UTC, 1 replies.
- Re: [PR] [FLINK-38884][table] Migrate `IncrementalAggregateRule` to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/10 19:21:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-38884) Migrate IncrementalAggregateRule java - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 19:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38884) Migrate IncrementalAggregateRule java - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 19:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38884) Migrate IncrementalAggregateRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 21:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38885) Migrate StreamPhysicalJoinRuleBase and its children - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 23:28:00 UTC, 0 replies.
- [PR] [FLINK-38885][table] Migrate `StreamPhysicalJoinRuleBase` and its children [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/10 23:31:43 UTC, 2 replies.
- [jira] [Updated] (FLINK-38885) Migrate StreamPhysicalJoinRuleBase and its children - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/10 23:32:00 UTC, 0 replies.
- Re: [PR] [FLINK-38804][runtime] draft fix [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2026/01/11 09:07:54 UTC, 2 replies.
- [jira] [Created] (FLINK-38886) Provide GenericRecordData in Pipeline public API - posted by "yux (Jira)" <ji...@apache.org> on 2026/01/11 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38887) YAML Transform module supports nested types - posted by "yux (Jira)" <ji...@apache.org> on 2026/01/11 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38888) YAML Pipeline supports item subscription of complex types - posted by "yux (Jira)" <ji...@apache.org> on 2026/01/11 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38889) YAML Kafka sink connector supports serializing complex types - posted by "yux (Jira)" <ji...@apache.org> on 2026/01/11 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38890) Migrate PullUpWindowTableFunctionIntoWindowAggregateRule - posted by "Roman Rybak (Jira)" <ji...@apache.org> on 2026/01/11 11:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38890) Migrate PullUpWindowTableFunctionIntoWindowAggregateRule - posted by "Roman Rybak (Jira)" <ji...@apache.org> on 2026/01/11 11:55:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38889) YAML Kafka sink connector supports serializing complex types - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/11 11:55:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38890) Migrate PullUpWindowTableFunctionIntoWindowAggregateRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/11 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38891) Migrate MiniBatchIntervalInferRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/11 15:00:00 UTC, 0 replies.
- [PR] [FLINK-38891][table] Migrate `MiniBatchIntervalInferRule` to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/11 15:01:40 UTC, 2 replies.
- [jira] [Updated] (FLINK-38891) Migrate MiniBatchIntervalInferRule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/11 15:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-31515) Move execution logic of AnalyzeTableOperation out from TableEnvironmentImpl - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/11 17:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31515) Move execution logic of AnalyzeTableOperation out from TableEnvironmentImpl - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/11 17:27:00 UTC, 0 replies.
- [PR] [hotfix][javadoc] Skip `skip-webui-build` while `javadoc:aggregate` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/11 18:09:08 UTC, 0 replies.
- Re: [PR] [hotfix][javadoc] Use `skip-webui-build` while `javadoc:aggregate` [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/11 18:14:29 UTC, 6 replies.
- Re: [I] [Feature][Doc] Add document for Elasticsearch VectorStore integration [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/12 01:34:37 UTC, 0 replies.
- Re: [I] [Feature][integration][Java] Java Implementation of Vector Store with Elasticsearch Support [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/12 01:34:47 UTC, 0 replies.
- [I] [Tech Debt] Unify the implementation of Long-Term Memory between python and java. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/12 02:52:07 UTC, 0 replies.
- [PR] [Feature][runtime] Support the use of Java EembeddingModel in Python [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/12 03:15:48 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-38889) YAML Kafka sink connector supports serializing complex types - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/12 03:20:00 UTC, 1 replies.
- Re: [PR] [FLINK-36520] CDC Supports MySQL 8.x and above [flink-cdc] - posted by "Romeoy (via GitHub)" <gi...@apache.org> on 2026/01/12 03:21:38 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38889) YAML Kafka sink connector supports serializing complex types - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/01/12 03:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38763) Add REST API for JarRunApplication - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/12 03:37:00 UTC, 1 replies.
- [PR] [FLINK-38886] Introduce `GenericRecordData` and Internal / External converters in flink-cdc-common [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/01/12 04:04:57 UTC, 5 replies.
- [jira] [Updated] (FLINK-38886) Provide GenericRecordData in Pipeline public API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/12 04:05:00 UTC, 0 replies.
- [PR] [FLINK-38021] [cdc connector mysql] Support double quotes in MySQL DDL parsing for DEFAULT VALUE and COMMENT [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/01/12 06:13:16 UTC, 1 replies.
- [jira] [Updated] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/12 06:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/12 06:26:39 UTC, 0 replies.
- Re: [PR] [FLINK-38345][flink-connector-base] Added previousEnumerator resolution for HybridSource during checkpoint recovery [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/12 06:26:43 UTC, 3 replies.
- [jira] [Commented] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/12 06:29:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/12 06:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/12 06:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-27519) Fix duplicates names when there are multiple levels of over window aggregate - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2026/01/12 06:46:00 UTC, 0 replies.
- [PR] [api][runtime] Clean up resource when close. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/12 08:51:32 UTC, 5 replies.
- [jira] [Commented] (FLINK-38244) When the column name of mysql supports case insensitive, fix the error that column name not being found - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/01/12 09:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38244) When the column name of mysql supports case insensitive, fix the error that column name not being found - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/01/12 09:16:00 UTC, 0 replies.
- Re: [PR] [released] Add Flink-Shaded 21.0 [flink-web] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2026/01/12 09:55:19 UTC, 1 replies.
- Re: [PR] [FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/12 10:13:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 10:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 10:16:00 UTC, 0 replies.
- [jira] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38893) Introduce the /jobs/:jobid/rescales/overview endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38892) Introduce the scheduler and type information of the target job in the /jobs/overview endpoint of the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38894) Introduce the /jobs/:jobid/rescales/history endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38896) Introduce the /jobs/:jobid/rescales/summary endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38895) Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38899) Introduce the Rescales/History sub-page for streaming jobs with the adaptive scheduler enabled - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38900) Introduce the Rescales/Summary sub-page for streaming jobs with the adaptive scheduler enabled - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38898) Introduce the Rescales/Overview sub-page for streaming jobs with the adaptive scheduler enabled - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38901) Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38902) Add user instructions and usage documentation for FLIP-487. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:59:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38894) Introduce the /jobs/:jobid/rescales/history endpoint in the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 11:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 11:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38902) Add user instructions and usage documentation for FLIP-487. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 11:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38895) Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 11:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38896) Introduce the /jobs/:jobid/rescales/summary endpoint in the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 11:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38892) Introduce the scheduler and type information of the target job in the /jobs/overview endpoint of the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 11:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38893) Introduce the /jobs/:jobid/rescales/overview endpoint in the REST API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/12 11:00:00 UTC, 0 replies.
- [PR] [build] Update copyright year to 2026 [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2026/01/12 12:40:10 UTC, 1 replies.
- [jira] [Closed] (FLINK-38816) HTTP Connector : Change deserialize method invocation so can work with Flink 2 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/12 12:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38816) HTTP Connector : Change deserialize method invocation so can work with Flink 2 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/12 12:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38527) Upgrade Netty version to 4.1.128.Final for Flink LTS 1.20 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/12 12:53:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/12 13:37:00 UTC, 0 replies.
- [PR] [hotfix] Fixup test implementation [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/12 14:30:45 UTC, 0 replies.
- [PR] [FLINK-38889][pipeline][kafka] Support serializing complex types(MAP, ARRAY, ROW) to JSON (Debezium / Canal) [flink-cdc] - posted by "linguoxuan (via GitHub)" <gi...@apache.org> on 2026/01/12 14:34:20 UTC, 9 replies.
- [jira] [Updated] (FLINK-38889) YAML Kafka sink connector supports serializing complex types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/12 14:35:00 UTC, 0 replies.
- Re: [PR] [hotfix] Remove unnecessary `ListCollector` impl [flink-connector-http] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/12 15:35:02 UTC, 0 replies.
- [jira] [Created] (FLINK-38904) MySQL CDC binlog reader hangs due to TLS 1.3 KeyUpdate deadlock (potentially JDK-8241239) - posted by "John Watson (Jira)" <ji...@apache.org> on 2026/01/12 16:01:00 UTC, 0 replies.
- [PR] [hotfix] Improve test coverage of UnalignedCheckpointsInterruptibleTimersTest [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2026/01/12 16:49:54 UTC, 2 replies.
- [jira] [Commented] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/12 18:58:00 UTC, 2 replies.
- Re: [PR] [FLINK-37155] [Runtime/Coordination] Implementing FLIP-505 for Flink History Server scalability improvements to decouple local and remote storage [flink] - posted by "mattcuento (via GitHub)" <gi...@apache.org> on 2026/01/12 23:23:06 UTC, 2 replies.
- [PR] test connector compatibility with flink 1.19 [flink-connector-kafka] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/01/13 00:52:30 UTC, 0 replies.
- Re: [I] [Feature] Support the use of Java EmbeddingModels in Python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/13 01:05:48 UTC, 0 replies.
- Re: [PR] [FLINK-0] test connector compatibility with flink 1.19 [flink-connector-kafka] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/01/13 01:20:02 UTC, 0 replies.
- Re: [I] [Feature] Introduce Long-Term Memory in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/13 01:29:04 UTC, 0 replies.
- Re: [I] [Feature] Introduce Long-Term Memory [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/13 01:29:19 UTC, 0 replies.
- [jira] [Updated] (FLINK-38823) Error running wide table task - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/01/13 02:41:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38823) Error running wide table task - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/13 03:13:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38905) YAML Transform to handle dirty data gracefully - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/01/13 06:20:00 UTC, 0 replies.
- Re: [PR] Reuse byte array buffer in BlobServerConnection::run [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/13 06:26:28 UTC, 1 replies.
- Re: [PR] [FLINK-38515][flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/13 06:26:31 UTC, 0 replies.
- [jira] [Created] (FLINK-38906) Polish YAML transform built-in functions - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/01/13 06:27:00 UTC, 0 replies.
- [PR] [tests][runtime] Add spec-based transform test cases [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/01/13 06:37:15 UTC, 1 replies.
- Re: [PR] [FLINK-38542][checkpoint] Recover output buffers of upstream task on downstream task side directly [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2026/01/13 06:47:32 UTC, 0 replies.
- Re: [PR] [FLINK-38850] Support PostgreSQL uuid type [flink-connector-jdbc] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/13 07:03:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38804) The shutdown sequence is incorrect causes TaskManager is shutting down - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/13 07:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38804) The shutdown sequence is incorrect causes TaskManager is shutting down - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/13 07:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38804) The shutdown sequence is incorrect causes TaskManager is shutting down - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/13 07:18:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38542) Recover output buffers of upstream task on downstream task side directly - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/13 07:18:00 UTC, 0 replies.
- [D] Java Async Execution Design [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/13 07:36:27 UTC, 0 replies.
- Re: [D] Support Java Async Execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/13 07:39:08 UTC, 0 replies.
- [I] [Feature] Support Java Async Execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/13 07:41:31 UTC, 2 replies.
- [jira] [Updated] (FLINK-38902) Add user instructions and usage documentation for FLIP-487 - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/13 07:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38899) Introduce the Rescales/History sub-page for streaming jobs with the adaptive scheduler enabled - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/13 08:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38904) MySQL CDC binlog reader hangs due to TLS 1.3 KeyUpdate deadlock (potentially JDK-8241239) - posted by "John Watson (Jira)" <ji...@apache.org> on 2026/01/13 10:00:00 UTC, 1 replies.
- [PR] [FLINK-38761][runtime] Support archiving applications [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/01/13 10:54:09 UTC, 2 replies.
- [jira] [Updated] (FLINK-38761) Support archiving applications - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/13 10:55:00 UTC, 1 replies.
- [PR] [Feature][runtime] Support the use of Python VectorStore in Java [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/13 11:00:43 UTC, 1 replies.
- [PR] [FLINK-33123][runtime] Fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/13 11:15:48 UTC, 7 replies.
- [jira] [Updated] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/13 11:16:00 UTC, 0 replies.
- Re: [PR] [FLINK-38763][runtime] Add REST API for JarRunApplication [flink] - posted by "zhuzhurk (via GitHub)" <gi...@apache.org> on 2026/01/13 11:33:33 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38823) Error running wide table task - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/01/13 11:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38810) Use splittable timers in Interval Join - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/13 12:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38864) HTTP Connector : Add IGNORE_STATUS_CODE http-completion-state - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/13 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38907) Records lost using filtered autocreate mode - posted by "Gio Gutierrez (Jira)" <ji...@apache.org> on 2026/01/13 17:14:00 UTC, 0 replies.
- [PR] checking Lyft diffs [flink] - posted by "maheepm-lyft (via GitHub)" <gi...@apache.org> on 2026/01/13 17:59:45 UTC, 3 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 2026/01/13 18:29:00 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 2026/01/13 18:29:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/13 19:18:00 UTC, 0 replies.
- [PR] [FLINK-38903] Fix flaky ExecutionPartitionLifecycleTest [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/01/13 19:23:55 UTC, 1 replies.
- [jira] [Updated] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/13 19:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/13 19:33:00 UTC, 3 replies.
- [PR] [FLINK-38903] Update flink-shaded to 21.0 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/01/13 19:43:39 UTC, 17 replies.
- [PR] [hotfix] re-enable unit tests in pyflink test_kafka.py [flink] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/01/13 20:40:42 UTC, 11 replies.
- [PR] [FLINK-38530] create Dynamic Kafka Source for pyflink [flink] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/01/13 21:16:45 UTC, 8 replies.
- [jira] [Resolved] (FLINK-38891) Migrate MiniBatchIntervalInferRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/13 21:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38891) Migrate MiniBatchIntervalInferRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/13 21:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36988) Migrate LogicalCorrelateToJoinFromTemporalTableFunctionRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/13 21:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36988) Migrate LogicalCorrelateToJoinFromTemporalTableFunctionRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/13 21:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36988) Migrate LogicalCorrelateToJoinFromTemporalTableFunctionRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/13 21:31:00 UTC, 0 replies.
- [PR] [FLINK-38907][postgres] Debezium publication filtering data lost [flink-cdc] - posted by "bakjos (via GitHub)" <gi...@apache.org> on 2026/01/13 23:23:43 UTC, 1 replies.
- [jira] [Updated] (FLINK-38907) Records lost using filtered autocreate mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/13 23:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38909) Unable to delete S3 checkpoint due to presence of default file - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2026/01/14 02:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38909) Unable to delete S3 checkpoint due to presence of default file - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2026/01/14 02:31:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-38763) Add REST API for JarRunApplication - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/14 03:07:00 UTC, 0 replies.
- Re: [I] [Feature] Support the use of Python VectorStore in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/14 03:10:18 UTC, 0 replies.
- [jira] [Created] (FLINK-38910) mysql-cdc-connector datastrea support scan.binlog.newly-added-table.enabled config - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/14 05:42:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38910) mysql-cdc-connector datastrea support scan.binlog.newly-added-table.enabled config - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/14 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled config - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/14 05:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled config - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/14 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38912) Upgrade Flink to use Netty 4.2.6.Final - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/14 05:48:00 UTC, 0 replies.
- [PR] [hotfix][build][javadoc] Use `${target.java.version}` in javadoc plugin [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/14 06:43:01 UTC, 2 replies.
- [I] [Feature] Use class name to declare resources and provide constant for built-in resources. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/14 07:34:56 UTC, 1 replies.
- [PR] [api ]Provide constant to point a resource to avoid importing integration package. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/14 07:39:55 UTC, 2 replies.
- [PR] Support connecting to remote MCP with predefined prompts [flink-agents] - posted by "qingfei1994 (via GitHub)" <gi...@apache.org> on 2026/01/14 09:06:54 UTC, 5 replies.
- [I] [Bug] ChatModelCrossLanguageTest.testChatModeIntegration failed when use ollama server 0.14.0 [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/14 09:26:06 UTC, 3 replies.
- [jira] [Commented] (FLINK-38906) Polish YAML transform built-in functions - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/14 09:27:00 UTC, 0 replies.
- Re: [I] [Tech Debt] Support close method for Resource [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/14 09:38:15 UTC, 0 replies.
- [PR] [hotfix] Use qwen3:1.7b in ChatModelCrossLanguageTest to improve stability [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/14 11:12:28 UTC, 1 replies.
- [jira] [Created] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with nested objects - posted by "david radley (Jira)" <ji...@apache.org> on 2026/01/14 12:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table computed rows including casts to null - posted by "david radley (Jira)" <ji...@apache.org> on 2026/01/14 12:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with computed rows including casts to null - posted by "david radley (Jira)" <ji...@apache.org> on 2026/01/14 12:05:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with computed rows including casts to null - posted by "david radley (Jira)" <ji...@apache.org> on 2026/01/14 12:06:00 UTC, 4 replies.
- [jira] [Assigned] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with computed rows including casts to null - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/14 12:14:00 UTC, 0 replies.
- [PR] Release 1.19 lyft [flink] - posted by "maheepm-lyft (via GitHub)" <gi...@apache.org> on 2026/01/14 12:31:41 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/01/14 12:44:00 UTC, 0 replies.
- [PR] [FLINK-38077] Make sure jobmanager is accessible when trying to cancel for suspend/upgrade [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2026/01/14 12:58:28 UTC, 1 replies.
- [jira] [Updated] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/14 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38914) Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/14 13:32:00 UTC, 0 replies.
- [PR] Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/14 13:57:44 UTC, 1 replies.
- [PR] [FLINK-38914][BP 2.1][docs] Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/14 14:48:17 UTC, 2 replies.
- [jira] [Updated] (FLINK-38914) Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/14 14:49:00 UTC, 2 replies.
- [PR] [FLINK-38914][BP 2.0][docs] Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/14 14:50:17 UTC, 2 replies.
- [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2026/01/14 15:17:11 UTC, 1 replies.
- [jira] [Updated] (FLINK-38551) Extend MultiJoin tests based on current join tests - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/14 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38915) Suspending Pipeline Breaks FlinkBlueGreenDeployment - posted by "Daniel Rossos (Jira)" <ji...@apache.org> on 2026/01/14 15:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/14 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38916) MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 - posted by "Stepan Stepanishchev (Jira)" <ji...@apache.org> on 2026/01/14 15:48:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/14 15:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with computed rows including casts to null - posted by "david radley (Jira)" <ji...@apache.org> on 2026/01/14 16:50:00 UTC, 1 replies.
- Re: [PR] [FLINK-38908] Fix flaky ExecutionPartitionLifecycleTest [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/01/14 18:14:43 UTC, 1 replies.
- [jira] [Updated] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 18:41:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 18:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 18:41:00 UTC, 0 replies.
- [PR] [FLINK-38917] add doc of pyflink DynamicKafkaSource to flink-connector-kafka [flink-connector-kafka] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/01/14 18:42:15 UTC, 2 replies.
- [PR] [hotfix] Update project version to 6.0-SNAPSHOT [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/14 19:04:02 UTC, 1 replies.
- Re: [PR] [FLINK-38914][docs] Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/14 19:08:19 UTC, 2 replies.
- [jira] [Commented] (FLINK-38507) OpenTelemetryTraceReporterITCase failed in Test - connect - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/14 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38918) support per cluster offset for DynamicKafkaSource in pyflink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 19:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38918) support per cluster offset for DynamicKafkaSource in pyflink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 19:13:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 19:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-37863] add DynamicKafkaSource interface [flink-connector-kafka] - posted by "lgo (via GitHub)" <gi...@apache.org> on 2026/01/14 20:03:22 UTC, 1 replies.
- [jira] [Commented] (FLINK-37864) Extend DynamicKafkaSource to allow for cluster-specific OffsetsInitializer - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 20:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37863) DynamicKafkaSource support in PyFlink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 20:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37863) DynamicKafkaSource support in PyFlink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 20:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37864) Extend DynamicKafkaSource to allow for cluster-specific OffsetsInitializer - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 20:09:00 UTC, 0 replies.
- [PR] [hotfix] Turn back Python tests [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/14 20:11:38 UTC, 1 replies.
- [jira] [Created] (FLINK-38920) create Table source and factory for DynamicKafkaSource in Flink Table API - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 21:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38920) create Table source and factory for DynamicKafkaSource in Flink Table API - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 21:46:00 UTC, 1 replies.
- [PR] [FLINK-38920] create Table source and factory for DynamicKafkaSource in Flink Table API [flink-connector-kafka] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/01/14 22:05:28 UTC, 9 replies.
- Re: [PR] [FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/15 00:05:39 UTC, 0 replies.
- [I] [Feature][doc] Add guidelines for how to choose between java / python apis [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/15 01:08:18 UTC, 5 replies.
- [PR] [runtime] Support Java async execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/15 01:40:45 UTC, 4 replies.
- [jira] [Closed] (FLINK-38530) create Dynamic Kafka Source for pyflink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/15 01:42:00 UTC, 0 replies.
- Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/15 06:26:28 UTC, 3 replies.
- [PR] [Feature][runtime] Support the use of Java VectorStore in Python [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/15 06:33:30 UTC, 4 replies.
- [jira] [Resolved] (FLINK-38877) Introduce VARIANT type to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/15 06:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-38799][runtime] Rename `LoadingWeight` to `SchedulingLoad` [flink] - posted by "zhuzhurk (via GitHub)" <gi...@apache.org> on 2026/01/15 06:50:17 UTC, 3 replies.
- [jira] [Updated] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/15 07:29:00 UTC, 0 replies.
- Re: [PR] [FLINK-38054] flink-connector-elasticsearch8 use correct ClassLoader in OperationSerializer [flink-connector-elasticsearch] - posted by "denizgursoy (via GitHub)" <gi...@apache.org> on 2026/01/15 08:25:14 UTC, 2 replies.
- [jira] [Created] (FLINK-38921) osc support custom regx - posted by "谢波 (Jira)" <ji...@apache.org> on 2026/01/15 08:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38921) osc support custom regx - posted by "谢波 (Jira)" <ji...@apache.org> on 2026/01/15 08:35:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38921) osc support custom regx - posted by "谢波 (Jira)" <ji...@apache.org> on 2026/01/15 08:36:00 UTC, 0 replies.
- Re: [I] [Feature] Support the use of Java VectorStore in Python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/15 09:32:00 UTC, 0 replies.
- Re: [I] [Feature] Support the use of Java resources in Python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/15 09:32:33 UTC, 0 replies.
- [PR] [hotfix] Log whether interruptible timers are enabled [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/01/15 09:36:18 UTC, 2 replies.
- [jira] [Created] (FLINK-38922) Cache Maven dependencies during documentation build - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 10:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38914) Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 10:09:00 UTC, 5 replies.
- [PR] [FLINK-38922][docs] Cache Maven dependencies during documentation building [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/15 10:09:57 UTC, 2 replies.
- [jira] [Updated] (FLINK-38922) Cache Maven dependencies during documentation build - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/15 10:10:00 UTC, 0 replies.
- [PR] [FLINK-38914][BP 2.2][docs] Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/15 10:15:44 UTC, 1 replies.
- [jira] [Created] (FLINK-38923) Pass configuration to operators/functions useInterruptibleTimers() - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/15 10:19:00 UTC, 0 replies.
- [PR] [FLINK-38914][BP 1.20][docs] Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/15 10:20:21 UTC, 2 replies.
- [PR] [FLINK-38914][BP 1.19][docs] Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/15 10:22:16 UTC, 1 replies.
- [PR] [FLINK-38923] Pass config to useInterruptibleTimers() [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/01/15 10:25:18 UTC, 2 replies.
- [jira] [Updated] (FLINK-38923) Pass configuration to operators/functions useInterruptibleTimers() - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/15 10:26:00 UTC, 0 replies.
- [PR] [FLINK-38909] Fix Unable to delete S3 checkpoint due to presence of default file [flink] - posted by "llllssss94 (via GitHub)" <gi...@apache.org> on 2026/01/15 10:58:03 UTC, 6 replies.
- [PR] [plan][python] Built-in actions support async execution. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/15 11:20:59 UTC, 5 replies.
- [jira] [Closed] (FLINK-38761) Support archiving applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/15 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38924) Redirect users to main page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 12:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38924) Redirect users to main page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 12:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38924) Redirect users to documentation home page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 12:56:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38924) Redirect users to documentation home page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 12:56:00 UTC, 0 replies.
- [PR] [FLINK-38924][docs] Redirect users to documentation home page when encountering a 404 [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/15 13:01:38 UTC, 6 replies.
- [jira] [Created] (FLINK-38925) Update Matomo URL to the right domain - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 13:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38923) Pass configuration to operators/functions useInterruptibleTimers() - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/15 13:48:00 UTC, 0 replies.
- [PR] [FLINK-38878][runtime] Add parse_json function. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/15 13:59:53 UTC, 15 replies.
- [jira] [Updated] (FLINK-38878) Add PARSE_JSON/TRY_PARSE_JSON function to Flink CDC pipeline - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/15 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38926) FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38927) Support ON CONFLICT in SqlParser - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38929) Add the ON CONFLICT configuration options - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37477) Emit full deletes from StreamJoin if it gets deletes on key on input - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:58:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37474) FLIP-510: Drop ChangelogNormalize for operations which don't need it - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37474) FLIP-510: Drop ChangelogNormalize for operations which don't need it - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:58:00 UTC, 0 replies.
- [PR] [FLINK-38925][docs] Update Matomo URL to the right domain [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/15 14:58:52 UTC, 2 replies.
- [jira] [Updated] (FLINK-38925) Update Matomo URL to the right domain - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/15 14:59:00 UTC, 1 replies.
- [PR] [FLINK-38927] Support ON CONFLICT in SqlParser [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2026/01/15 15:00:55 UTC, 11 replies.
- [jira] [Updated] (FLINK-38927) Support ON CONFLICT in SqlParser - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/15 15:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery - posted by "Tim Van Laer (Jira)" <ji...@apache.org> on 2026/01/15 15:09:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery - posted by "Tim Van Laer (Jira)" <ji...@apache.org> on 2026/01/15 15:10:00 UTC, 0 replies.
- Re: [PR] [FLINK-38764] Upgrade lz4 to 1.8.1 due to security vulnerability [flink] - posted by "sajjadrizvi (via GitHub)" <gi...@apache.org> on 2026/01/15 15:17:43 UTC, 3 replies.
- [jira] [Updated] (FLINK-38541) Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/15 16:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38930) Filtering record before processing without spilling strategy - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/15 16:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38930) Filtering record before processing without spilling strategy - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/15 16:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38544) Filtering record before processing with spilling strategy - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/15 16:54:00 UTC, 0 replies.
- Re: [PR] [FLINK-36181] Upgrade java version to 11 [flink-connector-shared-utils] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/15 17:40:33 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38048) flink-connector-parent java version should be set to 11 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/15 17:42:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38048) flink-connector-parent java version should be set to 11 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/15 17:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38922) Cache Maven dependencies during documentation build - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 20:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38925) Update Matomo URL to the right domain - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 20:25:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/16 00:28:00 UTC, 0 replies.
- Re: [PR] [hotfix] re-enable unit tests test_kafka.py for pyflink [flink] - posted by "bowenli86 (via GitHub)" <gi...@apache.org> on 2026/01/16 02:01:39 UTC, 3 replies.
- [jira] [Closed] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/16 02:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/16 02:10:00 UTC, 0 replies.
- [PR] [fix][runtime] Fix not switch memory context for async action task. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/16 02:33:50 UTC, 3 replies.
- [jira] [Created] (FLINK-38931) Support finish method in Python Table Function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/16 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2026/01/16 04:51:00 UTC, 0 replies.
- [PR] [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2026/01/16 05:01:46 UTC, 12 replies.
- [jira] [Updated] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/16 05:02:00 UTC, 1 replies.
- [PR] Fix async compation [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/16 05:24:47 UTC, 1 replies.
- [jira] [Created] (FLINK-38933) python udx supports get_index_of_this_subtask - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2026/01/16 06:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38933) python udx aligns with java udx - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2026/01/16 06:14:00 UTC, 1 replies.
- Re: [PR] [fix][runtime] Fix async compaction of long-term memory in python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/16 06:32:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-38924) Redirect users to documentation home page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/16 07:35:00 UTC, 0 replies.
- Re: [PR] [FLINK-38289] Update to Flink 2.1 [flink-connector-kafka] - posted by "mdemierre (via GitHub)" <gi...@apache.org> on 2026/01/16 07:37:34 UTC, 1 replies.
- [jira] [Updated] (FLINK-38777) HistoryServer supports application archives - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/16 08:35:00 UTC, 1 replies.
- [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/01/16 09:05:15 UTC, 15 replies.
- [I] [Feature][doc] Update documentation for async & durable execution [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/16 09:12:14 UTC, 1 replies.
- [I] [Feature] Improve event logging [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/16 11:28:54 UTC, 1 replies.
- [PR] [log] Add config to set the event log path [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/16 11:30:36 UTC, 0 replies.
- [jira] [Created] (FLINK-38934) Debezium config 'binlog.ssl.protocol' is ignored - posted by "John Watson (Jira)" <ji...@apache.org> on 2026/01/16 12:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38934) Debezium config 'binlog.ssl.protocol' is ignored - posted by "John Watson (Jira)" <ji...@apache.org> on 2026/01/16 12:16:00 UTC, 0 replies.
- [PR] [FLINK-38913][table-planner] ArrayIndexOutOfBoundsException unparsing CAST. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/16 13:21:57 UTC, 22 replies.
- Re: [PR] [log] Improve event logging [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/16 13:28:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-38887) YAML Transform module supports nested types - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/16 13:45:00 UTC, 2 replies.
- [PR] [plan][java] Built-in actions support async execution. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/16 14:04:07 UTC, 3 replies.
- Re: [PR] [FLINK-38592] [POC] Native Flink S3 FileSystem [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2026/01/16 14:04:37 UTC, 0 replies.
- [jira] [Updated] (FLINK-38934) Add binlog.ssl.protocol configuration for binlog client TLS - posted by "John Watson (Jira)" <ji...@apache.org> on 2026/01/16 14:45:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-38904) MySQL CDC binlog reader hangs due to TLS 1.3 KeyUpdate deadlock (potentially JDK-8241239) - posted by "John Watson (Jira)" <ji...@apache.org> on 2026/01/16 14:54:00 UTC, 0 replies.
- [PR] [FLINK-38934][cdc connector mysql] honour ssl protocol setting configured in debeziumProps [flink-cdc] - posted by "watsonjo737 (via GitHub)" <gi...@apache.org> on 2026/01/16 14:58:49 UTC, 0 replies.
- Re: [PR] [FLINK-36456] Add support to pass Datadog API Key as environment variable [flink] - posted by "barryib (via GitHub)" <gi...@apache.org> on 2026/01/16 15:34:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-38935) HTTP Connector Fix Bearer token casing in OIDC Change Authorization header from "BEARER" to "Bearer" to comply with RFC 6750. - posted by "David Radley (Jira)" <ji...@apache.org> on 2026/01/16 15:39:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38935) HTTP Connector Fixe Bearer token casing in OIDC Change Authorization header from "BEARER" to "Bearer" to comply with RFC 6750. - posted by "David Radley (Jira)" <ji...@apache.org> on 2026/01/16 15:39:00 UTC, 0 replies.
- [PR] feat: Add support to pass Datadog API Key as environment variable [flink] - posted by "barryib (via GitHub)" <gi...@apache.org> on 2026/01/16 15:51:27 UTC, 0 replies.
- Re: [PR] [FLINK-36456] feat: Add support to pass Datadog API Key as environment variable [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/16 15:58:07 UTC, 10 replies.
- [PR] [FLINK-38935] Change case of Bearer keyword [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/16 17:13:58 UTC, 3 replies.
- [PR] [hotfix] Add sleep to stop intermittent failure in ExecutionTimeBasedSlowTaskDetectorTest [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/16 17:36:25 UTC, 3 replies.
- Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2026/01/16 18:39:17 UTC, 1 replies.
- [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/16 21:18:31 UTC, 9 replies.
- Re: [PR] [FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation [flink] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/01/16 23:15:08 UTC, 0 replies.
- [PR] [FLINK-38867] FlinkBlueGreenDeployment used initialSavepointPath on restartSavepointNonce [flink-kubernetes-operator] - posted by "drossos (via GitHub)" <gi...@apache.org> on 2026/01/16 23:48:07 UTC, 1 replies.
- [jira] [Created] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 - posted by "liuerbao (Jira)" <ji...@apache.org> on 2026/01/17 06:47:00 UTC, 0 replies.
- [PR] support mcp without list_prompts interface [flink-agents] - posted by "qingfei1994 (via GitHub)" <gi...@apache.org> on 2026/01/17 08:05:23 UTC, 4 replies.
- [jira] [Updated] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 - posted by "liuerbao (Jira)" <ji...@apache.org> on 2026/01/17 08:42:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 - posted by "liuerbao (Jira)" <ji...@apache.org> on 2026/01/17 09:04:00 UTC, 0 replies.
- [I] [Tech Debt] Cross language resource can't support async execution. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/17 11:11:36 UTC, 0 replies.
- [jira] [Created] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/01/17 11:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-32416) Initial DynamicKafkaSource Implementation - posted by "wangkang (Jira)" <ji...@apache.org> on 2026/01/17 12:17:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-32416) Initial DynamicKafkaSource Implementation - posted by "wangkang (Jira)" <ji...@apache.org> on 2026/01/17 12:19:00 UTC, 0 replies.
- Re: [I] [Feature] Support async execution for built-in actions [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/17 13:06:17 UTC, 0 replies.
- Re: [I] [Feature][runtime][java] Support async execution for actions in java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/17 13:11:20 UTC, 0 replies.
- Re: [I] [Feature][runtime] Support async execution for actions [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/17 13:11:34 UTC, 0 replies.
- [PR] docs: add guidelines for choosing Java vs Python API [flink-agents] - posted by "anshuman9468 (via GitHub)" <gi...@apache.org> on 2026/01/17 13:20:10 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2026/01/17 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/17 17:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/17 17:13:00 UTC, 2 replies.
- [PR] [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/17 17:19:56 UTC, 12 replies.
- [jira] [Commented] (FLINK-37002) Migrate DecomposeGroupingSetsRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/17 22:26:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37002) Migrate DecomposeGroupingSetsRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/17 22:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37002) Migrate DecomposeGroupingSetsRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/17 22:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] - posted by "suhwan-cheon (via GitHub)" <gi...@apache.org> on 2026/01/18 09:14:15 UTC, 1 replies.
- Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/01/18 16:17:46 UTC, 15 replies.
- [PR] [FLINK-38937] Introduce TestKafkaContainer wrapper to support Confluent and Apache Kafka images with KRaft [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/01/18 17:52:31 UTC, 6 replies.
- [jira] [Updated] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/18 17:53:00 UTC, 1 replies.
- Re: [PR] [FLINK-37908] Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts [flink-connector-aws] - posted by "digitalpoetry (via GitHub)" <gi...@apache.org> on 2026/01/18 22:08:07 UTC, 0 replies.
- [jira] [Created] (FLINK-38939) Pause sources until the 1st checkpoint to prioritize processing recovered records - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/19 00:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/19 00:39:00 UTC, 0 replies.
- Re: [PR] Add documentation for adding Maven dependencies [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/19 02:23:34 UTC, 3 replies.
- [I] [Feature] [doc] Create a separate section document for MCP. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/19 02:31:30 UTC, 0 replies.
- [PR] Update datagen.md [flink] - posted by "JavaLeb (via GitHub)" <gi...@apache.org> on 2026/01/19 02:38:16 UTC, 3 replies.
- [PR] [doc] Update documentation for async & durable execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/19 04:03:10 UTC, 4 replies.
- [PR] [Feature][runtime] Support the use of Python MCP in Java [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/19 06:47:50 UTC, 6 replies.
- [PR] [doc] Create a dedicated section for introducing MCP. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/19 06:50:57 UTC, 2 replies.
- [jira] [Updated] (FLINK-31655) Umbrella: FLIP-339: Support Adaptive Partition Selection for StreamPartitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/19 06:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38882) Introduce rules for async python scalar function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/19 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38941) Add Python building blocks for Async Python Scalar Function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/19 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38942) Add documentation for async python scalar function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/19 07:01:00 UTC, 0 replies.
- [PR] [FLINK-38941][python] Add Python building blocks for async Python scalar function [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2026/01/19 07:03:40 UTC, 1 replies.
- [jira] [Updated] (FLINK-38941) Add Python building blocks for Async Python Scalar Function - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/19 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/19 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38944) Introduce a benchmark on adaptive partition selection for rescale partitioner and rebalance partitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/19 08:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38944) Introduce a benchmark on adaptive partition selection for RescalePartitioner and RebalancePartitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/19 08:30:00 UTC, 1 replies.
- [I] [Feature] Use resource descriptor to declare a MCP server in Agent. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/19 08:36:38 UTC, 1 replies.
- [PR] [api][plan] Use resource descriptor to declare a MCP server in Agent. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/19 08:37:45 UTC, 1 replies.
- Re: [I] [Feature][doc] Add document for built-in openai chat model support in java [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/19 08:45:15 UTC, 1 replies.
- [jira] [Updated] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2026/01/19 09:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2026/01/19 09:21:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38621) AsyncKeyedProcessOperator fails to restore with a java.io.FileNotFoundException: No such file or directory exception in ForSt - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2026/01/19 09:25:00 UTC, 0 replies.
- [jira] [Commented] (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 2026/01/19 09:29:00 UTC, 0 replies.
- [PR] [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/01/19 09:32:19 UTC, 9 replies.
- [jira] [Updated] (FLINK-38939) Pause sources until the 1st checkpoint to prioritize processing recovered records - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/19 09:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/01/19 10:02:02 UTC, 0 replies.
- Re: [PR] [hotfix] Add 3 sleeps to address intermittent unit test failures we have hit in ExecutionGraph tests [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/19 10:31:38 UTC, 2 replies.
- [PR] [FLINK-38940] Start checkpointing when all tasks are running and job is running [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/01/19 10:43:05 UTC, 14 replies.
- [jira] [Updated] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/19 10:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] - posted by "AndyShoeshim (via GitHub)" <gi...@apache.org> on 2026/01/19 10:47:16 UTC, 0 replies.
- [jira] [Created] (FLINK-38945) [FLIP-561] Restructure Flink documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/19 11:03:00 UTC, 0 replies.
- [PR] [FLINK-38778][ui] Web UI for applications [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/01/19 11:35:53 UTC, 2 replies.
- [jira] [Updated] (FLINK-38778) Web UI for applications - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/19 11:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/19 11:41:00 UTC, 0 replies.
- [PR] [BP-2.1][FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/19 11:44:24 UTC, 2 replies.
- [jira] [Created] (FLINK-38946) Update Datadog API endpoint from app.datadoghq to api.datadoghq - posted by "Ivan Stoiev (Jira)" <ji...@apache.org> on 2026/01/19 12:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38946) Update Datadog API endpoint from app.datadoghq to api.datadoghq - posted by "Ivan Stoiev (Jira)" <ji...@apache.org> on 2026/01/19 12:06:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38947) Notify Task thread via mailbox only once about kafka send error - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/19 13:17:00 UTC, 0 replies.
- [PR] [FLINK-38947] Handle errors in onCompletion callback only once [flink-connector-kafka] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2026/01/19 13:39:47 UTC, 9 replies.
- [jira] [Updated] (FLINK-38947) Notify Task thread via mailbox only once about kafka send error - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/19 13:40:00 UTC, 0 replies.
- [PR] tech-debt/#96-improve-observability-of-ci [flink-agents] - posted by "XL-Zhao-23 (via GitHub)" <gi...@apache.org> on 2026/01/19 15:05:15 UTC, 1 replies.
- [PR] [DP-17966] Improving performance for azure unpack artifacts [flink] - posted by "tomho-confluent (via GitHub)" <gi...@apache.org> on 2026/01/19 15:26:40 UTC, 1 replies.
- [jira] [Created] (FLINK-38948) Document SINGLE_VALUE aggregate function - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/01/19 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38949) unpack_build_artifact.sh script speed improvement - posted by "Tom Ho (Jira)" <ji...@apache.org> on 2026/01/19 16:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38949) unpack_build_artifact.sh script logic and speed improvement - posted by "Tom Ho (Jira)" <ji...@apache.org> on 2026/01/19 16:23:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/19 17:12:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/19 17:12:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38949) unpack_build_artifact.sh script logic and speed improvement - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/19 19:49:00 UTC, 0 replies.
- [PR] [FLINK-38787] Introduce FlinkBlueGreenDeployment Metrics [flink-kubernetes-operator] - posted by "james-kan-shopify (via GitHub)" <gi...@apache.org> on 2026/01/19 20:52:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38787) Add Metrics for FlinkBlueGreenDeployment resources - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/19 20:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses - posted by "Sebastien Pereira (Jira)" <ji...@apache.org> on 2026/01/19 21:06:00 UTC, 0 replies.
- [PR] [FLINK-38915] FlinkBlueGreenDeplomynet in place suspension handler [flink-kubernetes-operator] - posted by "james-kan-shopify (via GitHub)" <gi...@apache.org> on 2026/01/19 21:10:46 UTC, 5 replies.
- [jira] [Updated] (FLINK-38915) Suspending Pipeline Breaks FlinkBlueGreenDeployment - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/19 21:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses - posted by "Sebastien Pereira (Jira)" <ji...@apache.org> on 2026/01/19 21:13:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-30284) Make datadog reporter url configurable - posted by "Ivan Stoiev (Jira)" <ji...@apache.org> on 2026/01/19 21:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38946) Allow AWS VPC Endpoint/GCP Cloud Private Service Connect for Datadog integration - posted by "Ivan Stoiev (Jira)" <ji...@apache.org> on 2026/01/19 21:28:00 UTC, 2 replies.
- [PR] [FLINK-38950][table-planner] Fix SqlNodeConvertUtils to use validated query output [flink] - posted by "seb-pereira (via GitHub)" <gi...@apache.org> on 2026/01/19 21:33:01 UTC, 26 replies.
- [jira] [Updated] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/19 21:34:00 UTC, 3 replies.
- Re: [PR] [FLINK-38110] fix PostgreSQL connector reads Chinese columns with garbled charactor [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/20 00:05:26 UTC, 0 replies.
- [PR] [FLINK-38943][runtime] Support Adaptive Partition Selection for RescalePartitioner and RebalancePartitioner [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/20 00:15:39 UTC, 44 replies.
- [jira] [Updated] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/20 00:16:00 UTC, 0 replies.
- [PR] [FLINK-38944][benchmark] Introduce a benchmark on adaptive partition selection for RescalePartitioner and RebalancePartitioner [flink-benchmarks] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/20 00:20:05 UTC, 0 replies.
- Re: [I] [Feature] [doc] Create a dedicated section for introducing MCP. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/20 01:31:28 UTC, 0 replies.
- [jira] [Updated] (FLINK-38951) Upgrade pemja to 0.5.6 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2026/01/20 01:35:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38951) Upgrade pemja to 0.5.6 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2026/01/20 01:35:00 UTC, 0 replies.
- [PR] [hotfix][docs][Update datagen.md]Change the type of the "fields.#.null-rate" option in the DataGen SQL Connector to Float [flink] - posted by "JavaLeb (via GitHub)" <gi...@apache.org> on 2026/01/20 01:36:11 UTC, 9 replies.
- [jira] [Resolved] (FLINK-38878) Add PARSE_JSON/TRY_PARSE_JSON function to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/20 01:38:00 UTC, 0 replies.
- [PR] [FLINK-38879][pipeline-connector][paimon] Add support for creating and writing table with variant type. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/20 01:40:22 UTC, 4 replies.
- [jira] [Updated] (FLINK-38879) Add VARIANT type support in Paimon pipeline sink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/20 01:41:00 UTC, 0 replies.
- [PR] [FLINK-38951][python] Bump pemja to 0.5.6 [flink] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/20 02:57:20 UTC, 8 replies.
- [jira] [Assigned] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/20 03:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38342) Support record rescale information - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/20 03:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/20 03:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38343) Support store rescale history with statistics by ExecutionGraphInfoStore. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/20 03:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38341) Introduce the rescale history configuration option. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/20 03:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38944) Introduce a benchmark on adaptive partition selection for RescalePartitioner and RebalancePartitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/20 03:26:00 UTC, 0 replies.
- [PR] [hotfix] Fix the incorrect reference in the MCP document [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/20 03:45:33 UTC, 1 replies.
- [I] [Feature] Dynamic load MCP tools and prompt in runtime. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/20 07:23:44 UTC, 0 replies.
- [PR] [doc] Introduce cross-language resources [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/20 07:42:30 UTC, 8 replies.
- [I] [Feature] Update dependencies and NOTICE for flink-agents-dist. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/20 07:43:57 UTC, 1 replies.
- [PR] [package] Update dependencies and NOTICE for flink-agents-dist. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/20 07:45:07 UTC, 1 replies.
- Re: [I] [Feature] Support the use of Python resources in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/20 08:21:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-38947) Notify Task thread via mailbox only once about kafka send error - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/20 08:25:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38947) Notify Task thread via mailbox only once about kafka send error - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/20 08:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-38949] Improving performance for azure unpack artifacts [flink] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2026/01/20 08:54:32 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38949) unpack_build_artifact.sh script logic and speed improvement - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2026/01/20 08:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38935) HTTP Connector Fix Bearer token casing in OIDC Change Authorization header from "BEARER" to "Bearer" to comply with RFC 6750. - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/20 09:17:00 UTC, 0 replies.
- [PR] [FLINK-38946][flink-metrics] Allow AWS VPC Endpoint/GCP Cloud Private Service Connect for Datadog integration [flink] - posted by "stoiev (via GitHub)" <gi...@apache.org> on 2026/01/20 09:29:23 UTC, 0 replies.
- [jira] [Updated] (FLINK-38946) Allow AWS PrivateLink/GCP Cloud Private Service Connect for Datadog integration - posted by "Ivan Stoiev (Jira)" <ji...@apache.org> on 2026/01/20 09:31:00 UTC, 1 replies.
- Re: [PR] [FLINK-38946][flink-metrics] Allow AWS PrivateLink/GCP Cloud Private Service Connect for Datadog integration [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/20 09:33:38 UTC, 2 replies.
- [PR] (hotfix) stabilize integration tests [flink-connector-jdbc] - posted by "eskabetxe (via GitHub)" <gi...@apache.org> on 2026/01/20 09:41:07 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38865) Docs: Fix typos and clarify capacity scope in Async I/O documentation - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/20 10:47:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38865) Docs: Fix typos and clarify capacity scope in Async I/O documentation - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/20 10:48:00 UTC, 0 replies.
- [PR] [ci] Disable model think to improve test stability. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/20 13:25:44 UTC, 2 replies.
- [PR] [FLINK-38925][docs] Update Matomo URL to the right domain [flink-cdc] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/20 15:43:25 UTC, 1 replies.
- [PR] [BP 3.5][FLINK-38925][docs] Update Matomo URL to the right domain [flink-cdc] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/20 15:48:03 UTC, 1 replies.
- [PR] [BP 3.4][FLINK-38925][docs] Update Matomo URL to the right domain [flink-cdc] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/20 15:48:54 UTC, 1 replies.
- [PR] [FLINK-38925][docs] Update Matomo URL to the right domain [flink-kubernetes-operator] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/20 16:04:33 UTC, 1 replies.
- [PR] [BP 1.13][FLINK-38925][docs] Update Matomo URL to the right domain [flink-kubernetes-operator] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/20 16:06:25 UTC, 1 replies.
- [PR] [BP 1.12][FLINK-38925][docs] Update Matomo URL to the right domain [flink-kubernetes-operator] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/20 16:06:57 UTC, 1 replies.
- [jira] [Created] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/20 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38953) Cleanup configurations for SSL hostname verification - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/20 17:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38920) create Table source and factory for DynamicKafkaSource in Flink Table API - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/20 21:00:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38920) create Table source and factory for DynamicKafkaSource in Flink Table API - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/20 21:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38951) Upgrade pemja to 0.5.6 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2026/01/21 02:00:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38951) Upgrade pemja to 0.5.6 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2026/01/21 02:01:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38951) Upgrade pemja to 0.5.6 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2026/01/21 02:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38879) Add VARIANT type support in Paimon pipeline sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/21 02:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/21 02:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-37698] Rename fromSchedulerNg to fromWithinExecutionGraph [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/21 06:26:40 UTC, 0 replies.
- Re: [PR] [hotfix] Rename SessionDispatcherFactory to DefaultDispatcherFactory [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/21 06:26:44 UTC, 0 replies.
- Re: [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/21 06:26:48 UTC, 1 replies.
- [jira] [Closed] (FLINK-38778) Web UI for applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/21 07:44:00 UTC, 0 replies.
- [PR] [FLINK-38924][docs] Actually redirect users to 404 page when trying to access non-existent page [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/21 07:47:05 UTC, 1 replies.
- [jira] [Created] (FLINK-38954) Flink Benchmark Score Decreases After Upgrading JDK Versions of Flink Engine and User Program - posted by "zhangxing (Jira)" <ji...@apache.org> on 2026/01/21 07:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38954) Flink Benchmark Score Decreases After Upgrading JDK Versions of Flink Engine and User Program - posted by "zhangxing (Jira)" <ji...@apache.org> on 2026/01/21 07:58:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38955) Add canonical tag to generated Javadoc and PyDocs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/21 08:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38954) Flink Benchmark Performance regression After Upgrading JDK Versions of Flink Engine and User Program - posted by "zhangxing (Jira)" <ji...@apache.org> on 2026/01/21 08:47:00 UTC, 1 replies.
- Re: [PR] [FLINK-38924][docs] Redirects for 404, correct canonical tags and tracking for JavaDoc and PyDoc [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/21 10:25:52 UTC, 0 replies.
- [jira] [Closed] (FLINK-38645) Web UI may display incorrect SHIP policy names when the Adaptive Scheduler is enabled for a job - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/21 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38956) The Web UI cannot automatically show the latest edge name for AdaptiveScheduler - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/21 13:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38956) The Web UI cannot automatically show the latest edge name for AdaptiveScheduler - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/21 13:24:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38957) ProcessTableFunction UDFs cannot be loaded via CompiledPlan - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/21 17:17:00 UTC, 0 replies.
- [PR] [FLINK-38957][table-planner] Support `ProcessTableFunction` registration via `CompiledPlan` [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/21 17:21:03 UTC, 3 replies.
- [jira] [Updated] (FLINK-38957) ProcessTableFunction UDFs cannot be loaded via CompiledPlan - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/21 17:22:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38958) Support provided lib archives for YARN application mode - posted by "Archit Goyal (Jira)" <ji...@apache.org> on 2026/01/21 22:52:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38958) Support provided lib archives for YARN application mode - posted by "Archit Goyal (Jira)" <ji...@apache.org> on 2026/01/21 22:52:00 UTC, 0 replies.
- [PR] Bump lodash from 4.17.21 to 4.17.23 in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/21 23:10:49 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/21 23:42:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with computed rows including casts to null - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/21 23:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/21 23:58:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/21 23:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38959) Added support for schema change in the postgres pipeline connector - posted by "林健昌 (Jira)" <ji...@apache.org> on 2026/01/22 01:15:00 UTC, 0 replies.
- [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] - posted by "linjianchang (via GitHub)" <gi...@apache.org> on 2026/01/22 01:21:14 UTC, 6 replies.
- [jira] [Updated] (FLINK-38959) Added support for schema change in the postgres pipeline connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/22 01:22:00 UTC, 0 replies.
- [PR] [hotfix][docs] Add 2026 on NOTICE [flink-kubernetes-operator] - posted by "yangjf2019 (via GitHub)" <gi...@apache.org> on 2026/01/22 02:01:28 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37924) Support variant field accessing - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2026/01/22 02:45:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled config - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/22 02:48:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37447) [Flink CDC] Supports Variant type in YAML API - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/22 02:58:00 UTC, 0 replies.
- Re: [PR] [hotfix] Stabilize integration tests [flink-connector-jdbc] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2026/01/22 06:05:03 UTC, 10 replies.
- [jira] [Reopened] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2026/01/22 06:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2026/01/22 06:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2026/01/22 06:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility - posted by "Han Yin (Jira)" <ji...@apache.org> on 2026/01/22 06:25:00 UTC, 4 replies.
- [jira] [Created] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility - posted by "Han Yin (Jira)" <ji...@apache.org> on 2026/01/22 06:25:00 UTC, 0 replies.
- [PR] [FLINK-38960][doc] Clarify scope of state compatibility in "Upgrading… [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2026/01/22 06:34:20 UTC, 4 replies.
- [PR] [FLINK-38950][table] `SqlNodeConvertUtils` should use validated query output [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/22 06:43:59 UTC, 2 replies.
- [PR] [doc] Add OpenAI chat model docs [flink-agents] - posted by "xli1996 (via GitHub)" <gi...@apache.org> on 2026/01/22 06:50:06 UTC, 1 replies.
- [I] [Tech Debt] Align default value for python and java openai chatmodel [flink-agents] - posted by "xli1996 (via GitHub)" <gi...@apache.org> on 2026/01/22 06:52:26 UTC, 0 replies.
- [PR] [FLINK-38953] Cleanup configurations for SSL hostname verification [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/01/22 08:07:15 UTC, 5 replies.
- [jira] [Updated] (FLINK-38953) Cleanup configurations for SSL hostname verification - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/22 08:08:00 UTC, 0 replies.
- [PR] [FLINK-38952] Fix PyFlink AWS code to the current java package [flink-connector-aws] - posted by "gguptp (via GitHub)" <gi...@apache.org> on 2026/01/22 08:14:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/22 08:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/22 08:41:00 UTC, 0 replies.
- [PR] [FLINK-38812][API/Python] Add log to show whether PYFLINK_CYTHON_ENABLED is set [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/01/22 08:55:10 UTC, 6 replies.
- [jira] [Updated] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/22 08:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38699) Order the WebUI's Completed Job List by end time order - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/22 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/22 09:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/22 09:29:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/22 09:37:00 UTC, 0 replies.
- [PR] [hotfix] Handle durable execute exception properly [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/22 10:07:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBALANCE for autoscaler and adaptive scheduler - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/22 10:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-33123][runtime] Fix the wrong dynamic replacement of partitioner from FORWARD to REBALANCE for autoscaler and adaptive scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/22 10:43:40 UTC, 14 replies.
- [PR] [doc] Add documents for memory of flink-agents. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/22 10:51:45 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/22 10:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/22 10:54:00 UTC, 0 replies.
- [PR] [doc] Add documents for adding dependencies to flink-agents project. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/22 10:56:40 UTC, 4 replies.
- [PR] Add error handling feature skip failed events [flink-connector-elasticsearch] - posted by "SAitharaju (via GitHub)" <gi...@apache.org> on 2026/01/22 11:32:05 UTC, 4 replies.
- [jira] [Assigned] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/22 12:45:00 UTC, 0 replies.
- Re: [PR] [FLINK-38952] Fix PyFlink AWS code to point to the current java package [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/22 13:27:34 UTC, 0 replies.
- [jira] [Closed] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/22 13:31:00 UTC, 0 replies.
- [PR] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch] - posted by "uliandim (via GitHub)" <gi...@apache.org> on 2026/01/22 13:56:14 UTC, 2 replies.
- [jira] [Created] (FLINK-38962) Add OpenSearch 3.x connector support - posted by "Julian Dimitrov (Jira)" <ji...@apache.org> on 2026/01/22 16:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38728) fullWindowPartition().reduce() is not being chained - posted by "Zhe Wang (Jira)" <ji...@apache.org> on 2026/01/22 16:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38728) fullWindowPartition().reduce() is not being chained - posted by "Zhe Wang (Jira)" <ji...@apache.org> on 2026/01/22 17:03:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/22 17:21:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/22 20:09:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36296) Add incremental shard discovery for DDB Streams source - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/22 20:10:00 UTC, 0 replies.
- [PR] Add AWS Connectors 6.0.0 [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/22 20:22:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-38783) Caused by: java.util.ConcurrentModificationException - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/01/22 20:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38048) flink-connector-parent java version should be set to 11 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/22 20:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-37776][python] Drop python 3.8 support [flink] - posted by "yuhrichard (via GitHub)" <gi...@apache.org> on 2026/01/22 20:59:30 UTC, 0 replies.
- [PR] Flink 38783 [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2026/01/22 21:01:35 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38783) Caused by: java.util.ConcurrentModificationException - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/01/22 21:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38963) Altering query should be possible if MATERIALIZED TABLE schema contains non persisted columns - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/22 21:05:00 UTC, 0 replies.
- Re: [PR] [FLINK-38783][runtime] Improved TieredStorageResourceRegistry Thread-Safety/Concurrency [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2026/01/22 21:07:23 UTC, 4 replies.
- [jira] [Updated] (FLINK-38783) Caused by: java.util.ConcurrentModificationException - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/22 21:08:00 UTC, 0 replies.
- [PR] [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/22 21:11:03 UTC, 6 replies.
- [jira] [Updated] (FLINK-38963) Altering query should be possible if MATERIALIZED TABLE schema contains non persisted columns - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/22 21:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38799) Rename "LoadingWeight" to "TaskExecutionLoad" - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/22 21:21:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38964) Reuse Calcite's SlqValidatorImpl#maybeCast - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/22 22:20:00 UTC, 0 replies.
- [PR] [FLINK-38964][table] Reuse Calcite's `SlqValidatorImpl#maybeCast` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/22 22:24:08 UTC, 1 replies.
- [jira] [Updated] (FLINK-38964) Reuse Calcite's SlqValidatorImpl#maybeCast - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/22 22:25:00 UTC, 0 replies.
- Re: [PR] [FLINK-38964][table] Reuse Calcite's `SqlValidatorImpl#maybeCast` [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/22 22:33:01 UTC, 2 replies.
- Re: [PR] [FLINK-38962][connectors/opensearch] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch] - posted by "mishail (via GitHub)" <gi...@apache.org> on 2026/01/23 01:02:54 UTC, 1 replies.
- [jira] [Updated] (FLINK-38962) Add OpenSearch 3.x connector support - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/23 01:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-25509][connector/kafka] Add RecordEvaluator to dynamically stop source based on de-serialized records [flink-connector-kafka] - posted by "Zor-X-L (via GitHub)" <gi...@apache.org> on 2026/01/23 01:19:01 UTC, 0 replies.
- [PR] FLINK-38872: waitForAllTaskRunning Hang Indefinitely [flink] - posted by "teamconfx (via GitHub)" <gi...@apache.org> on 2026/01/23 01:48:08 UTC, 5 replies.
- [jira] [Commented] (FLINK-38872) waitForAllTaskRunning Hang Indefinitely - posted by "rstest (Jira)" <ji...@apache.org> on 2026/01/23 01:49:00 UTC, 0 replies.
- [PR] [FLINK-38870] Uninformative error message when job is suspended due to JobManager leadership loss [flink] - posted by "teamconfx (via GitHub)" <gi...@apache.org> on 2026/01/23 02:03:42 UTC, 6 replies.
- [jira] [Assigned] (FLINK-38699) Order the WebUI's Completed Job List by end time order - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/23 02:25:00 UTC, 0 replies.
- [PR] [FLINK-38699][ui] Sort jobs by default [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/01/23 02:41:10 UTC, 6 replies.
- [jira] [Updated] (FLINK-38699) Order the WebUI's Completed Job List by end time order - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/23 02:42:00 UTC, 0 replies.
- Re: [PR] [FLINK-38799][runtime] Rename `LoadingWeight` to `TaskExecutionLoad` [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/23 05:49:20 UTC, 1 replies.
- Re: [PR] [FLINK-36753] Adaptive Scheduler actively triggers a Checkpoint [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/23 06:26:35 UTC, 0 replies.
- Re: [PR] [FLINK-38525][python] Fix coder doesn't process TIMESTAMP_LTZ correctly [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/23 06:26:37 UTC, 0 replies.
- Re: [I] [Feature][doc] Add document on how to use cross-language resources [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/23 06:28:56 UTC, 0 replies.
- Re: [I] [Feature] Support Cross-Language Resource [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/23 06:29:07 UTC, 0 replies.
- [PR] [doc] Add java Anthropic chat model docs [flink-agents] - posted by "xli1996 (via GitHub)" <gi...@apache.org> on 2026/01/23 06:51:43 UTC, 2 replies.
- [jira] [Closed] (FLINK-38777) HistoryServer supports application archives - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/23 07:04:00 UTC, 0 replies.
- [I] [Feature] Introduce Hierarchical `ResourceClassName` for Cross-Language Resource Creation [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/23 07:13:22 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38886) Provide GenericRecordData in Pipeline public API - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/23 07:58:00 UTC, 0 replies.
- [PR] [doc] Update document for vector store. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/23 08:11:59 UTC, 3 replies.
- [PR] [doc] Add built-in resource providers overview page [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/23 08:32:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/23 08:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/23 08:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc] - posted by "Copilot (via GitHub)" <gi...@apache.org> on 2026/01/23 09:30:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-38799) Rename "LoadingWeight" to "TaskExecutionLoad" - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/23 09:43:00 UTC, 0 replies.
- [PR] [api] Introduce Hierarchical ResourceName for Cross-Language Resource Creation [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/23 09:46:12 UTC, 0 replies.
- Re: [PR] [api] Introduce Hierarchical ResourceName for Resource Creation [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/23 09:54:53 UTC, 6 replies.
- [jira] [Updated] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" - posted by "Tao Wang (Jira)" <ji...@apache.org> on 2026/01/23 10:18:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" - posted by "Tao Wang (Jira)" <ji...@apache.org> on 2026/01/23 10:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" - posted by "Tao Wang (Jira)" <ji...@apache.org> on 2026/01/23 10:24:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38966) Update rsync Github Actions to 8.0.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/23 10:45:00 UTC, 0 replies.
- [PR] [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2026/01/23 10:53:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-38966) Update rsync Github Actions to 8.0.2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/23 10:54:00 UTC, 0 replies.
- Re: [PR] [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) for legacy doc build [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/23 11:01:33 UTC, 1 replies.
- [jira] [Created] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/23 11:37:00 UTC, 0 replies.
- [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/01/23 11:42:58 UTC, 6 replies.
- [jira] [Updated] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/23 11:43:00 UTC, 0 replies.
- [PR] [minor][improvement] Fix a little logging mistake when scan.startup.mode is malformed [flink-cdc] - posted by "CatOrLeader (via GitHub)" <gi...@apache.org> on 2026/01/23 14:01:05 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2026/01/23 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38968) Add toCatalogTable method to CatalogMaterializedTable interface - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/01/23 14:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38963) Altering query should be possible if MATERIALIZED TABLE schema contains non persisted columns - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/23 14:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38963) Altering query should be possible if MATERIALIZED TABLE schema contains non persisted columns - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/23 14:30:00 UTC, 0 replies.
- [PR] [FLINK-38968][table] Add toCatalogTable method to CatalogMaterializedTable interface [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2026/01/23 14:45:11 UTC, 3 replies.
- [jira] [Updated] (FLINK-38968) Add toCatalogTable method to CatalogMaterializedTable interface - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/23 14:46:00 UTC, 1 replies.
- [I] [Bug] Serialize DurableExecutionException object exception [flink-agents] - posted by "choucmei (via GitHub)" <gi...@apache.org> on 2026/01/23 15:34:11 UTC, 2 replies.
- [PR] [fix] Fixed the DurableExecutionException error that could not be serialized [flink-agents] - posted by "choucmei (via GitHub)" <gi...@apache.org> on 2026/01/23 15:55:40 UTC, 6 replies.
- [jira] [Updated] (FLINK-38968) Allow toCatalogTable method to CatalogMaterializedTable interface - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/01/23 16:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38968) Allow ResolvedCatalogMaterializedTable.toResolvedCatalogTable() to delegate to CatalogMaterializedTable interface - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/01/23 16:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38968) Allow ResolvedCatalogMaterializedTable.toResolvedCatalogTable() to delegate to origin.toCatalogTable() - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/01/23 16:59:00 UTC, 0 replies.
- [PR] Override Fysnc Calls for HDFS [flink] - posted by "Santhosh0085 (via GitHub)" <gi...@apache.org> on 2026/01/23 18:28:56 UTC, 2 replies.
- [jira] [Created] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/01/23 18:57:00 UTC, 0 replies.
- Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] - posted by "nickdelnano (via GitHub)" <gi...@apache.org> on 2026/01/23 21:54:36 UTC, 6 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 2026/01/24 00:05:32 UTC, 0 replies.
- Re: [I] [Feature] [doc] Add document for built-in anthropic chat model support in java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/24 03:42:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-38885) Migrate StreamPhysicalJoinRuleBase and its children - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/24 08:50:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38885) Migrate StreamPhysicalJoinRuleBase and its children - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/24 08:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36986) Migrate SplitRemoteConditionFromJoinRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/24 09:00:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36986) Migrate SplitRemoteConditionFromJoinRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/24 09:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36986) Migrate SplitRemoteConditionFromJoinRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/24 09:01:00 UTC, 0 replies.
- Re: [I] [Feature] Add document for how to add dependency in pom for flink-agents project. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/25 01:01:24 UTC, 0 replies.
- Re: [PR] [FLINK-38392] Fix failing test in StreamPandasConversionTests [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/25 06:26:06 UTC, 1 replies.
- Re: [PR] [FLINK-38432][python] Fix missing finish/reset for keyWriter/valueWriter in ArrowMapWriter [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/25 06:26:08 UTC, 1 replies.
- Re: [PR] [FLINK-38438][Runtime] Support session mini cluster when use local ex… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/25 06:26:11 UTC, 1 replies.
- [PR] [FLINK-38912] Upgrade Netty to 4.2.6.Final [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/01/25 07:23:30 UTC, 9 replies.
- [jira] [Updated] (FLINK-38523) Upgrade Pekko to 1.4.0 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/25 07:24:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38912) Upgrade Flink to use Netty 4.2.6.Final - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/25 07:24:00 UTC, 0 replies.
- [PR] [FLINK-38523] Upgrade Pekko to 1.4.0 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2026/01/25 07:34:26 UTC, 3 replies.
- [PR] [python][hotfix] Fix constant name in RAG example [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2026/01/25 08:53:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/25 10:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/25 10:51:00 UTC, 0 replies.
- Re: [PR] [hotfix] Make it compilable with Flink 2.0-preview [flink-connector-hive] - posted by "zhelyan (via GitHub)" <gi...@apache.org> on 2026/01/25 11:52:12 UTC, 0 replies.
- Re: [PR] [FLINK-38468][flink-table-planner] When the coalesce parameter contains a function, convert it to case when [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/25 19:07:25 UTC, 15 replies.
- [PR] [hotfix][tests] Catch `AssertionError` in `DiffRepository` instead of `AssertionFailedError` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/25 21:15:22 UTC, 4 replies.
- [PR] [FLINK-38890][table] Migrate PullUpWindowTableFunctionIntoWindowAggre… [flink] - posted by "RVRhub (via GitHub)" <gi...@apache.org> on 2026/01/25 21:54:06 UTC, 3 replies.
- [jira] [Created] (FLINK-38971) Migrate ExpandWindowTableFunctionTransposeRule - posted by "Roman Rybak (Jira)" <ji...@apache.org> on 2026/01/25 22:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38971) Migrate ExpandWindowTableFunctionTransposeRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/25 22:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38971) Migrate ExpandWindowTableFunctionTransposeRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/25 22:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38972) FLIP-560: Application Capability Enhancement - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38972) FLIP-560: Application Capability Enhancement - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:04:00 UTC, 0 replies.
- Re: [PR] [doc] Add documentation about how to choose between Java & Python APIs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/26 02:13:38 UTC, 1 replies.
- [jira] [Created] (FLINK-38973) Job ID assignment and matching based on name - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38974) Handle jobs during HA recovery - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38975) Re-execute applications after HA recovery in session mode - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38976) Support multiple jobs in an application - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38977) Expose exceptions for applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38978) Expose JM config for applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:32:00 UTC, 0 replies.
- [I] [Feature] Support auto resolve memory reference for passing data across actions. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/26 03:50:38 UTC, 0 replies.
- Re: [PR] Add sensory memory documentation [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/26 04:57:12 UTC, 0 replies.
- Re: [PR] Add long-term memory documentation [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/26 04:57:18 UTC, 0 replies.
- Re: [I] [doc] Add documents for sensory memory [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/26 04:57:39 UTC, 0 replies.
- Re: [I] [doc] Add documents for long-term memory [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/26 04:57:43 UTC, 0 replies.
- Re: [I] [Feature] Introduce Comprehensive Memory Management. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/26 04:57:56 UTC, 0 replies.
- Re: [I] [Feature] Dynamic load MCP tools and prompts in runtime. [flink-agents] - posted by "yanand0909 (via GitHub)" <gi...@apache.org> on 2026/01/26 05:11:25 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38972) FLIP-560: Application Capability Enhancement - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/26 06:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38973) Job ID assignment and matching based on name - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/26 06:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38975) Re-execute applications after HA recovery in session mode - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/26 06:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38978) Expose JM config for applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/26 06:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38974) Handle jobs during HA recovery - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/26 06:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38977) Expose exceptions for applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/26 06:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38976) Support multiple jobs in an application - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2026/01/26 06:02:00 UTC, 0 replies.
- [I] [Feature] [Integration][Python] Add built-in support for Azure OpenAI Chat Model [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2026/01/26 06:07:16 UTC, 1 replies.
- [PR] [Feature] [Integration][Python] Add built-in support for Azure OpenAI Chat Model [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2026/01/26 06:16:34 UTC, 13 replies.
- Re: [PR] [FLINK-37932] Add UserAgent in GCS requests [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 06:26:53 UTC, 0 replies.
- [PR] Upgrade GitHub Actions for Node 24 compatibility [flink-cdc] - posted by "sd4324530 (via GitHub)" <gi...@apache.org> on 2026/01/26 06:35:57 UTC, 0 replies.
- [PR] [hotfix] Remove unnecessary import statements from the mcp document [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/26 07:53:17 UTC, 1 replies.
- [PR] [doc] Refactor the doc for configuration. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/26 08:05:40 UTC, 3 replies.
- [PR] [doc] Update doc for deployment. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/26 08:25:58 UTC, 1 replies.
- Re: [PR] [ci] Upgrade GitHub Actions for Node 24 compatibility [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/26 08:41:01 UTC, 1 replies.
- Re: [D] Flink Agents Release Process [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/26 08:47:23 UTC, 5 replies.
- [PR] [doc] Update doc for tool-use [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/26 09:09:49 UTC, 1 replies.
- [PR] [infra] Add script to cut branch for major release [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/26 09:12:43 UTC, 2 replies.
- [PR] [doc] Add faq for running examples in IDE. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/26 09:44:32 UTC, 1 replies.
- Re: [PR] [refactor] chore: support ci mutli tests [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/26 09:45:57 UTC, 0 replies.
- Re: [PR] [FLINK-37607] Fix RpcEndpoint#MainThreadExecutor lost scheduling tasks when not running [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2026/01/26 11:12:02 UTC, 0 replies.
- Re: [PR] [FLINK-21108][rest-client] Add basic & digest auth support to rest client [flink] - posted by "scienceyang (via GitHub)" <gi...@apache.org> on 2026/01/26 11:14:30 UTC, 0 replies.
- [PR] [FLINK-38887] Transform supports handling nested types (ARRAY, MAP, ROW, VARIANT) [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/01/26 11:23:49 UTC, 3 replies.
- [jira] [Updated] (FLINK-38887) YAML Transform module supports nested types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/26 11:24:00 UTC, 0 replies.
- [jira] (FLINK-38906) Polish YAML transform built-in functions - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/26 11:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36605) Upgrade Debezium version to 2.7.x - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/01/26 12:01:00 UTC, 0 replies.
- Re: [PR] [FLINK-38340][runtime] Introduce the rescale timeline related abstraction for performing rescale operations [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/26 15:30:14 UTC, 22 replies.
- [PR] [ci]fix action labeler v6 [flink-cdc] - posted by "sd4324530 (via GitHub)" <gi...@apache.org> on 2026/01/26 16:34:31 UTC, 3 replies.
- [PR] [hotfix] Bump `flink-connector-parent` to 1.1.0 [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/26 16:49:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2026/01/26 17:19:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-31661) Add parity between `ROW` value function and it's type declaration - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2026/01/26 17:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38394) Upgrade Flink CDC to Flink 2 - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2026/01/26 17:22:00 UTC, 0 replies.
- [PR] [hotfix] Make Flink minor version parse OS-agnostic [flink-connector-shared-utils] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/26 18:37:25 UTC, 1 replies.
- [PR] [FLINK-25538] Migrate tests from JUnit 4 to JUnit 5 [flink-connector-kafka] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2026/01/26 19:14:34 UTC, 0 replies.
- [jira] [Created] (FLINK-38979) flink-tests-java17 skipped while java21 build - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 19:21:00 UTC, 0 replies.
- [PR] [FLINK-38979][build] Enable flink-tests-java17 for jdk21 build [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/26 19:25:25 UTC, 4 replies.
- [jira] [Updated] (FLINK-38979) flink-tests-java17 skipped while java21 build - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/26 19:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-25538) [JUnit5 Migration] Module: flink-connector-kafka - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2026/01/26 19:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-38606][Connectors/MongoDB] Support for Flink 2.1.0 API [flink-connector-mongodb] - posted by "neoneo008 (via GitHub)" <gi...@apache.org> on 2026/01/26 19:38:13 UTC, 4 replies.
- [PR] Bump org.assertj:assertj-core from 3.21.0 to 3.27.7 [flink-connector-aws] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:41:37 UTC, 0 replies.
- [PR] Bump org.assertj:assertj-core from 3.21.0 to 3.27.7 [flink-connector-mongodb] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:41:47 UTC, 0 replies.
- [PR] Bump org.assertj:assertj-core from 3.23.1 to 3.27.7 [flink-connector-rabbitmq] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:44:05 UTC, 0 replies.
- [PR] Bump org.assertj:assertj-core from 3.23.1 to 3.27.7 in /flink-connector-cassandra [flink-connector-cassandra] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:44:26 UTC, 0 replies.
- [PR] Bump org.assertj:assertj-core from 3.24.2 to 3.27.7 [flink-connector-jdbc] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:48:06 UTC, 0 replies.
- [PR] Bump org.assertj:assertj-core from 3.23.1 to 3.27.7 [flink-agents] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:49:53 UTC, 3 replies.
- [PR] Bump org.assertj:assertj-core from 3.23.1 to 3.27.7 [flink-connector-http] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:50:44 UTC, 0 replies.
- [PR] Bump org.assertj:assertj-core from 3.25.3 to 3.27.7 [flink-connector-gcp-pubsub] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:51:28 UTC, 0 replies.
- [PR] Bump org.assertj:assertj-core from 3.25.3 to 3.27.7 [flink-connector-opensearch] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:51:42 UTC, 0 replies.
- [PR] Bump org.assertj:assertj-core from 3.25.3 to 3.27.7 [flink-connector-kudu] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:51:57 UTC, 1 replies.
- [PR] Bump org.assertj:assertj-core from 3.27.3 to 3.27.7 [flink-connector-kafka] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/01/26 21:55:15 UTC, 0 replies.
- [jira] [Commented] (FLINK-37351) Ensure writer and committer are colocated - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/01/26 22:07:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38979) flink-tests-java17 skipped while java21 build - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 22:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38979) flink-tests-java17 skipped while java21 build - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 22:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38964) Reuse Calcite's SlqValidatorImpl#maybeCast - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 22:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38964) Reuse Calcite's SlqValidatorImpl#maybeCast - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 22:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38890) Migrate PullUpWindowTableFunctionIntoWindowAggregateRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 22:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38890) Migrate PullUpWindowTableFunctionIntoWindowAggregateRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 22:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36992) Migrate SplitAggregateRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 22:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36992) Migrate SplitAggregateRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 22:44:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36992) Migrate SplitAggregateRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 22:45:00 UTC, 0 replies.
- [PR] [hotfix] Fix the incorrect reference in documents [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/27 01:10:46 UTC, 1 replies.
- [jira] [Created] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2026/01/27 02:33:00 UTC, 0 replies.
- [PR] [FLINK-38980][table] Migrate RemoveRedundantLocalSortAggRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2026/01/27 02:46:58 UTC, 9 replies.
- [jira] [Updated] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/27 02:47:00 UTC, 0 replies.
- [PR] [FLINK-38973][runtime] Job ID assignment and matching based on name [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2026/01/27 03:07:31 UTC, 2 replies.
- [jira] [Updated] (FLINK-38973) Job ID assignment and matching based on name - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/27 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2026/01/27 03:16:00 UTC, 0 replies.
- [PR] [FLINK-38981][table] Migrate BatchPhysicalSortMergeJoinRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2026/01/27 03:17:17 UTC, 8 replies.
- [jira] [Updated] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/27 03:18:00 UTC, 0 replies.
- [PR] [hotfix] Use qwen3:1.7b in Python Integration Test to improve stability [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/27 03:26:06 UTC, 3 replies.
- [PR] [hotfix] Fix errors for docs in development [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/27 03:38:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-38629) Add document for FLIP-544: SinkUpsertMaterializer V2 - posted by "Zhe Wang (Jira)" <ji...@apache.org> on 2026/01/27 03:40:00 UTC, 0 replies.
- Re: [D] Flink Multi-Version Support [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/27 03:53:11 UTC, 0 replies.
- [jira] [Created] (FLINK-38982) [JUnit5 Migration] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/27 05:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/27 05:08:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/27 05:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38982) [JUnit5 Migration] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/27 05:09:00 UTC, 0 replies.
- [PR] [JUnit5 Migration] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/27 05:10:05 UTC, 0 replies.
- [PR] [FLINK-38983][test] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2026/01/27 05:12:27 UTC, 6 replies.
- [jira] [Updated] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/27 05:13:00 UTC, 3 replies.
- Re: [PR] [FLINK-38982][test] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2026/01/27 05:17:41 UTC, 4 replies.
- [jira] [Updated] (FLINK-38982) [JUnit5 Migration] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/27 05:18:00 UTC, 0 replies.
- Re: [PR] [FLINK-38510][table-planner] Remove targetColumns from the digest generation in SinkReuser [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/27 06:26:35 UTC, 0 replies.
- [PR] [doc] Update document for embedding model. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/27 06:50:42 UTC, 2 replies.
- [PR] [doc] Update the documents in the get-started section [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/27 08:19:13 UTC, 5 replies.
- [PR] [hotfix][release] Build 0.2 docs in GitHub Action [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/27 08:34:33 UTC, 3 replies.
- [PR] [hotfix] Fix errors in sensory_and_short_term_memory [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/27 09:07:58 UTC, 3 replies.
- [PR] [release] Auto update documentation build ci when creating a new release branch [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/27 09:30:34 UTC, 1 replies.
- [PR] [Hotfix] [Build] Update flink-connector-kafka to 4.0.1-2.0 [flink] - posted by "eschcam (via GitHub)" <gi...@apache.org> on 2026/01/27 10:38:40 UTC, 5 replies.
- [PR] [hotfix] Update Flink versions in GitHub PR CI [flink-connector-kudu] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/27 11:25:03 UTC, 1 replies.
- [PR] [doc] Update document for chat model. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/27 11:33:48 UTC, 2 replies.
- Re: [PR] [FLINK-38691] [cdc connector mysql] Support for MySQL Transaction Boundary Events in Flink CDC Connector [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2026/01/27 11:46:44 UTC, 3 replies.
- [jira] [Updated] (FLINK-38691) Support for Transaction Boundary Events in Flink CDC Connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/27 11:47:00 UTC, 0 replies.
- Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.23.1 to 2.25.3 [flink-connector-kudu] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2026/01/27 11:57:26 UTC, 0 replies.
- [jira] [Created] (FLINK-38984) Python interpreter not found when using thread mode (pemja) - posted by "raoraoxiong (Jira)" <ji...@apache.org> on 2026/01/27 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38985) [Doc] Add document for VARIANT type and related functions - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/27 12:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38984) Python interpreter not found when using thread mode (pemja) - posted by "raoraoxiong (Jira)" <ji...@apache.org> on 2026/01/27 12:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38984) Python interpreter not found when using thread mode (pemja) - posted by "raoraoxiong (Jira)" <ji...@apache.org> on 2026/01/27 12:08:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38984) Python interpreter not found when using thread mode (pemja) - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/27 12:10:00 UTC, 0 replies.
- [PR] [release] Add scripts for generating contributor list [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/27 12:49:26 UTC, 2 replies.
- [PR] [minor][docs] add jdk baseline version and remove useless code [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/01/27 12:51:04 UTC, 6 replies.
- [PR] [hotfix] git ignore .metals and .bloop [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/27 14:30:41 UTC, 3 replies.
- [PR] [FLINK-38913][table-planner][BP-2.2] ArrayIndexOutOfBoundsException unparsing CAST [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/27 14:42:28 UTC, 2 replies.
- [PR] [FLINK-38913][table-planner][BP-2.1] ArrayIndexOutOfBoundsException unparsing CAST. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/27 14:45:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-38867) FlinkBlueGreenDeployment: savepointRedeployNonce does not respect user-provided initialSavepointPath - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/27 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/01/27 18:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/01/27 18:45:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/01/27 18:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38987) Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem - posted by "yunjiong zhao (Jira)" <ji...@apache.org> on 2026/01/28 00:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38691) Support for Transaction Boundary Events in Flink CDC Connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/28 01:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38889) YAML Kafka sink connector supports serializing complex types - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/28 02:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/28 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/28 03:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/28 03:32:00 UTC, 2 replies.
- [PR] [hotfix] Fix errors in mcp docs [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/28 03:47:07 UTC, 1 replies.
- Re: [I] [Feature] Support Configuring Event Logger via Configuration System [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/28 06:03:23 UTC, 1 replies.
- Re: [I] [Bug] Flink Agents Example Fails with 'ModuleNotFoundError: No module named 'encodings'' in YARN Cluster Mode [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/28 06:16:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38989) Support resetting backlog status - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2026/01/28 06:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38628) Add document for FLIP-542: Make materialized table DDL consistent with regular tables - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2026/01/28 06:52:00 UTC, 0 replies.
- [PR] [doc] Update Java vs Python API choice details [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/28 07:00:07 UTC, 3 replies.
- [jira] [Updated] (FLINK-38989) Support resetting backlog status - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2026/01/28 07:13:00 UTC, 3 replies.
- [PR] [FLINK-38965][cdc][postgres] Fix LIKE wildcard matching issue for similar table names in PostgreSQL CDC connector [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/01/28 07:19:47 UTC, 4 replies.
- [PR] [doc] Fix typos in documentation [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/01/28 07:37:37 UTC, 2 replies.
- [jira] [Closed] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/28 07:50:00 UTC, 0 replies.
- [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/01/28 08:25:12 UTC, 2 replies.
- [jira] [Created] (FLINK-38990) Support configurable initial delay for first checkpoint trigger - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/28 08:41:00 UTC, 0 replies.
- [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2026/01/28 09:09:06 UTC, 3 replies.
- [jira] [Updated] (FLINK-38990) Support configurable initial delay for first checkpoint trigger - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/28 09:10:00 UTC, 1 replies.
- Re: [PR] [FLINK-37722] Eliminate redundant field initialization of PojoSerializer [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2026/01/28 09:12:38 UTC, 3 replies.
- Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2026/01/28 09:13:44 UTC, 1 replies.
- [PR] Announce Flink Agents 0.2.0 [flink-web] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/28 11:13:30 UTC, 5 replies.
- [PR] [hotfix] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) [flink-cdc] - posted by "linguoxuan (via GitHub)" <gi...@apache.org> on 2026/01/28 11:13:40 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/28 11:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/28 11:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/28 11:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/28 11:55:00 UTC, 0 replies.
- Re: [D] Planning Flink Agents 0.2 [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/28 15:27:14 UTC, 0 replies.
- [jira] [Created] (FLINK-38991) MySQL CDC fails to detect online schema changes with custom gh-ost or pt-osc table naming - posted by "Vishal P R (Jira)" <ji...@apache.org> on 2026/01/28 17:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2026/01/28 17:48:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2026/01/28 17:48:00 UTC, 0 replies.
- [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2026/01/28 19:18:24 UTC, 3 replies.
- [jira] [Updated] (FLINK-37351) Ensure writer and committer are colocated - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/28 19:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2026/01/28 19:29:00 UTC, 0 replies.
- [PR] [FLINK-38992] Expire associated state together for non-time over windows [flink] - posted by "bvarghese1 (via GitHub)" <gi...@apache.org> on 2026/01/28 19:47:04 UTC, 7 replies.
- [jira] [Updated] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/28 19:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38993) Move query change validation logic from converter to operation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/28 22:05:00 UTC, 0 replies.
- [PR] [FLINK-38993][table] Move materialized table query change validation logic from converter to operation [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/01/28 22:10:21 UTC, 22 replies.
- [jira] [Updated] (FLINK-38993) Move query change validation logic from converter to operation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/28 22:11:00 UTC, 0 replies.
- [PR] [doc] Clarify Azure OpenAI vs Azure AI in FAQ [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/01/29 00:22:19 UTC, 2 replies.
- [jira] [Resolved] (FLINK-38982) [JUnit5 Migration] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/29 01:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38985) [Doc] Add document for VARIANT type and related functions - posted by "suhwan (Jira)" <ji...@apache.org> on 2026/01/29 01:53:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/29 01:55:00 UTC, 0 replies.
- Re: [I] [Feature] Use MCP SDK to replace custom MCP/agent annotations [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/29 01:57:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/29 01:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-34825][pipeline-connector][mongodb] Add Implementation of DataSource in MongoDB [flink-cdc] - posted by "sd4324530 (via GitHub)" <gi...@apache.org> on 2026/01/29 03:02:28 UTC, 0 replies.
- [PR] [Infra] Support centralized Flink version management via script to simplify upgrades [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/29 03:10:42 UTC, 1 replies.
- [PR] [FLINK-38888][transform] YAML Pipeline supports item subscription of array and map [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/01/29 03:25:37 UTC, 3 replies.
- [jira] [Updated] (FLINK-38888) YAML Pipeline supports item subscription of complex types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/29 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38994) Remove dependency log4j1 from flink-cdc-cli - posted by "Mingliang Zhu (Jira)" <ji...@apache.org> on 2026/01/29 03:37:00 UTC, 0 replies.
- [PR] [FLINK-38994][cli] Remove log4j1 dependency [flink-cdc] - posted by "zml1206 (via GitHub)" <gi...@apache.org> on 2026/01/29 03:40:14 UTC, 2 replies.
- [jira] [Updated] (FLINK-38994) Remove dependency log4j1 from flink-cdc-cli - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/29 03:41:00 UTC, 0 replies.
- [I] [Bug] [flink-agents]Caused by: java.io.IOException: Found local file path with authority 'C:' in path 'file://C://Users// [flink-agents] - posted by "JavaLeb (via GitHub)" <gi...@apache.org> on 2026/01/29 03:47:07 UTC, 7 replies.
- [PR] [example] Use Table API in workflow_multiple_agent_example [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/29 03:53:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-37926) Support type casting between variant and constructed type - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/01/29 04:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38985) [Doc] Add document for VARIANT type and related functions - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/29 05:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-38595][table] Add tests for multiple features with MJ [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/29 06:29:23 UTC, 0 replies.
- Re: [PR] [doc] Clarify Azure OpenAI vs Azure AI in documentation [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/29 06:34:00 UTC, 1 replies.
- [PR] [runtime] Support configure the thread pool size of async executor. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/29 07:11:16 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38995) Update the current Status of Disaggregated State & ForSt - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2026/01/29 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38995) Update the current Status of Disaggregated State & ForSt - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2026/01/29 07:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38995) Update the current Status of Disaggregated State & ForSt - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2026/01/29 07:45:00 UTC, 4 replies.
- [jira] [Created] (FLINK-38996) Add origin transform sql expression into exception message - posted by "Jia Fan (Jira)" <ji...@apache.org> on 2026/01/29 07:45:00 UTC, 0 replies.
- [PR] [FLINK-38996][transform] Enhance error messages for projection and filtering expressions [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/01/29 07:47:47 UTC, 6 replies.
- [jira] [Updated] (FLINK-38996) Add origin transform sql expression into exception message - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/29 07:48:00 UTC, 0 replies.
- Re: [I] [Feature][examples] Showcase Table API in the quickstart example [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/29 07:59:02 UTC, 0 replies.
- [PR] [FLINK-38995][docs] Update the current Status of Disaggregated State and ForSt [flink] - posted by "curcur (via GitHub)" <gi...@apache.org> on 2026/01/29 08:05:16 UTC, 18 replies.
- [PR] [doc] Rename OpenAI (Azure) to Azure OpenAI [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/29 08:16:17 UTC, 1 replies.
- [PR] [FLINK-38836][docs] update section headings and improve pipeline configuration options [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/01/29 08:23:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-38836) Chinese documentation for pipeline configuration options is missing. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/29 08:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2026/01/29 08:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2026/01/29 08:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2026/01/29 08:33:00 UTC, 0 replies.
- [PR] [example] Support submit the example in installed python package to f… [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2026/01/29 08:51:58 UTC, 0 replies.
- Re: [PR] [example] Support submit the example in installed python package to flink cluster. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/29 09:22:12 UTC, 1 replies.
- [jira] [Reopened] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled config - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/29 09:26:00 UTC, 0 replies.
- Re: [PR] [infra] Support centralized Flink version management via script to simplify upgrades [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2026/01/29 09:46:55 UTC, 1 replies.
- [jira] [Updated] (FLINK-38991) MySQL CDC fails to detect online schema changes with custom gh-ost or pt-osc table naming - posted by "Vishal P R (Jira)" <ji...@apache.org> on 2026/01/29 10:21:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38997) Job can get stuck in state transition because unexpected error during ExecutionGraph creation - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/29 10:56:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2026/01/29 11:05:00 UTC, 0 replies.
- [PR] [Flink 38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled config [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/01/29 11:19:46 UTC, 1 replies.
- [jira] [Created] (FLINK-38998) Cascaded event time Window Aggregate does not produce data when offset is specified - posted by "Sergey Kononov (Jira)" <ji...@apache.org> on 2026/01/29 11:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38998) Cascaded event time Window Aggregate does not produce data when offset is specified - posted by "Sergey Kononov (Jira)" <ji...@apache.org> on 2026/01/29 11:34:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2026/01/29 11:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2026/01/29 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38999) License lineage files - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/01/29 11:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38869) InitializationContext for KafkaSubscriber - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/01/29 11:48:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38998) Cascaded event time Window Aggregate does not produce data when offset is specified - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/29 12:12:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38866) TIMESTAMP_LTZ(6) values with UNION ALL into window TVF produce incorrect results in batch mode - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/29 12:12:00 UTC, 0 replies.
- [PR] [FLINK-38999][lineage] License lineage files [flink-connector-kafka] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2026/01/29 12:14:37 UTC, 1 replies.
- [jira] [Updated] (FLINK-38999) License lineage files - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/29 12:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38644) Reading tables with String type as the primary key may cause OutOfMemory Error - posted by "Jia Fan (Jira)" <ji...@apache.org> on 2026/01/29 12:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38999) License lineage files - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/01/29 13:43:00 UTC, 0 replies.
- [PR] [FLINK-38857][Model] Add docs for Triton inference model [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2026/01/29 14:29:05 UTC, 10 replies.
- [PR] [FLINK-38986][runtime] Migrate BlobKey to SHA-256 and update SSL test ciphers [flink] - posted by "balassai (via GitHub)" <gi...@apache.org> on 2026/01/29 17:21:51 UTC, 9 replies.
- [jira] [Updated] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/29 17:22:00 UTC, 1 replies.
- [jira] [Created] (FLINK-39000) Avoid redundant seeks during operator list state restore - posted by "Ivan Torres (Jira)" <ji...@apache.org> on 2026/01/29 19:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39000) Avoid redundant seeks during operator list state restore - posted by "Ivan Torres (Jira)" <ji...@apache.org> on 2026/01/29 19:13:00 UTC, 0 replies.
- [PR] [FLINK-38969][Sql] Extend json_string to convert variant type [flink] - posted by "swapna267 (via GitHub)" <gi...@apache.org> on 2026/01/29 19:32:28 UTC, 3 replies.
- [jira] [Updated] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/29 19:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39000) Avoid redundant seeks during operator list state restore - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/01/29 19:55:00 UTC, 0 replies.
- [I] [Bug] [runtime] Python awaitable lost during checkpoint restore causes NoneType error [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/01/29 22:05:27 UTC, 1 replies.
- [PR] [runtime] Fix Python awaitable lost during checkpoint restore [flink-agents] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/01/29 22:25:38 UTC, 6 replies.
- [PR] [Flink 38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/01/30 02:54:50 UTC, 0 replies.
- [jira] [Updated] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enable - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/30 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39001) [doc] Supplement the documentation regarding dynamic table addition - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/30 03:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39001) [doc] Supplement the documentation with newlyaddedtable - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/30 03:20:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-39001) [doc] Supplement the documentation with newlyaddedtable - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2026/01/30 04:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-39001) [doc] Supplement the documentation with newlyaddedtable - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2026/01/30 04:00:00 UTC, 0 replies.
- Re: [I] [Feature] Support submit the example in installed python package to flink cluster. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2026/01/30 04:02:10 UTC, 0 replies.
- [PR] [Flink-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2026/01/30 04:22:06 UTC, 0 replies.
- [PR] [FLINK-38906] Pass transform parser in context and polish built-in functions [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2026/01/30 05:49:38 UTC, 4 replies.
- [jira] [Updated] (FLINK-38906) Polish YAML transform built-in functions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/30 05:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38787) Add Metrics for FlinkBlueGreenDeployment resources - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/30 06:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-24493] [flink-connector-base] Introduce DemultiplexingSink [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/01/30 06:30:10 UTC, 0 replies.
- Re: [PR] [FLINK-38986][core][runtime] Change SecurityOptions.SSL_ALGORITHMS default value and update SSL tests [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2026/01/30 07:37:32 UTC, 1 replies.
- [jira] [Created] (FLINK-39002) Could not resolve ResourceManager because of NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/30 08:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39002) Could not resolve ResourceManager because of NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/30 08:40:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-39002) Could not resolve ResourceManager because of NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/30 08:41:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-38927) Support ON CONFLICT in SqlParser - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/30 09:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38887) YAML Transform module supports nested types - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/30 09:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38915) Suspending Pipeline Breaks FlinkBlueGreenDeployment - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/30 09:28:00 UTC, 0 replies.
- Re: [PR] Maximum parallelism expansion can be used in MAXIMIZE_UTILISATION mode. [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2026/01/30 09:28:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38836) Chinese documentation for pipeline configuration options is missing. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/30 09:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38996) Add origin transform sql expression into exception message - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/30 09:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-39002) Could not resolve ResourceManager because of NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/30 10:04:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38994) Remove dependency log4j1 from flink-cdc-cli - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/30 10:05:00 UTC, 0 replies.
- [PR] fix: issuer secret name [flink-kubernetes-operator] - posted by "mlboy (via GitHub)" <gi...@apache.org> on 2026/01/30 10:19:03 UTC, 1 replies.
- Re: [PR] [FLINK-38986][runtime] Update SSL tests with modern cipher suites [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2026/01/30 10:28:42 UTC, 0 replies.
- Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc] - posted by "Copilot (via GitHub)" <gi...@apache.org> on 2026/01/30 10:38:42 UTC, 0 replies.
- Re: [PR] [FLINK-38986][runtime][test] Update SSL tests with modern cipher suites [flink] - posted by "balassai (via GitHub)" <gi...@apache.org> on 2026/01/30 11:02:19 UTC, 20 replies.
- [jira] [Updated] (FLINK-39003) Inaccurate millisBehindLatest metric from the Kinesis source connector on failover - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/01/30 12:25:00 UTC, 3 replies.
- [jira] [Created] (FLINK-39003) Inaccurate millisBehindLatest metric from the Kinesis source connector on failover - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/01/30 12:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-39003) Draft: Inaccurate millisBehindLatest metric from the Kinesis source connector on failover - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/01/30 12:33:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-38993) Move query change validation logic from converter to operation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/30 14:32:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38993) Move query change validation logic from converter to operation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/30 14:32:00 UTC, 0 replies.
- Re: [PR] [FLINK-30975] Upgrade hadoop to 3.4.X [flink] - posted by "rmetzger (via GitHub)" <gi...@apache.org> on 2026/01/30 14:46:22 UTC, 2 replies.
- Re: [PR] [hotfix] Intermittent unit test failures we have hit in ExecutionGraph tests [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2026/01/30 15:15:14 UTC, 0 replies.
- [PR] [Hotfix][Flink-CI-Tools] Update Guava to 32.0.1 [flink] - posted by "eschcam (via GitHub)" <gi...@apache.org> on 2026/01/30 15:15:15 UTC, 2 replies.
- [jira] [Resolved] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBALANCE for autoscaler and adaptive scheduler - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/30 22:21:00 UTC, 0 replies.
- [PR] [FLINK-38985][docs] Add documentation for VARIANT type and PARSE_JSON functions [flink-cdc] - posted by "suhwan-cheon (via GitHub)" <gi...@apache.org> on 2026/01/31 00:57:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-38985) [Doc] Add document for VARIANT type and related functions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/31 00:58:00 UTC, 0 replies.
- [jira] (FLINK-38601) MongoDB CDC silently stops consuming from unbounded streams when Throwable errors occur and never recovers - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/01/31 06:32:00 UTC, 0 replies.
- [PR] [FLINK-38846][mysql] Optimize LinkedList processing in handleChange method to reduce complexity [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/01/31 13:34:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-38846) Binlog client use LinkedList to store binlog content - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/31 13:35:00 UTC, 0 replies.
- Re: [PR] [FLINK-38248] The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. [flink-cdc] - posted by "yunhaoww (via GitHub)" <gi...@apache.org> on 2026/01/31 14:21:13 UTC, 0 replies.
- [PR] The microseconds default value of '0000-00-00 00:00:00.000000' for MySQL TIMESTAMP fields is not supported in downstream systems. [flink-cdc] - posted by "yunhaoww (via GitHub)" <gi...@apache.org> on 2026/01/31 14:40:35 UTC, 0 replies.
- [PR] [hotfix] Fix the problems using Kafka as action state store [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2026/01/31 14:54:50 UTC, 0 replies.
- [PR] [FLINK-37586][udf] Add support for options in user-defined functions and update related documentation [flink-cdc] - posted by "Hisoka-X (via GitHub)" <gi...@apache.org> on 2026/01/31 15:29:54 UTC, 0 replies.
- [jira] [Updated] (FLINK-37586) YAML pipeline supports passing extra options to UDFs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/01/31 15:30:00 UTC, 0 replies.