issues  

Messages by Date

• 2025/09/18 [jira] [Commented] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows Gustavo de Morais (Jira)
• 2025/09/18 Re: [PR] [minor] Fix potential sql connection statement issue. [flink-cdc] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/09/18 [jira] [Resolved] (FLINK-38059) [docs] Add fluss pipeline connector documentation Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions Yanquan Lv (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Arvid Heise (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Maximilian Michels (Jira)
• 2025/09/18 [jira] [Assigned] (FLINK-23426) Support changelog processing in batch mode Timo Walther (Jira)
• 2025/09/18 Re: [PR] [WIP][BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/18 [jira] [Created] (FLINK-38383) Automatically republish Flink Kubernetes Operator image when base image receives security patches Jaydeep Karia (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Arvid Heise (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-36546) Handle batch sources in DataSinkTranslator Yanquan Lv (Jira)
• 2025/09/18 Re: [PR] [WIP][BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error [flink] via GitHub
• 2025/09/18 [PR] [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) [flink] via GitHub
• 2025/09/18 Re: [PR] [WIP][BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/18 [jira] [Created] (FLINK-38382) Confluent Schema Registry to support primitive types nicolas paris (Jira)
• 2025/09/18 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-37454) Unit Tests (mongodb6) / compile_and_test (8, generic) is not stable Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38232) [docs] updates the connector documentation to reflect the new features in Flink CDC 3.4.0 Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38293) Update Checkstyle version and related rules in Kubernetes Operator Ferenc Csaky (Jira)
• 2025/09/18 Re: [PR] Support MySQL in-source parallel deserialization [flink-cdc] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error [flink] via GitHub
• 2025/09/18 [PR] [FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] via GitHub
• 2025/09/18 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Xuannan Su (Jira)
• 2025/09/18 Re: [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] via GitHub
• 2025/09/18 [PR] [FLINK-38381] Enumerate Kafka partitions across Kafka clusters [flink-kubernetes-operator] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38381) Autoscaler does not enumerate partitions across kafka clusters ASF GitHub Bot (Jira)
• 2025/09/18 Re: [PR] feat: support avro primitive keys [flink] via GitHub
• 2025/09/18 Re: [PR] feat: support avro primitive keys [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error [flink] via GitHub
• 2025/09/18 [jira] [Created] (FLINK-38381) Autoscaler does not enumerate partitions across kafka clusters Maximilian Michels (Jira)
• 2025/09/18 Re: [PR] [docs] Update installation instructions for Flink Agents with PyPI and source build details [flink-agents] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus [flink] via GitHub
• 2025/09/18 [PR] Add Kubernetes Operator 1.13.0 release [flink-web] via GitHub
• 2025/09/18 [PR] [FLINK-38280][Build/Shaded] Update ASM to 9.8. [flink-shaded] via GitHub
• 2025/09/18 Re: [PR] [minor] Fix potential sql connection statement issue. [flink-cdc] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows ASF GitHub Bot (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38380) MySQL cdc may skip data in the GTID disordered scenario even after GTID merged Yanquan Lv (Jira)
• 2025/09/18 [jira] [Created] (FLINK-38380) MySQL cdc may skip data in the GTID disordered scenario even after GTID merged Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37331) Add comprehensive data type coverage tests for new MysqlSource implementation Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer Yanquan Lv (Jira)
• 2025/09/18 [jira] [Created] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows Gustavo de Morais (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37641) Fix: SchemaEvolveE2eITCase.testLenientSchemaEvolution timeout Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters Yanquan Lv (Jira)
• 2025/09/18 Re: [PR] [FLINK-38375][runtime] fix report slot numbers error [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables ASF GitHub Bot (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37346) [CI] Unit Tests (mysql) / compile_and_test (8, generic) (pull_request)Failing after 60m Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException. Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-36163) Kafka cdc pipeline source supports protobuf format. Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart. Yanquan Lv (Jira)
• 2025/09/18 Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error in CatalogManager [flink] via GitHub
• 2025/09/18 [jira] [Assigned] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37630) Support flink cdc pipeline Yarn session mode Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37762) No Infomation in Overview at Flink CDC 3.4 Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-36813) MySQLCDC supports synchronization of specified fields Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35664) Flink CDC pipeline transform supports mask function Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35713) Add sink PARALLELISM for flink-cdc Yanquan Lv (Jira)
• 2025/09/18 [jira] [Resolved] (FLINK-37065) MySQL cdc can lose/skip data during recovering from the checkpoint Yanquan Lv (Jira)
• 2025/09/18 [jira] [Resolved] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent correctly. Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37349) Add timeout for test case that call waitForSinkSize method to avoid Infinite waiting Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent. Yanquan Lv (Jira)
• 2025/09/18 [jira] [Assigned] (FLINK-35757) support read new tables when scanNewlyTableAdded is enabled Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35757) support read new tables when scanNewlyTableAdded is enabled Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37095) test case that used AI model may met quota not enough exception. Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing Yanquan Lv (Jira)
• 2025/09/18 [jira] [Resolved] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38378) Use ValidationException in CatalogManager in case of user error ASF GitHub Bot (Jira)
• 2025/09/18 [jira] [Created] (FLINK-38378) Use ValidationException in CatalogManager in case of user error Sergey Nuyanzin (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37411) Introduce the rollback mechanism for Autoscaler Ferenc Csaky (Jira)
• 2025/09/18 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/09/18 [jira] [Commented] (FLINK-38377) SQL Job Submission in the Flink Kubernetes Operator via SQL Gateway yuanfenghu (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38377) SQL Job Submission in the Flink Kubernetes Operator via SQL Gateway yuanfenghu (Jira)
• 2025/09/18 [jira] [Created] (FLINK-38377) SQL Job Submission in the Flink Kubernetes Operator via SQL Gateway yuanfenghu (Jira)
• 2025/09/18 Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
• 2025/09/18 [jira] [Closed] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory Roman Khachatryan (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38376) AsyncStateStreamingJoinOperator should not OOM due to collecting all matching records in memory Roman Khachatryan (Jira)
• 2025/09/18 [jira] [Assigned] (FLINK-38376) AsyncStateStreamingJoinOperator should not OOM due to collecting all matching records in memory Roman Khachatryan (Jira)
• 2025/09/18 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• 2025/09/18 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Arvid Heise (Jira)
• 2025/09/18 Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] via GitHub
• 2025/09/18 Re: [PR] [docs] Update installation instructions for Flink Agents with PyPI and source build details [flink-agents] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38375][runtime] fix report slot numbers error [flink] via GitHub
• 2025/09/18 [PR] feat: support avro primitive keys [flink] via GitHub
• 2025/09/18 Re: [PR] feat: support avro primitive keys [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Xuannan Su (Jira)
• 2025/09/18 Re: [PR] Update Minikube version to 1.28.0 [flink-kubernetes-operator] via GitHub
• 2025/09/18 [PR] [hotfix] fix the title of docs index [flink-agents] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38375][runtime] fix report slot numbers error [flink] via GitHub
• 2025/09/18 Re: [PR] [minor] Fix SQL injection vulnerabilities in OceanBase connector [flink-cdc] via GitHub
• 2025/09/17 Re: [PR] [FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image [flink-cdc] via GitHub
• 2025/09/17 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/17 [jira] [Created] (FLINK-38338) Introduce the abstraction to describe a rescale event. RocMarshal (Jira)
• 2025/09/17 Re: [PR] [FLINK-37936][flink-table] Support STATE TTL hints for MultiJoin [flink] via GitHub
• 2025/09/17 [jira] [Created] (FLINK-38353) FLIP-483: Add support for children Spans Piotr Nowojski (Jira)
• 2025/09/17 [PR] [minor] Fix SQL injection vulnerabilities in OceanBase connector [flink-cdc] via GitHub
• 2025/09/17 Re: [PR] [FLINK-33045][format avro-confluent] disable auto-registering schema in registry [flink] via GitHub
• 2025/09/17 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/17 [PR] [BP-1.20][FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] via GitHub
• 2025/09/17 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [FLINK-38365][table] Make invalid operations with `MATERIALIZED TABLE`s returning more user friendly message [flink] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/17 [jira] [Created] (FLINK-38373) Support dynamic index generation with field value suffix Liu (Jira)
• 2025/09/17 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/17 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/17 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/17 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/17 Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
• 2025/09/17 [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/17 [jira] [Created] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/17 [jira] [Commented] (FLINK-38333) Umbrella: FLIP-495: Support AdaptiveScheduler record and query the rescale history RocMarshal (Jira)
• 2025/09/17 [jira] [Updated] (FLINK-38333) Umbrella: FLIP-495: Support AdaptiveScheduler record and store the rescale history RocMarshal (Jira)
• 2025/09/17 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/17 Re: [I] [Feature] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-38343) Support store rescale history with statistics by ExecutionGraphInfoStore. RocMarshal (Jira)
• 2025/09/17 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/17 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] via GitHub
• 2025/09/17 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [hotfix] fix reasoning extraction from Tongyi model [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [Feature][API][python] Use Python property to simplify the getter in RunnerContext [flink-agents] via GitHub
• 2025/09/17 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/17 Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] via GitHub
• 2025/09/17 [PR] [hotfix][connectors][CI] Replace https://archive.apache.org/ by https://dlcdn.apache.org/ for Flink release download for connectors [flink-connector-shared-utils] via GitHub
• 2025/09/17 [jira] [Created] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs Dawid Wysakowicz (Jira)
• 2025/09/17 Re: [PR] [FLINK-38329][GithubAction] Add target release label for back port PRs [flink] via GitHub
• 2025/09/17 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/17 [PR] [minor] Fix potential sql connection statement issue. [flink-cdc] via GitHub
• 2025/09/17 Re: [PR] [hotfix] fix the title of docs index [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
• 2025/09/17 Re: [D] Community Sync [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [FLINK-38374][SQL API] Introduce new ARTIFACT keyword as an alternative to JAR [flink] via GitHub
• 2025/09/17 [jira] [Commented] (FLINK-38374) Add Artifact keyword as an option to create function syntax Zander Matheson (Jira)
• 2025/09/17 [jira] (FLINK-38374) Add Artifact keyword as an option to create function syntax Zander Matheson (Jira)
• 2025/09/17 [jira] [Updated] (FLINK-38374) Add Artifact keyword as an option to create function syntax ASF GitHub Bot (Jira)
• 2025/09/17 [PR] [FLINK-38374][SQL API] [flink] via GitHub
• 2025/09/17 Re: [PR] [FLINK-38193] Cherry-pick Bump commons-lang3 to version 3.18.0 into release-2.0 [flink] via GitHub
• 2025/09/17 Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] via GitHub
• 2025/09/17 [jira] [Created] (FLINK-38367) Potential Feedback Loop Between IterationHeadTask and SynchronizationSinkTask Shangshu Qian (Jira)
• 2025/09/17 Re: [PR] [api][python] Add Embedding Model abstraction and provide a built-in Ollama embedding model implementation [flink-agents] via GitHub
• 2025/09/17 Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/17 [jira] [Created] (FLINK-38374) Add Artifact keyword as an option to create function syntax Zander Matheson (Jira)
• 2025/09/17 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE ASF GitHub Bot (Jira)
• 2025/09/17 Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/17 [jira] [Updated] (FLINK-38331) Support displaying the hash keys on edges in web ui yisha zhou (Jira)
• 2025/09/17 [jira] [Updated] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese Leonard Xu (Jira)
• 2025/09/17 Re: [PR] [BP-2.1][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/17 [jira] [Closed] (FLINK-38332) Upgrade pemja to 0.5.5 Dian Fu (Jira)
• 2025/09/17 Re: [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-38366) Pyflink planner throws exception in batch mode when there is no limit on order_by() Ahmad Humayun (Jira)
• 2025/09/17 Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
• 2025/09/17 Re: [PR] [minor][improvement] Add subdirectory scrapping to add all .jar in classpath [flink-cdc] via GitHub
• 2025/09/17 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns Xuannan Su (Jira)
• 2025/09/17 [jira] [Commented] (FLINK-38360) HadoopRecoverableWriterTest failed in test_cron_adaptive_scheduler connect Ruan Hang (Jira)
• 2025/09/17 Re: [PR] [FLINK-38329][GithubAction] Add target release label for back port PRs [flink] via GitHub
• 2025/09/17 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/17 Re: [PR] [FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
• 2025/09/17 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/17 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/17 Re: [PR] Update README.md for end-to-end tests [flink] via GitHub
• 2025/09/17 Re: [PR] now issue is resolved [flink] via GitHub
• 2025/09/17 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/17 [jira] [Created] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE Sergey Nuyanzin (Jira)
• 2025/09/17 Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
• 2025/09/17 [jira] [Updated] (FLINK-38372) Introduces whitelist to the flink-metrics-prometheus ASF GitHub Bot (Jira)
• 2025/09/17 Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
• 2025/09/17 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub

• Earlier messages
• Later messages