issues@flink.apache.org, 2025-12

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

- [I] [Feature] Introduce Long-Term Memory in Java [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/01 01:51:34 UTC, 0 replies.
- [I] [doc] Add documents for sensory memory [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/01 01:52:52 UTC, 0 replies.
- [I] [doc] Add documents for long-term memory [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/01 01:53:36 UTC, 0 replies.
- Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] - posted by "WeiZhong94 (via GitHub)" <gi...@apache.org> on 2025/12/01 02:22:07 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38338) Introduce the abstraction to describe a rescale event. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/12/01 02:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38338) Introduce the abstraction to describe a rescale event. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/12/01 02:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38338) Introduce the abstraction to describe a rescale event. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/12/01 02:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38338) Introduce the abstraction to describe a rescale event. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2025/12/01 02:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38740) STDDEV related functions may produce invalid results - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/12/01 02:28:00 UTC, 1 replies.
- Re: [PR] [FLINK-38741][mysql-cdc] Fix MODIFY COLUMN position change events are… [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/12/01 04:15:01 UTC, 0 replies.
- Re: [PR] Add mysql operation metrics [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/12/01 04:19:11 UTC, 1 replies.
- Re: [PR] [FLINK-38531][cdc-connector-mysql]Fix data loss when restoring from a checkpoint positioned in the middle of a bulk DML operation. [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/12/01 04:21:20 UTC, 11 replies.
- Re: [PR] [FLINK-38100] Bump Iceberg dependency to 1.10.0 in iceberg-pipeline-sink connector [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/12/01 05:54:09 UTC, 1 replies.
- [I] [Feature] Support Cross-Language Resource [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/01 06:13:05 UTC, 0 replies.
- [I] [Feature] Support ChatModel cross-language calls [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/01 06:16:29 UTC, 1 replies.
- [I] [Feature] Support the use of Java ChatModel in Python [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/01 06:19:00 UTC, 1 replies.
- Re: [PR] Add Hudi sink connector support [flink-cdc] - posted by "cshuo (via GitHub)" <gi...@apache.org> on 2025/12/01 06:40:59 UTC, 4 replies.
- Re: [PR] [hotfix] Add Postgresql UUID catalog support [flink-connector-jdbc] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2025/12/01 07:18:46 UTC, 1 replies.
- Re: [PR] [api][runtime] Introduce long-term memory in python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/01 09:15:34 UTC, 11 replies.
- Re: [PR] Add Flink 2.2.0 Release [flink-web] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/12/01 09:30:36 UTC, 15 replies.
- Re: [PR] [FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/01 09:49:58 UTC, 6 replies.
- [PR] [hotfix] Remove unnecessary space to improve the pass rate of IntegrationTest [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/01 09:58:40 UTC, 3 replies.
- [PR] [Feature][Java] Add MCP support in Java [flink-agents] - posted by "yanand0909 (via GitHub)" <gi...@apache.org> on 2025/12/01 10:35:29 UTC, 20 replies.
- [jira] [Commented] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/12/01 10:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] - posted by "linjianchang (via GitHub)" <gi...@apache.org> on 2025/12/01 11:00:42 UTC, 22 replies.
- [jira] [Created] (FLINK-38753) Enrich more upsert keys by equiv expressions - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/12/01 11:17:00 UTC, 0 replies.
- [PR] [FLINK-38717][runtime] Display the load status of TaskManagers. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/12/01 11:22:54 UTC, 16 replies.
- [jira] [Updated] (FLINK-38717) Display the load status of TaskManagers. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/01 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38754) Unnecessary - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/01 11:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38754) Unnecessary reverse DNS lookup when task managers connect to BlobServer - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/01 11:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38754) An unnecessary reverse DNS lookup when TaskManager connects to BlobServer - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/01 11:27:00 UTC, 9 replies.
- [jira] [Created] (FLINK-38755) FLIP-549: Support Application Management - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/01 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38756) Add support for ALTER MATERIALIZED TABLE ADD columns in parser - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/01 12:31:00 UTC, 0 replies.
- [PR] [FLINK-38756][table] Add support for `ALTER MATERIALIZED TABLE ADD` columns in parser [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/01 12:34:12 UTC, 29 replies.
- [jira] [Updated] (FLINK-38756) Add support for ALTER MATERIALIZED TABLE ADD columns in parser - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/01 12:35:00 UTC, 0 replies.
- [PR] [hotfix][docs] Use stable fluss doc link to avoid broken link once fluss community version upgrade [flink] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/12/01 13:53:29 UTC, 3 replies.
- [PR] [FLINK-38738][table] Fix UIDs for ScanTableSource with multiple transformations [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/12/01 15:27:08 UTC, 14 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 2025/12/01 16:08:19 UTC, 1 replies.
- [PR] infra: update markdown lint check [flink-cdc] - posted by "kevinjqliu (via GitHub)" <gi...@apache.org> on 2025/12/01 16:56:53 UTC, 1 replies.
- [PR] FLINK-38743 Change connector identifiers [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/01 17:26:12 UTC, 4 replies.
- [jira] [Updated] (FLINK-38743) Change the HTTP connector name and identifiers so it does not clash with the getindata connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/01 17:27:00 UTC, 0 replies.
- Re: [PR] [FLINK-38260] Add parser changes for connection sql [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/12/01 18:21:05 UTC, 1 replies.
- Re: [PR] [Feature][Java] Add OpenAI chat model integration [flink-agents] - posted by "xli1996 (via GitHub)" <gi...@apache.org> on 2025/12/01 20:34:58 UTC, 1 replies.
- [PR] Bump express in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/01 21:16:38 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38756) Add support for ALTER MATERIALIZED TABLE ADD columns in parser - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/01 21:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38756) Add support for ALTER MATERIALIZED TABLE ADD columns in parser - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/01 21:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38750) Validation of queries with functions erroneously invoked under select fails with StackOverflow - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/01 21:49:00 UTC, 3 replies.
- [jira] [Resolved] (FLINK-38750) Validation of queries with functions erroneously invoked under select fails with StackOverflow - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/01 21:49:00 UTC, 0 replies.
- Re: [PR] [FLINK-38661][docs] Add 2.2.0 release note [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/12/01 23:19:25 UTC, 7 replies.
- [jira] [Updated] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/12/01 23:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38260) Connection sql syntax - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/01 23:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38260) Connection sql syntax - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/01 23:37:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38260) Connection sql syntax - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/01 23:37:00 UTC, 0 replies.
- [PR] [FLINK-38084][doc] add download doc for model providers [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/12/02 00:27:21 UTC, 5 replies.
- [jira] [Updated] (FLINK-38084) Update model provider download doc - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/02 00:28:00 UTC, 0 replies.
- [PR] [hotfix] postgresql uuid type support [flink-connector-jdbc] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2025/12/02 02:05:23 UTC, 10 replies.
- [I] [Feature] Support the use of Python resources in Java [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/02 02:14:18 UTC, 0 replies.
- [I] [Feature] Support the use of Java resources in Python [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/02 02:16:05 UTC, 0 replies.
- [I] [Feature] Support the use of Python EmbeddingModels in Java [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/02 02:21:39 UTC, 0 replies.
- [I] [Feature] Support the use of Python VectorStore in Java [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/02 02:22:26 UTC, 0 replies.
- [I] [Feature] Support the use of Python MCP in Java [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/02 02:22:49 UTC, 0 replies.
- [I] [Feature] Support the use of Java EmbeddingModels in Python [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/02 02:24:14 UTC, 0 replies.
- [I] [Feature] Support the use of Java VectorStore in Python [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/02 02:25:15 UTC, 0 replies.
- [I] [Feature] Support the use of Java MCP in Python [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/02 02:25:44 UTC, 0 replies.
- [PR] [runtime] Implement hashCode and equals for ActionTask. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/02 02:57:11 UTC, 3 replies.
- [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 2025/12/02 03:22:53 UTC, 1 replies.
- [I] [Bug] PythonEvent not show properly in event log [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/02 04:10:10 UTC, 1 replies.
- [PR] [hotfix][runtime] EventLogger displays the content of PythonEvent as string [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/02 04:18:24 UTC, 4 replies.
- Re: [PR] [FLINK-36536] Bumped `commons-text` from 1.10.0 to 1.12.0 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/02 06:26:22 UTC, 1 replies.
- [I] [Feature][doc] Add document for built-in openai chat model support in java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/02 06:42:05 UTC, 0 replies.
- Re: [I] [Feature] [integration] [java] Integrate built-in openai chat model [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/02 06:43:28 UTC, 1 replies.
- Re: [PR] [hotfix][doc] Update latest version of 1.20 as 1.20.3 [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/12/02 07:39:25 UTC, 0 replies.
- Re: [PR] [hotfix][doc] Update latest version of 2.1 as 2.1.1 [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/12/02 07:39:36 UTC, 0 replies.
- Re: [I] [Bug] Python async execution can not work with flink checkpoint. [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/02 07:47:05 UTC, 0 replies.
- [PR] [BP-2.2][FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/02 08:40:59 UTC, 2 replies.
- [PR] [BP-2.1][FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/02 08:41:29 UTC, 2 replies.
- [jira] [Created] (FLINK-38757) Introduce the base class for application - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/02 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38758) Introduce PackagedProgramApplication - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/02 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38759) Refactor application mode with PackagedProgramApplication - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/02 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38760) Add REST APIs for application query and cancellation - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/02 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38761) Support archiving applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/02 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38762) Introduce SingleJobApplication - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/02 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38763) Add REST API for JarRunApplication - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/02 09:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38605) Feature: Stateless Ordered Async - posted by "Guotao Ding (Jira)" <ji...@apache.org> on 2025/12/02 09:17:00 UTC, 0 replies.
- [PR] [BP-1.20][FLINK-38750][table] Validation of queries with functions erroneously invoked under SELECT fails with StackOverflow [flink] - posted by "gkomlossi (via GitHub)" <gi...@apache.org> on 2025/12/02 09:50:49 UTC, 2 replies.
- Re: [PR] [FLINK-38752][table] Drop `EquivalentExprShuttle` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/02 10:58:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-38752) Drop EquivalentExprShuttle - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/02 11:00: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 2025/12/02 11:04:03 UTC, 1 replies.
- Re: [PR] [FLINK-38743] Change connector identifiers [flink-connector-http] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/12/02 11:35:48 UTC, 0 replies.
- [jira] [Closed] (FLINK-38743) Change the HTTP connector name and identifiers so it does not clash with the getindata connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/02 11:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/12/02 11:48:47 UTC, 1 replies.
- Re: [PR] [FLINK-35633] Add more YAML structure validations & provide better error messages [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/12/02 12:04:20 UTC, 0 replies.
- [jira] [Created] (FLINK-38764) switch lz4-java to at.yawk.lz4 version due to CVE - posted by "PJ Fanning (Jira)" <ji...@apache.org> on 2025/12/02 12:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38764) switch lz4-java to at.yawk.lz4 version due to CVE - posted by "PJ Fanning (Jira)" <ji...@apache.org> on 2025/12/02 12:32:00 UTC, 1 replies.
- [PR] [FLINK-38737][common] Fix potential backwards incompatibility with fallback keys. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/12/02 12:56:50 UTC, 3 replies.
- [jira] [Updated] (FLINK-38737) Introducing fallback keys can cause validateFactoryOptions to fail - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/02 12:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38750) Validation of queries with functions erroneously invoked under select fails with StackOverflow - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/02 13:17:00 UTC, 0 replies.
- Re: [PR] [FLINK-36296][Connectors/DynamoDB] Add support for incremental shard discovery for DynamoDB Streams Source [flink-connector-aws] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/02 13:28:32 UTC, 40 replies.
- [jira] [Commented] (FLINK-38751) RowTimeRangeBoundedPrecedingFunction incorrectly cleans lastTriggeringTsState, may not discard expired data - posted by "Dongsheng He (Jira)" <ji...@apache.org> on 2025/12/02 14:01:00 UTC, 1 replies.
- Re: [PR] [FLINK-38481][http] Remove http header and responses from logging [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/02 14:22:17 UTC, 7 replies.
- [jira] [Created] (FLINK-38765) Sink Upsert Materializer does not work with metadata columns - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/12/02 14:25:00 UTC, 0 replies.
- [PR] [FLINK-38765] Fix persisted metadata handling in sink [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/12/02 14:32:34 UTC, 7 replies.
- [jira] [Updated] (FLINK-38765) Sink Upsert Materializer does not work with metadata columns - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/02 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38766) Add support for ALTER MATERIALIZED TABLE ADD support - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/02 14:42:00 UTC, 0 replies.
- [PR] [FLINK-38766][table] Add support for `ALTER MATERIALIZED TABLE ADD` support [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/02 14:46:45 UTC, 13 replies.
- [jira] [Updated] (FLINK-38766) Add support for ALTER MATERIALIZED TABLE ADD support - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/02 14:47:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) - posted by "EMERSON WANG (Jira)" <ji...@apache.org> on 2025/12/02 20:38:00 UTC, 2 replies.
- Re: [PR] [FLINK-38746][table-runtime] Fix StackOverflowError in RecordsWindowBuffer.addElement [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/12/02 21:09:04 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38530) create Dynamic Kafka Source for pyflink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2025/12/02 23:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38530) create Dynamic Kafka Source for pyflink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2025/12/02 23:21:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38767) Fix vector_search transformation - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/12/03 00:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38768) Materialized table fails with validation exception in case of LATERAL TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/03 00:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38768) Materialized table fails with validation exception in case of LATERAL TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/03 00:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38767) Fix vector_search transformation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/03 00:32:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38767) Fix vector_search transformation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/03 01:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38084) Update model provider download doc - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/03 02:30:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38084) Update model provider download doc - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/03 02:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38084) Update model provider download doc - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/03 02:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38754) An unnecessary reverse DNS lookup when TaskManager connects to BlobServer - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/03 03:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc] - posted by "ChaomingZhangCN (via GitHub)" <gi...@apache.org> on 2025/12/03 03:18:30 UTC, 3 replies.
- Re: [PR] [backport][FLINK-37813][runtime] Pass numberSlots via WorkerRegistration instead of SlotReport [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/12/03 03:20:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file - posted by "wangkang (Jira)" <ji...@apache.org> on 2025/12/03 05:53:00 UTC, 0 replies.
- [PR] [FLINK-38757][runtime] Introduce the base class for application [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2025/12/03 06:00:32 UTC, 6 replies.
- [jira] [Updated] (FLINK-38757) Introduce the base class for application - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/03 06:27:00 UTC, 0 replies.
- [PR] Add GPG key for 2.2.0 release [flink-docker] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/12/03 06:54:04 UTC, 1 replies.
- [PR] Update Dockerfiles for 2.2.0 release [flink-docker] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/12/03 07:02:22 UTC, 9 replies.
- [jira] [Resolved] (FLINK-37813) SlotManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2025/12/03 07:11:00 UTC, 0 replies.
- [PR] [FLINK-38758][runtime] Introduce PackagedProgramApplication [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2025/12/03 07:48:08 UTC, 6 replies.
- [jira] [Updated] (FLINK-38758) Introduce PackagedProgramApplication - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/03 07:49:00 UTC, 2 replies.
- [PR] Announce Flink Agents 0.1.1 [flink-web] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/03 08:43:06 UTC, 5 replies.
- Re: [PR] [FLINK-38768][table] Materialized table fails with validation exception in case of `LATERAL TABLE` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/03 09:47:23 UTC, 0 replies.
- [jira] [Created] (FLINK-38769) Flink Cdc Parse Mysql data is uncompleted - posted by "Hao Yu (Jira)" <ji...@apache.org> on 2025/12/03 10:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38769) Flink CDC parsing of MySQL data is incomplete. - posted by "Hao Yu (Jira)" <ji...@apache.org> on 2025/12/03 10:44:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38768) Materialized table fails with validation exception in case of LATERAL TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/03 12:45:00 UTC, 0 replies.
- [PR] [FLINK-38730][build] Bump jdk version from 8 to 11. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/12/03 13:03:04 UTC, 10 replies.
- [jira] [Updated] (FLINK-38730) Bump jdk version of Flink CDC to 11 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/03 13:04:00 UTC, 0 replies.
- Re: [PR] [FLINK-38747][core] Update the annotation of RateLimiter and RateLimiterStrategy interface from @Experimental to @PublicEvolving. [flink] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/12/03 13:05:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-38738) Incorrect UID for DataStreamScanProvider and TransformationScanProvider - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/12/03 13:28:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38738) Incorrect UID for DataStreamScanProvider and TransformationScanProvider - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/12/03 13:29:00 UTC, 0 replies.
- Re: [PR] [docs] Update Avro schema resolution link to latest version [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/03 13:40:11 UTC, 4 replies.
- Re: [D] Community Sync [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/03 14:17:13 UTC, 4 replies.
- [jira] [Created] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode - posted by "Barak (Jira)" <ji...@apache.org> on 2025/12/03 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38771) Scalar arguments don't work with multi-table inputs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/12/03 15:29:00 UTC, 0 replies.
- [PR] [hotfix] remove options from docs that do not exist in the code [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/03 15:40:10 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/12/03 16:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-38767] fix vector search execnode transform name [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/12/03 18:33:05 UTC, 0 replies.
- [jira] [Created] (FLINK-38772) CliClientITCase is broken in IDE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/03 18:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38746) `RecordsWindowBuffer.addElement()` catches `EOFException` and retries recursively, causing StackOverflowError - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/12/03 18:48:00 UTC, 0 replies.
- [PR] [FLINK-38772][table] `CliClientITCase` is broken in IDE [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/03 18:50:36 UTC, 2 replies.
- [jira] [Updated] (FLINK-38772) CliClientITCase is broken in IDE - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/03 18:51:00 UTC, 0 replies.
- [PR] [FLINK-37902] batch support for ml_predict [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/12/03 23:45:41 UTC, 1 replies.
- [jira] [Updated] (FLINK-37902) Support batch execution for ML_PREDICT - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/03 23:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38773) BatchExecVectorSearchTableFunction uses wrong context - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/12/03 23:58:00 UTC, 0 replies.
- [PR] [Feature][Java] Add Anthropic chat model integration [flink-agents] - posted by "xli1996 (via GitHub)" <gi...@apache.org> on 2025/12/04 00:28:36 UTC, 3 replies.
- [PR] [FLINK-38773] fix batch vector search excnode context [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/12/04 01:32:36 UTC, 0 replies.
- [jira] [Updated] (FLINK-38773) BatchExecVectorSearchTableFunction uses wrong context - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/04 01:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38767) Fix vector_search transformation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/04 01:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-38773] fix batch vector search execnode context [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/12/04 01:37:42 UTC, 0 replies.
- Re: [PR] [hotfix] Include meaningful messages after applying the prompt [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/04 02:07:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-31975) default catalog failed to retrieve partition Spec - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/12/04 02:35:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-31975) default catalog failed to retrieve partition Spec - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/12/04 02:35:00 UTC, 2 replies.
- [PR] Update japicmp configuration for 2.2.0 [flink] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/12/04 02:35:56 UTC, 2 replies.
- [jira] [Created] (FLINK-38774) Fixed incorrect handling of hidden directories when obtaining partition structure - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/12/04 02:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38774) Fixed incorrect handling of hidden directories when obtaining partition structure - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/12/04 02:44:00 UTC, 5 replies.
- [PR] Fixed incorrect handling of hidden directories when obtFixed incorrect handling of hidden directories when obtaining partition structureaining partiti… [flink] - posted by "abjfh30 (via GitHub)" <gi...@apache.org> on 2025/12/04 03:02:01 UTC, 0 replies.
- Re: [PR] [FLINK-38774] Fixed incorrect handling of hidden directories when obtFixed incorrect handling of hidden directories when obtaining partition structureaining partiti… [flink] - posted by "abjfh30 (via GitHub)" <gi...@apache.org> on 2025/12/04 03:06:23 UTC, 6 replies.
- [jira] [Updated] (FLINK-37813) SlotManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 03:16:00 UTC, 0 replies.
- [jira] (FLINK-38754) An unnecessary reverse DNS lookup when TaskManager connects to BlobServer - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/04 03:26:00 UTC, 0 replies.
- [PR] [hotfix][release] Build 2.2 docs in GitHub Action and mark 2.2 as stable in docs [flink] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/12/04 03:34:29 UTC, 1 replies.
- [PR] Bump @modelcontextprotocol/sdk and @angular/cli in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/04 03:37:37 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38775) Flink 2.2: update reference data for Migration Tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/12/04 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38775) Flink 2.2: update reference data for Migration Tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/12/04 03:50:00 UTC, 0 replies.
- [PR] [FLINK-38775][release] Generate reference data for state migration tests based on release-2.2.0 [flink] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/12/04 03:51:45 UTC, 4 replies.
- [jira] [Updated] (FLINK-38775) Flink 2.2: update reference data for Migration Tests - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/04 03:52:00 UTC, 0 replies.
- [I] [Bug] -fling [flink-agents] - posted by "KaranShishodia (via GitHub)" <gi...@apache.org> on 2025/12/04 05:23:19 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38754) An unnecessary reverse DNS lookup when TaskManager connects to BlobServer - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/04 05:50:00 UTC, 0 replies.
- Re: [PR] [FLINK-33449][table]Support array_contains_seq function [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/04 06:26:10 UTC, 0 replies.
- Re: [PR] [FLINK-34587][table] Introduce MODE aggregate function [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/04 06:26:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2025/12/04 06:46:00 UTC, 0 replies.
- [I] [Bug] Chat Model repeat request tool call in Java [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/04 06:46:15 UTC, 0 replies.
- [jira] [Created] (FLINK-38776) Incorrect auxiliary group field names - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/12/04 07:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38776) Incorrect auxiliary group field names - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/12/04 07:24:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38776) Incorrect auxiliary group field names - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/12/04 07:29:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38776) Incorrect auxiliary group field names - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/12/04 07:35:00 UTC, 0 replies.
- [PR] [Feature][runtime] Support the use of Python ChatModel in Java [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/04 08:13:02 UTC, 4 replies.
- [jira] [Created] (FLINK-38777) HistoryServer supports application archives - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/04 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38778) Web UI for applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/04 08:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38757) Introduce the base class for application - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 08:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38755) FLIP-549: Support Application Management - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 08:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38758) Introduce PackagedProgramApplication - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 08:50:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38761) Support archiving applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 08:50:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38762) Introduce SingleJobApplication - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 08:50:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38759) Refactor application mode with PackagedProgramApplication - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 08:50:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38778) Web UI for applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 08:51:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38777) HistoryServer supports application archives - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 08:51:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38763) Add REST API for JarRunApplication - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/04 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38779) YAML Pipeline router supports RegEx based routing - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/12/04 08:59:00 UTC, 0 replies.
- [PR] [FLINK-38754][runtime] Avoid reverse DNS lookups when connecting to BlobServer [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2025/12/04 09:01:59 UTC, 7 replies.
- [jira] [Assigned] (FLINK-38779) YAML Pipeline router supports RegEx based routing - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/04 09:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38779) YAML Pipeline router supports RegEx based routing - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/04 09:24:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38780) Potential State Incompatibility Issue in Paimon Sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/04 10:05:00 UTC, 0 replies.
- [PR] [hotfix] Bump Doris flink connector version to 25.1.0 [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/12/04 10:08:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-38773) BatchExecVectorSearchTableFunction uses wrong context - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/04 11:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38773) BatchExecVectorSearchTableFunction uses wrong context - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/04 11:17:00 UTC, 0 replies.
- [PR] [FLINK-38776][table] Fix incorrect auxiliary group field names [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/12/04 11:24:12 UTC, 9 replies.
- Re: [PR] [FLINK-38403][tests] Fix the unexpected test that the second job does not restore from checkpoint [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/12/04 12:20:48 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38481) Make HTTP header, request, and response logging configurable - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/04 12:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38481) Make HTTP header, request, and response logging configurable - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/04 12:50:00 UTC, 2 replies.
- Re: [PR] [FLINK-38481] Make HTTP request/response logging configurable [flink-connector-http] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/12/04 12:50:56 UTC, 0 replies.
- [jira] [Updated] (FLINK-38481) Make HTTP request/response logging configurable - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/04 12:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38481) Make HTTP request/response logging configurable - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/04 12:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38527) Upgrade Netty version to 4.1.128.Final for Flink LTS 1.20 - posted by "David Sutta (Jira)" <ji...@apache.org> on 2025/12/04 13:52:00 UTC, 1 replies.
- Re: [PR] Kafka 4.x Queue Semantics support [flink-connector-kafka] - posted by "huangmingyuan (via GitHub)" <gi...@apache.org> on 2025/12/04 14:21:23 UTC, 2 replies.
- Re: [PR] [hotfix][docs] Add documentation for building multiple legacy releases on Windowses on Windows [flink] - posted by "MOliverRoth (via GitHub)" <gi...@apache.org> on 2025/12/04 14:50:28 UTC, 5 replies.
- [PR] [Improve] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2025/12/04 14:54:15 UTC, 0 replies.
- [jira] [Created] (FLINK-38781) pass format options to the http response - posted by "david radley (Jira)" <ji...@apache.org> on 2025/12/04 16:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/12/04 16:51:00 UTC, 0 replies.
- [PR] [FLINK-38771][table] Allow scalar args for multi-table PTFs [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/12/04 16:51:44 UTC, 2 replies.
- [jira] [Commented] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/12/04 16:52:00 UTC, 0 replies.
- [PR] FLINK-38781 pass format options to response using json format [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/04 17:20:49 UTC, 8 replies.
- [jira] [Updated] (FLINK-38781) pass format options to the http response - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/04 17:21:00 UTC, 0 replies.
- [PR] fix: update 2.0.0 to 2.1.0 [flink] - posted by "chenrui333 (via GitHub)" <gi...@apache.org> on 2025/12/04 20:49:00 UTC, 1 replies.
- Re: [PR] fix: update wording for 2.1.0 release notes for java 17 usage [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/12/04 20:57:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38766) Add support for ALTER MATERIALIZED TABLE ADD support - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/04 21:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38766) Add support for ALTER MATERIALIZED TABLE ADD support - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/04 21:50:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38772) CliClientITCase is broken in IDE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/04 21:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38772) CliClientITCase is broken in IDE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/04 21:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38766) Add support for ALTER MATERIALIZED TABLE ADD - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/04 22:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38782) Mongodb CDC need a config to filter large size column - posted by "Joekwal (Jira)" <ji...@apache.org> on 2025/12/05 02:54:00 UTC, 0 replies.
- [PR] [hotfix][table] Fix incorrect error message of RootArgumentTypeStrategy [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/12/05 03:30:20 UTC, 4 replies.
- [PR] Vs cp [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/12/05 03:41:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-38783) Caused by: java.util.ConcurrentModificationException - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/12/05 03:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38132) CLONE - Improve the CSV reading process - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/12/05 03:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38132) CLONE - Improve the CSV reading process - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/12/05 03:48:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38132) CLONE - Improve the CSV reading process - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/12/05 03:49:00 UTC, 0 replies.
- Re: [PR] Cherry-pick a few fixes to 2.2 release [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/12/05 03:49:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-38783) Caused by: java.util.ConcurrentModificationException - posted by "huyuliang (Jira)" <ji...@apache.org> on 2025/12/05 03:50:00 UTC, 2 replies.
- Re: [PR] [Feature][Integration][Java] add ElasticsearchVectorStore in Java [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/05 03:52:28 UTC, 20 replies.
- [jira] [Updated] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted - posted by " xingsuo-zbz (Jira)" <ji...@apache.org> on 2025/12/05 06:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted - posted by " xingsuo-zbz (Jira)" <ji...@apache.org> on 2025/12/05 06:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted - posted by " xingsuo-zbz (Jira)" <ji...@apache.org> on 2025/12/05 06:19:00 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase Migrated to Source V2 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/05 06:26:09 UTC, 1 replies.
- Re: [PR] [FLINK-32695] [Tests] Migrated TimestampITCase to SourceV2 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/05 06:26:12 UTC, 1 replies.
- Re: [PR] [FLINK-38192] Improve DynamicSourceUtils#validateAndApplyMetadata exception msg [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/05 06:26:14 UTC, 1 replies.
- Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/05 06:26:17 UTC, 0 replies.
- [PR] [FLINK-38759][runtime] Refactor application mode with PackagedProgramApplication [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2025/12/05 06:56:23 UTC, 7 replies.
- [jira] [Updated] (FLINK-38759) Refactor application mode with PackagedProgramApplication - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/05 06:57:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38782) Mongodb CDC need a config to filter large size column - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/12/05 08:14:00 UTC, 1 replies.
- Re: [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] - posted by "dieggoluis (via GitHub)" <gi...@apache.org> on 2025/12/05 08:33:20 UTC, 0 replies.
- Re: [PR] [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] - posted by "ztison (via GitHub)" <gi...@apache.org> on 2025/12/05 08:57:56 UTC, 4 replies.
- Re: [PR] [FLINK-38183] Fix the problem of data loss in the GTID disordered scenario [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/12/05 09:13:40 UTC, 0 replies.
- [PR] [FLINK-36794] [cdc-composer/cli] pipeline cdc connector support multiple data sources [flink-cdc] - posted by "linjianchang (via GitHub)" <gi...@apache.org> on 2025/12/05 09:16:57 UTC, 3 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 2025/12/05 09:17:48 UTC, 0 replies.
- [PR] [FLINK-38740][table] Introduce Welford's online algorithm for variance related functions to avoid catastrophic cancellation in naive algorithm [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/12/05 09:18:52 UTC, 9 replies.
- [jira] [Updated] (FLINK-38740) STDDEV related functions may produce invalid results - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/05 09:19:00 UTC, 2 replies.
- Re: [PR] [FLINK-38735][connector-file] add restore state check [flink] - posted by "liunaijie (via GitHub)" <gi...@apache.org> on 2025/12/05 09:58:34 UTC, 1 replies.
- [jira] [Updated] (FLINK-38735) ProcTimeCommitTrigger restore issue without state - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/05 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38784) Bump the version of Paimon flink to 1.3.1 - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/12/05 10:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38784) Bump the version of Paimon flink to 1.3.1 - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/12/05 10:21:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38784) Bump the version of Paimon flink to 1.3.1 - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/12/05 10:22:00 UTC, 2 replies.
- Re: [PR] [FLINK-38522][cdc connector mysql] use ssl for BinaryLogClient when searching for binlog offset for starting mysql cdc from timestamp [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/12/05 10:35:31 UTC, 3 replies.
- [jira] [Created] (FLINK-38785) Quotes removal doesn't remove them properly - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/12/05 10:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38785) Quotes removal doesn't remove them properly - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/12/05 10:56:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38786) Does support oracle-cdc partitioned table now ? - posted by "laixiong (Jira)" <ji...@apache.org> on 2025/12/05 11:06:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38764) switch lz4-java to at.yawk.lz4 version due to CVE - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/12/05 11:42:00 UTC, 0 replies.
- [PR] [FLINK-38764] Upgrade lz4 to 1.8.1 due to security vulnerability [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/12/05 13:27:26 UTC, 5 replies.
- Re: [PR] [FLINK-38592] [POC] Native Flink S3 FileSystem [flink] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2025/12/05 15:29:45 UTC, 2 replies.
- [jira] [Created] (FLINK-38787) Add Metrics for FlinkBlueGreenDeployment resources - posted by "Daniel Rossos (Jira)" <ji...@apache.org> on 2025/12/05 16:22:00 UTC, 0 replies.
- Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/12/05 16:26:34 UTC, 4 replies.
- Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws] - posted by "fsenart (via GitHub)" <gi...@apache.org> on 2025/12/05 17:10:58 UTC, 2 replies.
- [jira] [Created] (FLINK-38788) flink-connector-mysql-cdc silently fails when unable to reconnect due to credentials rotation - posted by "supreetha (Jira)" <ji...@apache.org> on 2025/12/05 17:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38788) flink-connector-mysql-cdc silently fails when unable to reconnect due to credentials rotation - posted by "supreetha (Jira)" <ji...@apache.org> on 2025/12/05 17:33:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38788) flink-connector-mysql-cdc silently fails when unable to reconnect due to credentials rotation - posted by "supreetha (Jira)" <ji...@apache.org> on 2025/12/05 17:37:00 UTC, 0 replies.
- [PR] FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP) [flink-kubernetes-operator] - posted by "schongloo (via GitHub)" <gi...@apache.org> on 2025/12/05 22:29:23 UTC, 0 replies.
- [jira] [Updated] (FLINK-36296) Add incremental shard discovery for DDB Streams source - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/06 06:53:00 UTC, 1 replies.
- [PR] Maximum parallelism expansion can be used in MAXIMIZE_UTILISATION mode. [flink-kubernetes-operator] - posted by "low-bee (via GitHub)" <gi...@apache.org> on 2025/12/07 09:13:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-37288) Add Google Cloud Spanner dialect and catalog - posted by "Tomoyuki NAKAMURA (Jira)" <ji...@apache.org> on 2025/12/07 10:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38771) Scalar arguments don't work with multi-table inputs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/12/07 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38789) Consistently use AssertJ-related assertion APIs to implement assertions in the HTTP connector - posted by "david radley (Jira)" <ji...@apache.org> on 2025/12/07 19:28:00 UTC, 0 replies.
- Re: [PR] [FLINK-37934][cdc-source-connectors] Get the case-sensitive variable names and method names of table id are not standardized, and need to be adjusted [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/08 00:05:29 UTC, 1 replies.
- Re: [PR] [hotfix] Cherry-pick a few fixes to 2.2 release [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/12/08 01:53:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38767) Fix vector_search transformation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/08 01:55:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38773) BatchExecVectorSearchTableFunction uses wrong context - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/08 01:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38773) BatchExecVectorSearchTableFunction uses wrong context - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/08 01:55:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38084) Update model provider download doc - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/08 01:56:00 UTC, 0 replies.
- Re: [PR] [FLINK-38046][Connector/JDBC]Solve the issue of missing one piece of data [flink-connector-jdbc] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/12/08 01:58:35 UTC, 0 replies.
- [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 2025/12/08 02:21:55 UTC, 0 replies.
- Re: [I] [Feature] [integration] [java] Integrate built-in Anthropic chat model [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/08 02:23:22 UTC, 1 replies.
- [PR] [integration] Remove unnecessary dependency flink-agents-plan for cha… [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/08 02:35:45 UTC, 0 replies.
- Re: [PR] [integration] Remove unnecessary dependency flink-agents-plan for chat model integration. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/08 03:36:35 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 2025/12/08 06:26:28 UTC, 0 replies.
- [jira] [Updated] (FLINK-38782) Mongodb CDC need a config to filter large size column - posted by "Joekwal (Jira)" <ji...@apache.org> on 2025/12/08 07:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38782) Mongodb CDC need a config to filter large size column - posted by "Joekwal (Jira)" <ji...@apache.org> on 2025/12/08 07:31:00 UTC, 2 replies.
- Re: [PR] [hotfix] Fix the type loss issue in the deserialization of ResourceProvider [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/08 07:59:13 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38790) Update Flink Connector Kafka to use Flink 2.2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/12/08 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38791) Add suppotr for ALTER MATERIALIZED TABLE MODIFY - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/08 08:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38791) Add support for ALTER MATERIALIZED TABLE MODIFY - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/08 08:56:00 UTC, 1 replies.
- [PR] [FLINK-38791][table] Add support for `ALTER MATERIALIZED TABLE MODIFY` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/08 09:00:26 UTC, 11 replies.
- [jira] [Created] (FLINK-38792) Properly support configuration parameters for Flink CDC UDFs - posted by "Hans-Peter Grahsl (Jira)" <ji...@apache.org> on 2025/12/08 09:03:00 UTC, 0 replies.
- [PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/12/08 09:14:04 UTC, 5 replies.
- [jira] [Updated] (FLINK-38790) Update Flink Connector Kafka to use Flink 2.2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/08 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38793) Reuse result of functions if ther are used multiple times as input for other functions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/08 09:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38793) Reuse result of functions if ther are used multiple times as input for other functions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/08 09:18:00 UTC, 2 replies.
- [PR] [FLINK-38793][table] Reuse result of functions if ther are used multiple times as input for other functions [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/08 09:23:41 UTC, 5 replies.
- [jira] [Updated] (FLINK-38792) Properly support configuration parameters for Flink CDC UDFs - posted by "Hans-Peter Grahsl (Jira)" <ji...@apache.org> on 2025/12/08 09:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38755) FLIP-549: Support Application Management - posted by "Jimmy Wang (Jira)" <ji...@apache.org> on 2025/12/08 10:06:00 UTC, 1 replies.
- Re: [PR] [hotfix] Fix maven-shade-plugin not printing included artifacts [flink-shaded] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/12/08 10:13:56 UTC, 0 replies.
- Re: [PR] [FLINK-38694] Update dependencies to latest versions [flink-shaded] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/12/08 10:14:27 UTC, 4 replies.
- [jira] [Updated] (FLINK-38694) Update Flink Shaded dependencies - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/08 10:15:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38794) Update Kafka Connector to Kafka 4.1.1 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/12/08 11:31:00 UTC, 0 replies.
- [PR] [paimon] Bump Paimon version to 1.3.1 [flink-cdc] - posted by "sd4324530 (via GitHub)" <gi...@apache.org> on 2025/12/08 12:38:01 UTC, 0 replies.
- [jira] [Created] (FLINK-38795) Do not use "--host" CLI param for standalone job - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/08 12:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38795) Do not use "--host" CLI param for standalone job - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/08 12:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38795) Do not use "--host" CLI param for standalone job - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/08 12:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-37607] Fix RpcEndpoint#MainThreadExecutor lost scheduling tasks when not running [flink] - posted by "Look-Y-Y (via GitHub)" <gi...@apache.org> on 2025/12/08 16:28:26 UTC, 0 replies.
- [PR] [FLINK-38794] Update to Kafka 4.1.1 [flink-connector-kafka] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/12/08 16:31:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-38794) Update Kafka Connector to Kafka 4.1.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/08 16:32:00 UTC, 0 replies.
- [I] [Feature] Update to Flink 2.2 [flink-agents] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2025/12/08 17:56:11 UTC, 1 replies.
- [jira] [Created] (FLINK-38796) UnresolvedMetadataColumn misses type during serializing to string - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/08 23:59:00 UTC, 0 replies.
- [PR] [FLINK-38796][table] UnresolvedMetadataColumn misses type during serializing to string [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/09 00:01:30 UTC, 3 replies.
- [jira] [Updated] (FLINK-38796) UnresolvedMetadataColumn misses type during serializing to string - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/09 00:02:00 UTC, 0 replies.
- Re: [PR] [pipeline-connector/paimon] Support table specific table.properties configuration [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/09 00:05:15 UTC, 0 replies.
- Re: [PR] [Connector/JDBC] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/12/09 03:49:48 UTC, 5 replies.
- Re: [PR] [FLINK-38784][pipeline-connector][paimon] Bump Paimon version to 1.3.1 [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/12/09 07:19:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38784) Bump the version of Paimon flink to 1.3.1 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/09 07:21:00 UTC, 0 replies.
- Re: [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-jdbc] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/12/09 07:49:08 UTC, 1 replies.
- [I] [Bug] RescalingITCase fails due to data loss [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/09 08:06:38 UTC, 4 replies.
- Re: [PR] [hotfix][Connector/JDBC] Support PostgreSQL uuid type [flink-connector-jdbc] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2025/12/09 08:47:59 UTC, 3 replies.
- [jira] [Assigned] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/12/09 09:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-38413] Adding support for append only tables to MySQL Pipeline connector [flink-cdc] - posted by "junmuz (via GitHub)" <gi...@apache.org> on 2025/12/09 15:12:48 UTC, 4 replies.
- [jira] [Updated] (FLINK-38413) Support Append Only table from MySQL Pipeline Connectors - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/09 15:13:00 UTC, 0 replies.
- [PR] [FLINK-37924][sql]Introduce Built-in Function to Access field or element in the Variant [flink] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2025/12/09 16:17:36 UTC, 0 replies.
- Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/12/09 16:30:47 UTC, 11 replies.
- [jira] [Commented] (FLINK-38796) UnresolvedMetadataColumn misses type during serializing to string - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/09 20:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38796) UnresolvedMetadataColumn misses type during serializing to string - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/09 20:49:00 UTC, 0 replies.
- Re: [PR] [hotfix] Make it compilable with Flink 2.0-preview [flink-connector-hive] - posted by "mattiaforc (via GitHub)" <gi...@apache.org> on 2025/12/09 23:08:48 UTC, 0 replies.
- Re: [PR] [draft] MySqlDatabaseSchema include gh-ost ddl in HistorizedRelationalDatabaseSchema [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/10 00:05:26 UTC, 0 replies.
- [jira] [Created] (FLINK-38797) PyFlink CsvSchemaBuilder.set_null_value method missing return self - posted by "Wren (Jira)" <ji...@apache.org> on 2025/12/10 01:07:00 UTC, 0 replies.
- Re: [D] Flink Agents Release Process [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/10 01:42:10 UTC, 2 replies.
- [jira] [Updated] (FLINK-38797) PyFlink CsvSchemaBuilder.set_null_value method missing return self - posted by "Wren (Jira)" <ji...@apache.org> on 2025/12/10 01:45:00 UTC, 2 replies.
- [PR] [FLINK-38797][python] Fixed PyFlink issue CsvSchemaBuilder.set_null_value missing return self [flink] - posted by "wchan87 (via GitHub)" <gi...@apache.org> on 2025/12/10 01:58:53 UTC, 5 replies.
- [jira] [Commented] (FLINK-38797) PyFlink CsvSchemaBuilder.set_null_value method missing return self - posted by "Wren (Jira)" <ji...@apache.org> on 2025/12/10 02:02:00 UTC, 0 replies.
- [PR] [doc] Update doc version to 0.1.1 [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/10 02:07:10 UTC, 1 replies.
- [PR] [runtime] Remove userCodeClassLoader field for ActionTask to fix can't be serialized to state. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/10 03:11:59 UTC, 1 replies.
- Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/12/10 05:42:20 UTC, 2 replies.
- Re: [PR] [FLINK-38345][flink-connector-base] Unit test to replicate null previousEnumerator for HybridSource on checkpoint recovery [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/10 06:26:32 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38531) MySQL CDC BinlogOffset compareTo method cannot work correctly when gtidSet is same, which may cause loss data when restored from gtid . - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/10 06:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35917) Failed to deserialize data of EventHeaderV4 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/10 07:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35917) Failed to deserialize data of EventHeaderV4 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/10 07:01:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/10 07:01:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/10 07:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38754) An unnecessary reverse DNS lookup when TaskManager connects to BlobServer - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/10 07:07:00 UTC, 0 replies.
- Re: [PR] [Feature][runtime] Support the use of Java ChatModel in Python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/10 07:57:23 UTC, 9 replies.
- [PR] [FLINK-38779] Route module supports standard RegExp replacement rules [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/12/10 09:45:35 UTC, 1 replies.
- Re: [PR] [hotfix][docs] Pull request to update documentation for Flink 2.0 support. [flink-kubernetes-operator] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/10 11:49:38 UTC, 1 replies.
- [jira] [Created] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases - posted by "Avi Sanwal (Jira)" <ji...@apache.org> on 2025/12/10 12:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases - posted by "Avi Sanwal (Jira)" <ji...@apache.org> on 2025/12/10 12:10:00 UTC, 4 replies.
- [PR] FLINK-38785: Fixing the quotes issue with variable concatenation [flink] - posted by "junmuz (via GitHub)" <gi...@apache.org> on 2025/12/10 12:33:16 UTC, 2 replies.
- [jira] [Updated] (FLINK-38785) Quotes removal doesn't remove them properly - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/10 12:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-38696] Replace custom RateLimiterStrategy with built-in in KafkaSinkITCase [flink-connector-kafka] - posted by "zackary-naas (via GitHub)" <gi...@apache.org> on 2025/12/10 13:15:43 UTC, 0 replies.
- [jira] [Created] (FLINK-38799) Rename "LoadingWeight" to "ResourceUnitCount" - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/10 13:53:00 UTC, 0 replies.
- [PR] [FLINK-38799][runtime] Rename `LoadingWeight` to `ResourceUnitCount` [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/12/10 14:05:27 UTC, 3 replies.
- [jira] [Updated] (FLINK-38799) Rename "LoadingWeight" to "ResourceUnitCount" - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/10 14:06:00 UTC, 0 replies.
- [PR] [FLINK-38770] Fix parallelism overrides ignored in Application Mode [flink] - posted by "barakbaron12 (via GitHub)" <gi...@apache.org> on 2025/12/10 15:00:37 UTC, 0 replies.
- [jira] [Updated] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/10 15:01:00 UTC, 0 replies.
- Re: [PR] [FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/12/10 15:05:04 UTC, 2 replies.
- [jira] [Created] (FLINK-38800) Add a maven submodule for Flink MCP server. - posted by "ChaomingZhang (Jira)" <ji...@apache.org> on 2025/12/10 16:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38800) Add a maven submodule for Flink MCP server. - posted by "ChaomingZhang (Jira)" <ji...@apache.org> on 2025/12/10 16:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-35137][Connectors/JDBC] Update website data for 3.2.0 [flink-connector-jdbc] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/12/10 16:38:19 UTC, 1 replies.
- [jira] [Created] (FLINK-38801) Add Spotless plugin with Google AOSP style for flink benchmark repository - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/12/10 16:58:00 UTC, 0 replies.
- Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] - posted by "AndyShoeshim (via GitHub)" <gi...@apache.org> on 2025/12/10 18:19:25 UTC, 0 replies.
- [jira] [Created] (FLINK-38802) DDL with duplicated keys in table options should fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/10 21:09:00 UTC, 0 replies.
- [PR] [FLINK-38802][table] DDL with duplicated keys in table options should fail while validation [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/10 21:11:50 UTC, 5 replies.
- [jira] [Updated] (FLINK-38802) DDL with duplicated keys in table options should fail - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/10 21:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/11 00:05:34 UTC, 0 replies.
- Re: [PR] [FLINK-36580][pipeline-connector-mysql] Fix column.[in|ex]clude.list parameter causing schema inconsistency [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/11 00:05:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-38786) Does support oracle-cdc partitioned table now ? - posted by "laixiong (Jira)" <ji...@apache.org> on 2025/12/11 03:06:00 UTC, 0 replies.
- [PR] [ci] Add java 17 pipeline for java ut and it. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/11 06:13:53 UTC, 1 replies.
- [jira] [Closed] (FLINK-36296) Add incremental shard discovery for DDB Streams source - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/11 06:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/12/11 07:14:39 UTC, 6 replies.
- Re: [PR] [FLINK-37739][cli] fix flink-conf is not obtained in local mode [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/12/11 07:16:06 UTC, 1 replies.
- [I] [Feature] Support async execution for built-in actions [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/11 08:43:09 UTC, 0 replies.
- Re: [PR] [hotfix] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-jdbc] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/12/11 09:22:15 UTC, 3 replies.
- [jira] [Created] (FLINK-38803) Add UNABLE_TO_DESERIALIZE_RESPONSE http-completion-state. - posted by "david radley (Jira)" <ji...@apache.org> on 2025/12/11 10:00:00 UTC, 0 replies.
- Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] - posted by "FranMorilloAWS (via GitHub)" <gi...@apache.org> on 2025/12/11 10:06:45 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 2025/12/11 10:23:00 UTC, 4 replies.
- [jira] [Created] (FLINK-38804) The shutdown sequence is incorrect causes TaskManager is shutting down - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/12/11 10:23:00 UTC, 0 replies.
- [PR] [hotfix] Try to stabilize the flaky integration tests [flink-connector-jdbc] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/12/11 10:47:31 UTC, 7 replies.
- [PR] FLINK-38803 add deserialize completion state [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/11 10:55:09 UTC, 2 replies.
- [jira] [Updated] (FLINK-38803) Add UNABLE_TO_DESERIALIZE_RESPONSE http-completion-state. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/11 10:56:00 UTC, 2 replies.
- Re: [PR] [hotfix] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] - posted by "och5351 (via GitHub)" <gi...@apache.org> on 2025/12/11 15:09:58 UTC, 11 replies.
- [PR] [BP-2.1][FLINK-38486] Harden shutdown of system UDFs [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/12/11 15:32:38 UTC, 5 replies.
- [jira] [Reopened] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/11 15:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/12/11 15:39:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/11 15:39:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-38486] Harden shutdown of system UDFs [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/12/11 15:39:02 UTC, 7 replies.
- [jira] [Updated] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/12/11 15:40:00 UTC, 1 replies.
- [PR] [FLINK-36026][table] Options from `OPTIONS` hint should be present in compiled plan [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/12/11 15:42:41 UTC, 0 replies.
- [PR] [FLINK-38486] Harden shutdown of system UDFs [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/12/11 15:45:22 UTC, 1 replies.
- Re: [PR] [backport][FLINK-36026][table] Options from `OPTIONS` hint should be present in compiled plan [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/12/11 15:50:06 UTC, 2 replies.
- [jira] [Closed] (FLINK-38781) pass format options to the http response - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/11 15:58:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38781) pass format options to the http response - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/11 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38805) Flaky test cases in JDBC connector. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/12/12 01:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38805) Flaky test cases in JDBC connector. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/12/12 01:46:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38805) Flaky test cases in JDBC connector. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/12/12 01:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38805) OceanBase container start up failed in JDBC connector - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/12/12 01:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38805) OceanBase container start up failed in JDBC connector - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/12/12 01:55:00 UTC, 1 replies.
- Re: [PR] [client] optimise JobStatusPollingUtils of pollJobResultAsync [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/12 06:26:26 UTC, 1 replies.
- Re: [PR] Update japicmp configuration for 2.1.0 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/12 06:26:28 UTC, 1 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 2025/12/12 06:26:32 UTC, 0 replies.
- Re: [I] [Feature] Support the use of Python ChatModel in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/12 06:42:40 UTC, 0 replies.
- [I] [Feature][doc] Add document on how to use cross-language resources. [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/12 06:47:48 UTC, 0 replies.
- [jira] [Created] (FLINK-38806) Pipeline post-transform converters ineffective without a projection rule - posted by "yux (Jira)" <ji...@apache.org> on 2025/12/12 07:08:00 UTC, 0 replies.
- [PR] [FLINK-38806] Fix post-transform converters ineffective without projection or filter rules [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/12/12 07:10:06 UTC, 1 replies.
- [jira] [Updated] (FLINK-38806) Pipeline post-transform converters ineffective without a projection rule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/12 07:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] - posted by "Savonitar (via GitHub)" <gi...@apache.org> on 2025/12/12 11:59:46 UTC, 0 replies.
- Re: [PR] [BP-1.19][FLINK-38486] Harden shutdown of system UDFs [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/12/12 13:17:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-38210) s5cmd somtimes fails due to path starting with s3p:// - posted by "Zackary Naas (Jira)" <ji...@apache.org> on 2025/12/12 15:00:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38210) s5cmd somtimes fails due to path starting with s3p:// - posted by "Zackary Naas (Jira)" <ji...@apache.org> on 2025/12/12 15:01:00 UTC, 0 replies.
- Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/12/12 15:03:57 UTC, 6 replies.
- [jira] [Updated] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/12 15:05:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/12 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38807) Add state SQL metadata type inference - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/12/12 20:30:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38807) Add state SQL metadata type inference - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/12/12 20:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38807) Add state SQL metadata based type inference - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/12/12 20:42:00 UTC, 1 replies.
- [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/12/12 21:22:40 UTC, 7 replies.
- [jira] [Commented] (FLINK-38699) Order the WebUI's Completed Job List by end time order - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/13 09:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/14 00:05:36 UTC, 0 replies.
- Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/14 00:05:38 UTC, 0 replies.
- Re: [PR] [FLINK-36842] FlinkPipelineComposer allows injecting StreamExecutionEnvironment [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/14 00:05:45 UTC, 1 replies.
- Re: [PR] Reuse byte array buffer in BlobServerConnection::run [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/14 06:26:03 UTC, 0 replies.
- [PR] Flink Version upgrade 2.3-SNAPSHOT [flink-agents] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2025/12/14 07:44:40 UTC, 2 replies.
- Re: [PR] [FLINK-37855-][cdc-connector-mysql] Reduce the time cost in MySqlSchemaUtils#listTables [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/15 00:05:31 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38797) PyFlink CsvSchemaBuilder.set_null_value method missing return self - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/12/15 01:43:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38797) PyFlink CsvSchemaBuilder.set_null_value method missing return self - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/12/15 01:44:00 UTC, 0 replies.
- Re: [PR] Implement comma-separated parsing for chunk key columns [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/12/15 02:32:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/12/15 05:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38808) Support partition transforms in Iceberg sink - posted by "ChaoFang (Jira)" <ji...@apache.org> on 2025/12/15 06:20:00 UTC, 0 replies.
- [PR] [FLINK-38808][pipeline-connector][iceberg] Support partition transforms in Iceberg sink [flink-cdc] - posted by "fcfangcc (via GitHub)" <gi...@apache.org> on 2025/12/15 06:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38808) Support partition transforms in Iceberg sink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/15 06:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/15 06:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/12/15 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38809) Update testcontainers to 2.0.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/12/15 09:47:00 UTC, 0 replies.
- [PR] [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.2 [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/12/15 09:54:35 UTC, 5 replies.
- [jira] [Updated] (FLINK-38809) Update testcontainers to 2.0.2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/15 09:55:00 UTC, 0 replies.
- [PR] [hotfix] Adapt supported Python versions to Flink 1.20 [flink-connector-aws] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/12/15 13:14:34 UTC, 2 replies.
- [jira] [Closed] (FLINK-38765) Sink Upsert Materializer does not work with metadata columns - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/12/15 13:45:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/15 15:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/15 15:15:00 UTC, 0 replies.
- [PR] [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/12/15 15:24:51 UTC, 1 replies.
- [PR] [BP-2.0][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/12/15 15:27:37 UTC, 2 replies.
- [PR] [BP-1.19][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/12/15 15:29:41 UTC, 2 replies.
- [jira] [Updated] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/15 15:31:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/15 15:31:00 UTC, 0 replies.
- Re: [PR] [BP-2.1][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/12/15 15:33:26 UTC, 1 replies.
- [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "Oleksandr Nitavskyi (Jira)" <ji...@apache.org> on 2025/12/15 15:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38810) Use splittable timers in Interval Join - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/15 16:45:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38810) Use splittable timers in Interval Join - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/15 16:45:00 UTC, 0 replies.
- [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/12/15 17:01:35 UTC, 2 replies.
- [jira] [Commented] (FLINK-38791) Add support for ALTER MATERIALIZED TABLE MODIFY - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/15 19:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38791) Add support for ALTER MATERIALIZED TABLE MODIFY - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/15 19:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38776) Incorrect auxiliary group field names - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/15 20:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38811) Translate async function doc to Chinese - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/12/15 23:06:00 UTC, 0 replies.
- [PR] [FLINK-38811] translate async scalar function doc to Chinese [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/12/15 23:49:39 UTC, 2 replies.
- [jira] [Updated] (FLINK-38811) Translate async function doc to Chinese - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/15 23:50:00 UTC, 0 replies.
- Re: [PR] [FLINK-37275][pipeline-connector/mysql] MySQL source connector supports using the base module's source metric statistics [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/16 00:06:13 UTC, 1 replies.
- [jira] [Closed] (FLINK-38757) Introduce the base class for application - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/16 02:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36609) Protobuf Format not support proto3 - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/12/16 06:30:00 UTC, 1 replies.
- [PR] [FLINK-38802][table] DDL with duplicated keys in table options should not fail [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/16 08:55:25 UTC, 7 replies.
- [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/16 09:41:24 UTC, 0 replies.
- Re: [PR] [FLINK-38181] Fix code generation for primitive type casting and improve cast consistency across compile-time and runtime paths [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/12/16 10:19:39 UTC, 0 replies.
- Re: [PR] [FLINK-38048] Update java version and move parent pom to v1.2.0 [flink-connector-shared-utils] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/16 10:35:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled - posted by "Liu (Jira)" <ji...@apache.org> on 2025/12/16 11:25:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled - posted by "Liu (Jira)" <ji...@apache.org> on 2025/12/16 11:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38802) DDL with duplicated keys in table options should not fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/16 13:03:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38802) DDL with duplicated keys in table options should not fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/16 13:04:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38802) DDL with duplicated keys in table options should not fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/12/16 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38813) Enable Flink CDC connector to emit Debezium heartbeat events to downstream consumers - posted by "Tejansh Rana (Jira)" <ji...@apache.org> on 2025/12/16 14:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38813) Enable Flink CDC connector to emit Debezium heartbeat events to downstream consumers - posted by "Tejansh Rana (Jira)" <ji...@apache.org> on 2025/12/16 14:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38813) Enable Flink CDC connectors to emit Debezium heartbeat events to downstream consumers - posted by "Tejansh Rana (Jira)" <ji...@apache.org> on 2025/12/16 14:34:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38049) UpgradeMode falls back to last-state mode on HA resubmission even for stateless - posted by "Lucas Borges (Jira)" <ji...@apache.org> on 2025/12/16 15:26:00 UTC, 0 replies.
- [PR] [PROPOSAL][FLINK-38813] : Support for emitting heartbeat events [flink-cdc] - posted by "tejanshrana (via GitHub)" <gi...@apache.org> on 2025/12/16 15:30:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/16 17:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/12/16 17:17:00 UTC, 0 replies.
- Re: [PR] [FLINK-37811][Build/Shaded] Update Curator to 5.8.0 [flink-shaded] - posted by "arunlakshman (via GitHub)" <gi...@apache.org> on 2025/12/16 21:46:48 UTC, 2 replies.
- [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 2025/12/17 07:51:27 UTC, 3 replies.
- [jira] [Updated] (FLINK-38801) Add Spotless plugin with Google AOSP style for flink benchmark repository - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/17 07:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38811) Translate async function doc to Chinese - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/17 08:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38811) Translate async function doc to Chinese - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/17 08:32:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38811) Translate async function doc to Chinese - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/12/17 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure - posted by "Juliusz Nadberezny (Jira)" <ji...@apache.org> on 2025/12/17 09:17:00 UTC, 0 replies.
- Re: [PR] [FLINK-34257][core] Update Flink YAML Parser to Support YAML 1.2 Specification. [flink] - posted by "asomov (via GitHub)" <gi...@apache.org> on 2025/12/17 09:17:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure - posted by "Juliusz Nadberezny (Jira)" <ji...@apache.org> on 2025/12/17 09:18:00 UTC, 4 replies.
- Re: [PR] [FLINK-34088] [hotfix] fix the problems with special table name characters of postgres and oracle and sqlserver. [flink-connector-jdbc] - posted by "fengzhi09 (via GitHub)" <gi...@apache.org> on 2025/12/17 09:37:43 UTC, 0 replies.
- [PR] [Flink-388814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] - posted by "nadberezny (via GitHub)" <gi...@apache.org> on 2025/12/17 09:47:21 UTC, 0 replies.
- [I] [Feature] Add document for Elasticsearch VectorStore integration [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/17 11:03:01 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 2025/12/17 11:04:31 UTC, 0 replies.
- [jira] [Created] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager - posted by "dengxaing (Jira)" <ji...@apache.org> on 2025/12/17 12:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager - posted by "dengxaing (Jira)" <ji...@apache.org> on 2025/12/17 12:30:00 UTC, 4 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 "dengxaing (Jira)" <ji...@apache.org> on 2025/12/17 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38816) HTTP Connector : Change deserialize method invocation so can work with Flink 2 - posted by "david radley (Jira)" <ji...@apache.org> on 2025/12/17 13:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38816) HTTP Connector : Change deserialize method invocation so can work with Flink 2 - posted by "david radley (Jira)" <ji...@apache.org> on 2025/12/17 13:38:00 UTC, 0 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 2025/12/17 14:50:04 UTC, 2 replies.
- [jira] [Created] (FLINK-38817) Out of order data seen while running tpc-ds queries - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2025/12/18 00:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38817) Out of order data seen while running tpc-ds queries - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2025/12/18 00:25:00 UTC, 1 replies.
- [PR] [hotfix][metrics] Fix NullArgumentException when calculating checkpoint statistics with empty data [flink] - posted by "qiref (via GitHub)" <gi...@apache.org> on 2025/12/18 02:22:37 UTC, 4 replies.
- Re: [I] [Feature] Introduce Long-Term Memory in Python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/18 02:23:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-38813) Enable Flink CDC connectors to emit Debezium heartbeat events to downstream consumers - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/18 03:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38813) Enable Flink CDC connectors to emit Debezium heartbeat events to downstream consumers - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/18 03:54:00 UTC, 0 replies.
- Re: [I] [Feature][Doc] Add document for Elasticsearch VectorStore integration [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/12/18 04:49:20 UTC, 1 replies.
- Re: [PR] [FLINK-30935][connector/kafka] Add kafka serializers version check when using SimpleVersionedSerializer [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:26:22 UTC, 1 replies.
- Re: [PR] [FLINK-32522][connectors/kafka] Kafka connector should depend on commons-collections instead of inheriting from flink [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:26:26 UTC, 1 replies.
- Re: [PR] [FLINK-32743][Connectors/Kafka] Parse data from kafka connect and convert it into regular JSON data [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:26:31 UTC, 1 replies.
- Re: [PR] [FLINK-32893][Connectors/Kafka] Allow the clientid to be fully configurable [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:26:36 UTC, 1 replies.
- Re: [PR] [hotfix][docs] Fix scan.bounded.mode missing forward options [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:26:41 UTC, 1 replies.
- Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from junit4 to junit5 [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:26:45 UTC, 1 replies.
- Re: [PR] [hotfix][docs] refer to kafka_sasl_ssl_example in the docs [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:26:49 UTC, 1 replies.
- Re: [PR] [FLINK-33545][Connectors/Kafka] KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:26:53 UTC, 1 replies.
- Re: [PR] [FLINK-33466][Connectors/Kafka]: Bounded Kafka source never finishes after restore from savepoint [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:26:58 UTC, 1 replies.
- Re: [PR] [FLINK-25509][connector/kafka] Add RecordEvaluator to dynamically stop source based on de-serialized records [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:02 UTC, 1 replies.
- Re: [PR] FLINK-31361 - Added the right shaded dependency for SQL client connector for kafka - Updated kafka.md [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:09 UTC, 1 replies.
- Re: [PR] [FLINK-34996][Connectors/Kafka] Use UserCodeCL to instantiate Deserializer [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:14 UTC, 1 replies.
- Re: [PR] [FLINK-34995] flink kafka connector source stuck when partition leade… [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:18 UTC, 1 replies.
- Re: [PR] [FLINK-34127] Upgrade to flink-connector-parent 1.1.0 to exclude runn… [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:23 UTC, 1 replies.
- Re: [PR] [FLINK-35283] PoC for supporting unique Kafka producer client ids [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:28 UTC, 1 replies.
- Re: [PR] [FLINK-35404] Report all metrics of KafkaConsumer in new Kafka source [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:32 UTC, 1 replies.
- Re: [PR] [FLINK-35632] Fix the example provided in the kafkaSource documentation for topic regex subscription [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:37 UTC, 1 replies.
- Re: [PR] [FLINK-35631] enable dynamic partition discovery by default in CONTINUOUS_UNBOUNDED mode [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:44 UTC, 1 replies.
- Re: [PR] [FLINK-35870] Change DEFAULT_KAFKA_TRANSACTION_TIMEOUT in KafkaSinkBuilder [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:48 UTC, 1 replies.
- Re: [PR] [FLINK-28842] add client.id.prefix for kafka sink [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:55 UTC, 1 replies.
- Re: [PR] [FLINK-36817] Introduce KafkaConsumerFactory [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:27:59 UTC, 1 replies.
- Re: [PR] fix DynamicKafkaRecordSerializationSchema, add serialVersionUID [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:28:07 UTC, 1 replies.
- Re: [PR] [FLINK-XXX] Add set_deserializer method to Python KafkaSourceBuilder [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:28:10 UTC, 1 replies.
- Re: [PR] [FLINK-37366] Allow configurable retry for Kafka topic metadata fetch [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/18 06:28:14 UTC, 1 replies.
- [jira] [Commented] (FLINK-38817) Out of order data seen while running tpc-ds queries - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/18 07:23:00 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-38817) Out of order data seen while running tpc-ds queries - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/18 07:24:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38818) [posgtresql]Build createTableEventCache using TableSchemas from split and Make transform operator stateless - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/12/18 07:33:00 UTC, 0 replies.
- [PR] [ci] Move the cross-language resource tests from the Python IT Test to the cross-language CI test [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/18 07:53:10 UTC, 4 replies.
- [jira] [Commented] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure - posted by "Juliusz Nadberezny (Jira)" <ji...@apache.org> on 2025/12/18 09:01:00 UTC, 0 replies.
- [PR] [FLINK-38818] [posgtresql]Build createTableEventCache using TableSchemas from split and Make transform operator stateless [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/12/18 09:21:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-38818) [posgtresql]Build createTableEventCache using TableSchemas from split and Make transform operator stateless - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/18 09:22:00 UTC, 0 replies.
- [PR] [FLINK-38816] use Flink 2 compatible deserialise [flink-connector-http] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/12/18 09:50:22 UTC, 1 replies.
- [jira] [Updated] (FLINK-38816) HTTP Connector : Change deserialize method invocation so can work with Flink 2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/18 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38819) Make Flink JSON deserialization schema log parsing errors - posted by "Santwana Verma (Jira)" <ji...@apache.org> on 2025/12/18 10:56:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38819) Make Flink JSON deserialization schema log parsing errors - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/12/18 10:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38819) Make Flink JSON deserialization schema log parsing errors - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/12/18 11:53:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-38819) Make Flink JSON deserialization schema log parsing errors - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/12/18 11:54:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38819) Make Flink JSON deserialization schema log parsing errors - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/12/18 12:14:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-38519) Custom Message Keys with PyFlink Kafka Sink - posted by "Sebastian YEPES FERNANDEZ (Jira)" <ji...@apache.org> on 2025/12/18 13:37:00 UTC, 1 replies.
- [PR] feat: Add GaussDB CDC connector with critical bug fixes [flink-cdc] - posted by "liumingjian (via GitHub)" <gi...@apache.org> on 2025/12/18 14:46:44 UTC, 0 replies.
- [jira] [Reopened] (FLINK-38738) Incorrect UID for DataStreamScanProvider and TransformationScanProvider - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/12/18 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38820) Move ptf rules to rule folder - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/12/18 19:44:00 UTC, 0 replies.
- [PR] [FLINK-38820] Move ptf rule to rule folder [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/12/18 19:48:34 UTC, 2 replies.
- [jira] [Updated] (FLINK-38820) Move ptf rules to rule folder - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/18 19:49:00 UTC, 0 replies.
- Re: [PR] [FLINK-38530] create Dynamic Kafka Source for pyflink [flink-connector-kafka] - posted by "bowenli-oai (via GitHub)" <gi...@apache.org> on 2025/12/18 23:54:01 UTC, 0 replies.
- Re: [PR] [FLINK-37630] Support flink cdc pipeline Yarn session mode [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/19 00:05:46 UTC, 1 replies.
- [jira] [Created] (FLINK-38821) Add TaskManager creation/deletion metrics to Active Resource Manager - posted by "moonyoung (Jira)" <ji...@apache.org> on 2025/12/19 01:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38821) Add TaskManager creation/deletion metrics to Active Resource Manager - posted by "moonyoung (Jira)" <ji...@apache.org> on 2025/12/19 01:47:00 UTC, 0 replies.
- [PR] [FLINK-38760][runtime] Add REST APIs for application query and cancellation [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2025/12/19 02:00:12 UTC, 5 replies.
- [jira] [Updated] (FLINK-38760) Add REST APIs for application query and cancellation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/19 02:01:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38822) Extend URL_DECODE with a recursive parameter for multi-level decoding - posted by "featzhang (Jira)" <ji...@apache.org> on 2025/12/19 02:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38822) Extend URL_DECODE with a recursive parameter for multi-level decoding - posted by "featzhang (Jira)" <ji...@apache.org> on 2025/12/19 02:30:00 UTC, 1 replies.
- Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2025/12/19 03:04:50 UTC, 0 replies.
- [PR] [cdc-connector-mysql] Add MySQL 8.4+ compatibility for binlog status command [flink-cdc] - posted by "sunlicp (via GitHub)" <gi...@apache.org> on 2025/12/19 06:47:28 UTC, 0 replies.
- [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents] - posted by "KaranShishodia (via GitHub)" <gi...@apache.org> on 2025/12/19 06:48:04 UTC, 5 replies.
- [jira] [Assigned] (FLINK-38818) [posgtres-cdc] Emit initial table schemas from state - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/12/19 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38818) [posgtres-cdc] Emit initial table schemas from state - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/12/19 07:18:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-38758) Introduce PackagedProgramApplication - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/19 07:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-36816] Support source parallelism setting for JDBC connector [flink-connector-jdbc] - posted by "grzegorz8 (via GitHub)" <gi...@apache.org> on 2025/12/19 07:54:47 UTC, 0 replies.
- [jira] [Created] (FLINK-38823) Error running wide table task - posted by "peiyu (Jira)" <ji...@apache.org> on 2025/12/19 08:36:00 UTC, 0 replies.
- Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/12/19 08:45:48 UTC, 3 replies.
- [jira] [Updated] (FLINK-38742) Postgres CDC pipeline fails when there is column of type TIMESTAMPTZ (timestamp with timezone) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/19 08:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38823) Error running wide table task - posted by "peiyu (Jira)" <ji...@apache.org> on 2025/12/19 08:46:00 UTC, 1 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 2025/12/19 10:54:27 UTC, 0 replies.
- [PR] [FLINK-38822] Extend URL_DECODE with optional recursive decoding [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2025/12/19 11:02:05 UTC, 1 replies.
- [PR] [FLINK-38738][table] Expose more context in table connectors to correct UID [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/12/19 12:16:17 UTC, 3 replies.
- [jira] (FLINK-38822) Extend URL_DECODE with a recursive parameter for multi-level decoding - posted by "featzhang (Jira)" <ji...@apache.org> on 2025/12/19 15:06:00 UTC, 0 replies.
- [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.1 to 2.25.3 in /flink-connector-cassandra [flink-connector-cassandra] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/19 22:54:36 UTC, 1 replies.
- [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.2 to 2.25.3 [flink-connector-rabbitmq] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/19 23:13:18 UTC, 0 replies.
- [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.2 to 2.25.3 [flink-connector-jdbc] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/19 23:13:36 UTC, 0 replies.
- [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.2 to 2.25.3 [flink-connector-mongodb] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/19 23:14:00 UTC, 0 replies.
- [PR] Bump org.apache.logging.log4j:log4j-core from 2.23.1 to 2.25.3 [flink-connector-gcp-pubsub] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/19 23:44:50 UTC, 0 replies.
- [PR] Bump org.apache.logging.log4j:log4j-core from 2.23.1 to 2.25.3 [flink-connector-kudu] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/19 23:45:09 UTC, 0 replies.
- [PR] Bump org.apache.logging.log4j:log4j-core from 2.24.1 to 2.25.3 [flink-connector-opensearch] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/19 23:51:09 UTC, 0 replies.
- [PR] Bump org.apache.logging.log4j:log4j-core from 2.25.0 to 2.25.3 [flink-connector-kafka] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/12/19 23:55:23 UTC, 0 replies.
- Re: [PR] [improvement] adding runtime converter array [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/20 00:05:13 UTC, 0 replies.
- [PR] [FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization [flink] - posted by "Nflrijal (via GitHub)" <gi...@apache.org> on 2025/12/20 11:01:29 UTC, 1 replies.
- [jira] [Updated] (FLINK-38189) Allow it to sink data to Kafka partitions based on KEY in PyFlink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/20 11:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-38250] The Flink CDC type supports the timeTZ field type. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/21 00:05:27 UTC, 0 replies.
- [jira] [Created] (FLINK-38824) Incorrect default values for primitive types - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/12/21 06:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38824) Incorrect default values for primitive types - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/12/21 06:39:00 UTC, 5 replies.
- [PR] [FLINK-38824][table] Fix incorrect default values for primitive types [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/12/21 07:21:41 UTC, 8 replies.
- Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] - posted by "gaaraG (via GitHub)" <gi...@apache.org> on 2025/12/21 08:28:39 UTC, 4 replies.
- [jira] [Commented] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads - posted by "featzhang (Jira)" <ji...@apache.org> on 2025/12/21 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads - posted by "featzhang (Jira)" <ji...@apache.org> on 2025/12/21 08:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads - posted by "featzhang (Jira)" <ji...@apache.org> on 2025/12/21 08:54:00 UTC, 3 replies.
- [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2025/12/21 09:42:39 UTC, 1 replies.
- [PR] [FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2025/12/21 10:18:34 UTC, 1 replies.
- [PR] [FLINK-38825][streaming] Add ordered async batch support for AsyncBatchWaitOperator [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2025/12/21 10:32:15 UTC, 1 replies.
- [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2025/12/21 11:32:21 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38824) Incorrect default values for primitive types - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/12/21 14:18:00 UTC, 0 replies.
- Re: [PR] [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.3 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/12/21 18:43:51 UTC, 0 replies.
- [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2025/12/22 01:04:25 UTC, 1 replies.
- [PR] [FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2025/12/22 01:24:04 UTC, 1 replies.
- [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] - posted by "featzhang (via GitHub)" <gi...@apache.org> on 2025/12/22 01:35:23 UTC, 1 replies.
- [PR] [api][runtime] Support use long-term memory in action and async compaction. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/22 06:00:29 UTC, 2 replies.
- Re: [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/22 06:26:26 UTC, 0 replies.
- [I] [Feature] Update release infra to support multi-jdk version [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/22 06:28:21 UTC, 0 replies.
- [jira] [Created] (FLINK-38826) Add new ArgumentStrategy to support array with specified element type - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/12/22 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2025/12/22 11:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38827) [Draft] NullPointerException and job restart when consuming from DynamoDB CDC - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2025/12/22 11:57:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2025/12/22 12:04:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2025/12/22 12:04:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/12/22 12:15:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38824) Incorrect default values for primitive types - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/12/22 12:56:00 UTC, 0 replies.
- Re: [PR] [hotfix][runtime] Minor polish for the parameter naming of ExecutionGraphWithVertexParallelism#create. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/12/22 15:12:59 UTC, 1 replies.
- Re: [PR] [FLINK-37503] Compatibility Issue with MySQL Syntax SHOW MASTER STATUS [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/23 00:05:26 UTC, 1 replies.
- [jira] [Created] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint - posted by "Vinay Sagar Gonabavi (Jira)" <ji...@apache.org> on 2025/12/23 01:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint - posted by "Vinay Sagar Gonabavi (Jira)" <ji...@apache.org> on 2025/12/23 01:09:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38829) Support rename column DDL for starrocks sink connector - posted by "Mingliang Zhu (Jira)" <ji...@apache.org> on 2025/12/23 01:11:00 UTC, 0 replies.
- [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] - posted by "zml1206 (via GitHub)" <gi...@apache.org> on 2025/12/23 01:18:20 UTC, 4 replies.
- [jira] [Updated] (FLINK-38829) Support rename column DDL for starrocks sink connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/23 01:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint - posted by "Vinay Sagar Gonabavi (Jira)" <ji...@apache.org> on 2025/12/23 01:35:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better - posted by "Vinay Sagar Gonabavi (Jira)" <ji...@apache.org> on 2025/12/23 01:55:00 UTC, 0 replies.
- [PR] [FLINK-38762][runtime] Introduce SingleJobApplication [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2025/12/23 02:03:38 UTC, 2 replies.
- [jira] [Updated] (FLINK-38762) Introduce SingleJobApplication - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/23 02:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38432) Missing finish/reset for keyWriter/valueWriter in ArrowMapWriter - posted by "Zhe Wang (Jira)" <ji...@apache.org> on 2025/12/23 02:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/12/23 04:18:48 UTC, 0 replies.
- [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/12/23 06:42:30 UTC, 5 replies.
- [jira] [Created] (FLINK-38831) The route configuration supports matching the first one - posted by "peiyu (Jira)" <ji...@apache.org> on 2025/12/23 07:11:00 UTC, 0 replies.
- [PR] [BP-1.20][FLINK-38824][table] Fix incorrect default values for primitive types [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/12/23 07:25:41 UTC, 2 replies.
- [jira] [Commented] (FLINK-38375) Flink Resouce leak on Flink k8s - posted by "xiaolong3817 (Jira)" <ji...@apache.org> on 2025/12/23 09:24:00 UTC, 1 replies.
- Re: [PR] [FLINK-38818] [posgtresql]Build createTableEventCache using TableSchemas from split [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/12/23 09:57:39 UTC, 1 replies.
- Re: [PR] [FLINK-38813] : Support for emitting heartbeat events [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/12/23 10:57:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36313) Support pipeline sink hudi - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/23 11:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36313) Support pipeline sink hudi - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/23 11:00:02 UTC, 2 replies.
- [jira] [Resolved] (FLINK-38813) Enable Flink CDC connectors to emit Debezium heartbeat events to downstream consumers - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/23 11:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38829) Support rename column DDL for starrocks sink connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/23 11:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/12/23 11:48:48 UTC, 6 replies.
- [jira] [Assigned] (FLINK-38694) Update Flink Shaded dependencies - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/12/23 13:32:00 UTC, 0 replies.
- Re: [I] upgrade flink 1.20 [flink-shaded] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/12/23 13:32:14 UTC, 1 replies.
- Re: [I] Issue with Flink Application Mode args – Custom Command Not Executing as Expected [flink-shaded] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/12/23 13:32:23 UTC, 1 replies.
- [jira] [Closed] (FLINK-38694) Update Flink Shaded dependencies - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/12/23 13:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38694) Update Flink Shaded dependencies - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/12/23 13:36:00 UTC, 0 replies.
- [PR] [hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35 [flink-shaded] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/12/23 13:52:04 UTC, 1 replies.
- [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] - posted by "zflynn-mdsol (via GitHub)" <gi...@apache.org> on 2025/12/23 22:56:17 UTC, 6 replies.
- [jira] [Commented] (FLINK-38831) The route configuration supports matching the first one - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/12/24 02:37:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38832) Planner of count(*) changes - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/12/24 02:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38832) Planner of count(*) changes - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/12/24 02:47:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/12/24 02:51:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38832) Projection pushdown of count(*) in planner changes - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/12/24 02:58:00 UTC, 0 replies.
- [I] [Feature] Add metrics to record the token usage [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/24 03:44:05 UTC, 1 replies.
- [jira] [Created] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization - posted by "peiyu (Jira)" <ji...@apache.org> on 2025/12/24 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38834) Support modify column type DDL for starrocks sink connector - posted by "Mingliang Zhu (Jira)" <ji...@apache.org> on 2025/12/24 04:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38834) Support alter column type DDL for starrocks sink connector - posted by "Mingliang Zhu (Jira)" <ji...@apache.org> on 2025/12/24 04:12:00 UTC, 1 replies.
- [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] - posted by "zml1206 (via GitHub)" <gi...@apache.org> on 2025/12/24 04:22:34 UTC, 12 replies.
- [jira] [Created] (FLINK-38835) When using postgresql cdc to read timestamp data with a value of 1900-01-01, abnormal data occurred - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/24 05:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38836) Chinese documentation for pipeline configuration options is missing. - posted by "peiyu (Jira)" <ji...@apache.org> on 2025/12/24 05:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38831) The route configuration supports matching the first one - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/12/24 06:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/24 06:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/24 06:19:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36313) Support pipeline sink hudi - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/24 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/24 06:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/12/24 06:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36797) hudi sink supports pipeline configuration connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/24 06:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2025/12/24 06:50:00 UTC, 1 replies.
- Re: [PR] [Draft] support overriding autoscaling scaling realizer via plugins [flink-kubernetes-operator] - posted by "ctrlaltdilj (via GitHub)" <gi...@apache.org> on 2025/12/24 07:01:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/24 07:12:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/12/24 07:26:00 UTC, 0 replies.
- [PR] [FLINK-38721] Support vector search for es connector. [flink-connector-elasticsearch] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/24 09:01:04 UTC, 1 replies.
- [D] Flink Agents: Flink Multi-Version Support Design [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/24 09:01:29 UTC, 1 replies.
- [jira] [Updated] (FLINK-38721) Support vector search for es connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/24 09:02:00 UTC, 0 replies.
- [PR] [FLINK-38763][runtime] Add REST API for JarRunApplication [flink] - posted by "eemario (via GitHub)" <gi...@apache.org> on 2025/12/24 09:07:15 UTC, 1 replies.
- Re: [D] Flink Multi-Version Support [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/24 09:07:34 UTC, 1 replies.
- [jira] [Updated] (FLINK-38763) Add REST API for JarRunApplication - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/24 09:08:00 UTC, 0 replies.
- [PR] [runtime] Avoid create new runner context each time execute action. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/24 10:50:14 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38189) Allow it to sink data to Kafka partitions based on KEY in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/12/24 11:20:00 UTC, 0 replies.
- [PR] [released] Add Flink-Shaded 21.0 [flink-web] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/12/24 12:24:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-30252) Publish flink-shaded pom - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/12/24 12:30:00 UTC, 0 replies.
- [I] [Feature] Add document for how to add dependency in pom for flink-agents project. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/24 12:55:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2025/12/24 13:04:00 UTC, 0 replies.
- Re: [PR] [FLINK-38276][cdc-common] PaimonWriter does not invalidate cache when… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/25 00:05:26 UTC, 0 replies.
- Re: [I] [Tech Debt] Avoid create AgentPlan instance each time execute action. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/25 02:06:56 UTC, 0 replies.
- Re: [PR] [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/25 06:26:15 UTC, 1 replies.
- Re: [PR] [FLINK-38392] Fix failing test in StreamPandasConversionTests [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/25 06:26:22 UTC, 0 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 2025/12/25 06:26:24 UTC, 0 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 2025/12/25 06:26:26 UTC, 0 replies.
- [PR] Fix broken image links in the dynamic iceberg sink blogpost [flink-web] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/12/25 07:32:34 UTC, 1 replies.
- [PR] [metrics] Implement token usage metrics tracking for chat models [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/25 07:33:09 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37501) Incorrect url for jobmanager log on history server - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2025/12/25 07:48:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38824) Incorrect default values for primitive types - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/12/25 07:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/25 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/25 08:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38834) Support alter column type DDL for starrocks sink connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/25 08:58:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38818) [posgtres-cdc] Emit initial table schemas from state - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/12/25 08:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38823) Error running wide table task - posted by "Thorne (Jira)" <ji...@apache.org> on 2025/12/25 09:17:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-24701) "late events" link in "Timely Stream Processing" document is not working - posted by "Sandesh Mendan (Jira)" <ji...@apache.org> on 2025/12/25 11:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-23882) Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL - posted by "Sandesh Mendan (Jira)" <ji...@apache.org> on 2025/12/25 11:11:00 UTC, 0 replies.
- [I] [Feature] Support Multi-Version Flink for Flink Agents [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/25 11:23:43 UTC, 0 replies.
- [PR] [Feature][runtime] Support Multi-Version Flink for Flink Agents [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/25 11:30:02 UTC, 1 replies.
- [jira] [Created] (FLINK-38839) Support semicolon delimiter for transform table-options - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/12/25 11:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38839) Support semicolon delimiter for transform table-options - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/12/25 11:34:00 UTC, 3 replies.
- [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/12/25 11:51:38 UTC, 3 replies.
- [PR] [FLINK-38837][pipeline-connector/hudi] Fix the configuraton for Hudi … [flink-cdc] - posted by "cshuo (via GitHub)" <gi...@apache.org> on 2025/12/26 02:20:50 UTC, 2 replies.
- [jira] [Updated] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/26 02:22:00 UTC, 0 replies.
- [PR] doc : add ElasticsearchVectorStore doc [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/12/26 03:18:05 UTC, 2 replies.
- [jira] [Commented] (FLINK-9680) Reduce heartbeat timeout for E2E tests - posted by "Sandesh Mendan (Jira)" <ji...@apache.org> on 2025/12/26 04:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7288) Yarn production classes contain testing code - posted by "Sandesh Mendan (Jira)" <ji...@apache.org> on 2025/12/26 04:13:00 UTC, 0 replies.
- Re: [PR] [FLINK-37863] add DynamicKafkaSource interface [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/26 06:26:03 UTC, 0 replies.
- Re: [PR] [FLINK-37575] Simplify the code for creating Netty shuffle environment. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/26 06:26:15 UTC, 1 replies.
- [jira] [Created] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/12/26 06:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/12/26 06:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/12/26 06:58:00 UTC, 0 replies.
- [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/12/26 07:39:55 UTC, 7 replies.
- [jira] [Updated] (FLINK-38523) Upgrade Pekko to 1.2.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/26 07:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-23140) Invalid link in Data Sources documentation - posted by "Sandesh Mendan (Jira)" <ji...@apache.org> on 2025/12/26 09:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33383) flink-quickstart-scala.sh is not supported anymore since 1.17 but is used in flink-web helper scripts - posted by "Sandesh Mendan (Jira)" <ji...@apache.org> on 2025/12/26 09:07:00 UTC, 0 replies.
- [PR] [test] Use qwen3:8b in integration test to improve stability. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/26 09:17:55 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38801) Add Spotless plugin with Google AOSP style for flink benchmark repository - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2025/12/26 09:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-36664][Window]Window with offset need deal offset when cal nextTriggerWatermark. [flink] - posted by "xing1mo (via GitHub)" <gi...@apache.org> on 2025/12/26 09:56:54 UTC, 0 replies.
- [jira] [Closed] (FLINK-38759) Refactor application mode with PackagedProgramApplication - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/26 10:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38730) Bump jdk version of Flink CDC to 11 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/26 12:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38730) Bump jdk version of Flink CDC to 11 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/26 12:17:00 UTC, 0 replies.
- [PR] Add documentation for adding Maven dependencies [flink-agents] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2025/12/26 12:17:42 UTC, 3 replies.
- [jira] [Created] (FLINK-38841) Nullability is lost in FamilyArgumentStrategy - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/12/26 12:31:00 UTC, 0 replies.
- [PR] Add async execution support for built-in actions [flink-agents] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2025/12/26 12:31:23 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/12/26 12:48:00 UTC, 0 replies.
- [PR] [FLINK-38841][table] Enforce expected nullability in FamilyArgumentStrategy [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/12/26 13:00:41 UTC, 3 replies.
- [jira] [Updated] (FLINK-38841) Nullability is lost in FamilyArgumentStrategy - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/26 13:01:00 UTC, 0 replies.
- Re: [PR] [FLINK-37984] Cassandra Sink V2 Implementation (FLIP-533) (Phase-1) [flink-connector-cassandra] - posted by "vahmed-hamdy (via GitHub)" <gi...@apache.org> on 2025/12/27 19:23:08 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38803) Add UNABLE_TO_DESERIALIZE_RESPONSE http-completion-state. - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/27 21:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38803) Add UNABLE_TO_DESERIALIZE_RESPONSE http-completion-state. - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/27 21:45:00 UTC, 0 replies.
- Re: [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/28 00:05:44 UTC, 1 replies.
- Re: [PR] [FLINK-36694][Filesystems] Update Azure FS to Hadoop 3.4.1 with versioned Hadoop modules for 3.3 and 3.4 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/28 06:26:04 UTC, 1 replies.
- [PR] Add sensory memory documentation [flink-agents] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2025/12/28 10:11:09 UTC, 1 replies.
- [PR] Add long-term memory documentation [flink-agents] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2025/12/28 10:17:21 UTC, 0 replies.
- [PR] [hotfix] Fix build_docs GHA workflow not working after Java 11 upgrade [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/12/29 03:03:25 UTC, 1 replies.
- [D] Improve Python Async Execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/29 03:45:11 UTC, 0 replies.
- Re: [PR] [FLINK-37501][runtime/web] Fix incorrect job ID in url for logs in history server [flink] - posted by "ldadima (via GitHub)" <gi...@apache.org> on 2025/12/29 04:44:20 UTC, 0 replies.
- [D] Support Fine-Grain Durable Execution [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/29 06:19:06 UTC, 0 replies.
- Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:26:27 UTC, 0 replies.
- Re: [PR] [FLINK-30371][Connector/JDBC] Fix the problem of JdbcOutputFormat database connection leak [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:27:39 UTC, 1 replies.
- Re: [PR] [FLINK-31530] support oracle catalog [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:27:41 UTC, 1 replies.
- Re: [PR] [FLINK-32068] connector jdbc support clickhouse [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:27:43 UTC, 1 replies.
- Re: [PR] [FLINK-27429] Add Vertica JDBC Dialect [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:27:46 UTC, 1 replies.
- Re: [PR] Update AbstractPostgresCompatibleDialect.java [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:27:49 UTC, 1 replies.
- Re: [PR] [FLINK-32600] Fix MS SQL quote identifier and upsert statement [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:27:51 UTC, 1 replies.
- Re: [PR] [FLINK-33069]Mysql and Postgres catalog support url extra parameters [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:27:53 UTC, 1 replies.
- Re: [PR] [FLINK-30371] Fix the problem of JdbcOutputFormat database connection leak [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:27:56 UTC, 1 replies.
- Re: [PR] [FLINK-30960] Fix a corner case oom error [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:27:59 UTC, 1 replies.
- Re: [PR] [FLINK-33800][JDBC/Connector] Allow passing parameters to database via jdbc url [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:01 UTC, 1 replies.
- Re: [PR] [FLINK-33929][jdbc-connector] Support JDBC String field read Fragment read [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:03 UTC, 1 replies.
- [D] Flink Agents Support Multi-JDK Versions [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:06 UTC, 0 replies.
- Re: [PR] [FLINK-34901][connectors/jdbc]Update clause must EXCLUDED unique index. [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:06 UTC, 1 replies.
- Re: [PR] Merge pull request #1 from apache/main [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:08 UTC, 1 replies.
- Re: [PR] [FLINK-33761][Connector/JDBC] Add Snowflake JDBC Dialect [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:10 UTC, 1 replies.
- Re: [PR] [FLINK-30702] Add Elasticsearch dialect [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:13 UTC, 1 replies.
- Re: [PR] [FLINK-36271] Support reading json and jsonb types in PostgreSQL dialect [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:16 UTC, 1 replies.
- Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:18 UTC, 1 replies.
- Re: [PR] [FLINK-37809][Connector/JDBC] sqlserver limit statement support [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:21 UTC, 1 replies.
- Re: [PR] [FLINK-37737] Add support for GaussDB database type [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:23 UTC, 1 replies.
- Re: [PR] [hotfix][build & docs] Update version to 4.1-SNAPSHOT and update docs [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:25 UTC, 1 replies.
- Re: [PR] [FLINK-38099]Merge pull request #155 from apache/main [flink-connector-jdbc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/12/29 06:28:28 UTC, 1 replies.
- [jira] [Created] (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 "linguoxuan (Jira)" <ji...@apache.org> on 2025/12/29 06:39:00 UTC, 0 replies.
- [jira] [Commented] (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 2025/12/29 06:47:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38740) STDDEV related functions may produce invalid results - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/12/29 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38843) Flakey test case ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/12/29 08:37:00 UTC, 0 replies.
- [PR] [FLINK-XXXXX][pipeline-connector/postgres] Add metadata column support for PostgreSQL Pipeline Connector [flink-cdc] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/12/29 09:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-38844) Add metadata column support for PostgreSQL Pipeline Connector - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/12/29 09:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38844) Add metadata column support for PostgreSQL Pipeline Connector - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/12/29 09:27:00 UTC, 1 replies.
- [PR] [common] Add PatternCache to optimize regex compilation performance [flink-cdc] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/12/29 09:45:48 UTC, 0 replies.
- [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] - posted by "vsantwana (via GitHub)" <gi...@apache.org> on 2025/12/29 11:07:53 UTC, 10 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 2025/12/29 11:11:59 UTC, 0 replies.
- Re: [PR] [FLINK-38844][pipeline-connector][postgres]Add metadata column support [flink-cdc] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/12/29 11:23:29 UTC, 3 replies.
- [PR] [plan] Support error handling strategy for built-in chat action. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/12/29 11:52:03 UTC, 0 replies.
- [jira] [Created] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/12/29 12:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38843) Flakey test case ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/12/29 16:37:00 UTC, 0 replies.
- [PR] [FLINK-38579] Fix incorrect UB drop for filter on non-upsert key [flink] - posted by "fresh-borzoni (via GitHub)" <gi...@apache.org> on 2025/12/29 23:15:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-38579) NonEquivCond in join and Filters pushed down in source should also affect the upstream changelog just like Filter in Calc - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/29 23:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38775) Flink 2.2: update reference data for Migration Tests - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/12/30 02:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38760) Add REST APIs for application query and cancellation - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/30 02:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/12/30 02:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38717) Display the load status of TaskManagers. - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/30 06:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38719) Display the number of tasks on the TaskManagers page. - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/30 06:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38718) Display the number of tasks at slots level on the detailed TaskManager page. - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/12/30 06:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/12/30 06:48:44 UTC, 0 replies.
- [jira] [Created] (FLINK-38846) Binlog client use LinkedList to store binlog content - posted by "张皓然 (Jira)" <ji...@apache.org> on 2025/12/30 07:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38846) Binlog client use LinkedList to store binlog content - posted by "张皓然 (Jira)" <ji...@apache.org> on 2025/12/30 07:30:00 UTC, 0 replies.
- Re: [D] Label-Based Version Control Strategy [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/30 08:54:36 UTC, 1 replies.
- [PR] [infra] Add doc-including label to indicate docs are included in the PR [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/12/30 09:03:55 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38804) The shutdown sequence is incorrect causes TaskManager is shutting down - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/12/30 09:25:00 UTC, 0 replies.
- [PR] Fix ConnectionPoolId to use username [flink-cdc] - posted by "JNSimba (via GitHub)" <gi...@apache.org> on 2025/12/30 10:13:23 UTC, 0 replies.
- [jira] [Created] (FLINK-38847) Incorrect construction of Postgres ConnectionPoolId - posted by "Di Wu (Jira)" <ji...@apache.org> on 2025/12/30 10:19:00 UTC, 0 replies.
- Re: [PR] [FLINK-38726][fluss] Bump Fluss version to 0.8.0-incubating [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/12/30 11:53:57 UTC, 0 replies.
- [PR] [FLINK-38753] Enrich upsert keys by equi-join equivalences [flink] - posted by "fresh-borzoni (via GitHub)" <gi...@apache.org> on 2025/12/30 14:28:15 UTC, 1 replies.
- [jira] [Updated] (FLINK-38753) Enrich more upsert keys by equiv expressions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/30 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38848) Catalog#getTable should indicate if it's for writing - posted by "He Qi (Jira)" <ji...@apache.org> on 2025/12/30 14:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38848) Catalog#getTable should indicate if it's for writing - posted by "He Qi (Jira)" <ji...@apache.org> on 2025/12/30 14:42:00 UTC, 0 replies.
- Re: [PR] [FLINK-38345][flink-connector-base] Annotate SourceSwitchContext#getPreviousEnumerator as nullable for recovery scenarios [flink] - posted by "mattcuento (via GitHub)" <gi...@apache.org> on 2025/12/30 18:18:26 UTC, 0 replies.
- [jira] [Created] (FLINK-38849) HybridSourceReader does not respect pauseOrResumeSplits implementations - posted by "Matt Cuento (Jira)" <ji...@apache.org> on 2025/12/30 18:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38849) HybridSourceReader does not respect pauseOrResumeSplits implementations - posted by "Matt Cuento (Jira)" <ji...@apache.org> on 2025/12/30 18:38:00 UTC, 0 replies.
- [PR] [FLINK-38804][runtime] draft fix [flink] - posted by "Efrat19 (via GitHub)" <gi...@apache.org> on 2025/12/30 20:07:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket - posted by "peiyu (Jira)" <ji...@apache.org> on 2025/12/31 02:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38647) NullPointerException in Postgres CDC pipeline when update data in table - posted by "Daishuyuan (Jira)" <ji...@apache.org> on 2025/12/31 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38850) [Connector/JDBC] Support PostgreSQL uuid type - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2025/12/31 04:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38851) [Connector/JDBC] Support passing arbitrary database options to JDBC Catalog - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2025/12/31 05:03:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38851) [Connector/JDBC] Support passing arbitrary database options to JDBC Catalog - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2025/12/31 05:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38850) Support PostgreSQL uuid type - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2025/12/31 05:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2025/12/31 05:06:00 UTC, 0 replies.
- Re: [D] Improve Python Async Execution API [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/31 08:27:54 UTC, 0 replies.
- [I] [Feature] Improve Python Async Execution API [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/12/31 08:28:22 UTC, 0 replies.
- [PR] [FLINK-38826][table] Add new ArgumentStrategy to support array with specified element type [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2025/12/31 08:57:50 UTC, 2 replies.
- [jira] [Updated] (FLINK-38826) Add new ArgumentStrategy to support array with specified element type - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/12/31 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38852) FLIP-556: Introduce BITMAP Data Type - posted by "dylanhz (Jira)" <ji...@apache.org> on 2025/12/31 09:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22258) Adaptive Scheduler: Show history of rescales in the Web UI - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2025/12/31 15:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38163) Adaptive Scheduler: Support record and query rescales hisotry. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2025/12/31 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38853) Enhance the standardization of the REST API JSON schema - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2025/12/31 15:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22258) Umbrella: FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2025/12/31 15:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38853) Umbrella: FLIP-XXX: Enhance the standardization of the REST API JSON schema - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2025/12/31 15:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38753) Enrich more upsert keys by equiv expressions - posted by "Anton Borisov (Jira)" <ji...@apache.org> on 2025/12/31 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38854) Enrich upsert keys across equivalence relations in MultiJoin - posted by "Anton Borisov (Jira)" <ji...@apache.org> on 2025/12/31 16:57:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38753) Enrich more upsert keys by equiv expressions - posted by "Anton Borisov (Jira)" <ji...@apache.org> on 2025/12/31 16:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38854) Enrich upsert keys across equivalence relations in MultiJoin - posted by "Anton Borisov (Jira)" <ji...@apache.org> on 2025/12/31 17:02:00 UTC, 0 replies.