issues  

Messages by Date

• 2025/04/26 Re: [PR] [hotfix][core] Replace the concating on strings with the placeholder in log lines [flink] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-37128) Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill Yanquan Lv (Jira)
• 2025/04/26 [PR] [hotfix] Avoid duplicate operation ! [flink] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent correctly. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36708) Optimize Table Collection Handling Logic to Improve Efficiency Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation. Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] Add support for GaussDB database type [flink-connector-jdbc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-35849) [flink-cdc] Use expose_snapshot to read snapshot splits of postgres cdc connector. Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 [jira] [Assigned] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-35757) support read new tables when scanNewlyTableAdded is enabled Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 [jira] [Created] (FLINK-37734) Update version to 3.5-SNAPSHOT and update related docs Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] [hotfix][core] Optimize the merge logic lines calling in Histogram.java. [flink] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-37454) Unit Tests (mongodb6) / compile_and_test (8, generic) is not stable Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-37349) Add timeout for test case that call waitForSinkSize method to avoid Infinite waiting Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37277) Add guidance for configuring different kind of catalog of Paimon Sink. Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer Yanquan Lv (Jira)
• 2025/04/26 [jira] [Commented] (FLINK-37349) Add timeout for test case that call waitForSinkSize method to avoid Infinite waiting Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37508) Postgres CDC Jdbc query should use debezium.snapshot.fetch.size rather than debezium.query.fetch.size. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Assigned] (FLINK-37508) Postgres CDC Jdbc query should use debezium.snapshot.fetch.size rather than debezium.query.fetch.size. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37346) [CI] Unit Tests (mysql) / compile_and_test (8, generic) (pull_request)Failing after 60m Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37347) [docs ]Support any columns as chunk key column (postgres, orcale, db2, sqlserver) Yanquan Lv (Jira)
• 2025/04/26 [jira] [Assigned] (FLINK-37331) Add comprehensive data type coverage tests for new MysqlSource implementation Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37200) Add e2e test for ElasticSearch Sink. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration Yanquan Lv (Jira)
• 2025/04/26 [jira] [Assigned] (FLINK-37200) Add e2e test for ElasticSearch Sink. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36813) MySQLCDC supports synchronization of specified fields Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36967) Bump dependency of Paimon Pipeline connector to 0.9.0 Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-35664) Flink CDC pipeline transform supports mask function Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] Add support for GaussDB database type [flink-connector-jdbc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-36546) Handle batch sources in DataSinkTranslator Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-35713) Add sink PARALLELISM for flink-cdc Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] Add support for GaussDB database type [flink-connector-jdbc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink Yanquan Lv (Jira)
• 2025/04/26 [jira] [Assigned] (FLINK-35684) Add missing option for DataSource and DataSink Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36163) Kafka cdc pipeline source supports protobuf format. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect Yanquan Lv (Jira)
• 2025/04/26 Re: [PR] Add support for GaussDB database type [flink-connector-jdbc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-37223) Add the missing content of MySQL CDC to the Chinese document. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese Yanquan Lv (Jira)
• 2025/04/26 [jira] [Commented] (FLINK-33319) Add AverageTime metric to measure delta change in GC time ouyangwulin (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37118) Enhance flink cdc metrics Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-36222) Support the use of LLM models for data processing in the transform module. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Assigned] (FLINK-35450) Introduce Tikv pipeline DataSource Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation Yanquan Lv (Jira)
• 2025/04/26 [jira] [Assigned] (FLINK-35459) Use Incremental Source Framework in Flink CDC TiKV Source Connector Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-35459) Use Incremental Source Framework in Flink CDC TiKV Source Connector Yanquan Lv (Jira)
• 2025/04/26 [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data ouyangwulin (Jira)
• 2025/04/26 [jira] [Assigned] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation. Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation Yanquan Lv (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover Leonard Xu (Jira)
• 2025/04/26 Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
• 2025/04/26 [jira] [Resolved] (FLINK-37709) Add file descriptor usage in default JVM metrics Leonard Xu (Jira)
• 2025/04/26 Re: [PR] [FLINK-37709][metrics] add file descriptor jvm metrics [flink] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37709][metrics] add file descriptor jvm metrics [flink] via GitHub
• 2025/04/26 [jira] [Assigned] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket Leonard Xu (Jira)
• 2025/04/26 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE ASF GitHub Bot (Jira)
• 2025/04/26 Re: [PR] [FLINK-35595][core] MailboxProcessor#processMailsWhenDefaultActionUnavailable avoids allocating Optional [flink] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] via GitHub
• 2025/04/26 Re: [PR] Verify Flaky Behavior in Apache Flink CEP Operator Test Using GitHub ActionsVerify cep flaky test [flink] via GitHub
• 2025/04/26 [PR] Verify Flaky Behavior in Apache Flink CEP Operator Test Using GitHub ActionsVerify cep flaky test [flink] via GitHub
• 2025/04/26 Re: [PR] [hotfix][python] Add pandas type annotations for TableEnvironment.from_pandas and Table.to_pandas [flink] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] via GitHub
• 2025/04/26 [PR] [hotfix][python] Add pandas type annotations for TableEnvironment.from_pandas and Table.to_pandas [flink] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37652][Connectors/Opensearch] Move to Flink to 2.0.0 [flink-connector-opensearch] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37652][Connectors/Opensearch] Move to Flink to 2.0.0 [flink-connector-opensearch] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-37523) e2e: Test stream python udf sql job fails ASF GitHub Bot (Jira)
• 2025/04/26 [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] via GitHub
• 2025/04/26 Re: [PR] [hotfix][build] Update CI to support Flink 2.0 [flink-connector-aws] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37652][Connectors/Opensearch] Move to Flink to 2.0.0 [flink-connector-opensearch] via GitHub
• 2025/04/26 [jira] [Commented] (FLINK-37733) Externalise DynamoDB connector IT Test to E2E test package Daren Wong (Jira)
• 2025/04/26 Re: [PR] [FLINK-37652][Connectors/Opensearch] Move to Flink to 2.0.0 [flink-connector-opensearch] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] via GitHub
• 2025/04/26 Re: [PR] [FLINK-37652][Connectors/Opensearch] Move to Flink to 2.0.0 [flink-connector-opensearch] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-37733) Externalise DynamoDB IT Test to E2E test package Daren Wong (Jira)
• 2025/04/26 [jira] [Updated] (FLINK-37733) Externalise DynamoDB connector IT Test to E2E test package ASF GitHub Bot (Jira)
• 2025/04/26 [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] via GitHub
• 2025/04/26 [jira] [Updated] (FLINK-37733) Externalise DynamoDB connector IT Test to E2E test package Daren Wong (Jira)
• 2025/04/26 [jira] [Created] (FLINK-37733) Externalise DynamoDB IT Test to E2E test package Daren Wong (Jira)
• 2025/04/26 Re: [PR] [FLINK-37693][state] Avoid reading NOT_OWNED file by local file system when restoring [flink] via GitHub
• 2025/04/26 [jira] [Assigned] (FLINK-37523) e2e: Test stream python udf sql job fails Mika Naylor (Jira)
• 2025/04/25 [jira] [Updated] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Weiqing Yang (Jira)
• 2025/04/25 [jira] [Updated] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Weiqing Yang (Jira)
• 2025/04/25 [jira] [Created] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Weiqing Yang (Jira)
• 2025/04/25 [PR] Add FlinkCDC v3.4.0 [flink-web] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37720][table-planner] Enable sink reuse table optimizer by default and apply plan changes to existing test cases [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37683][Connectors/AWS] Enable SSO credentials [flink-connector-aws] via GitHub
• 2025/04/25 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37683][Connectors/AWS] Enable SSO credentials [flink-connector-aws] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37683][Connectors/AWS] Enable SSO credentials [flink-connector-aws] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37683][Connectors/AWS] Enable SSO credentials [flink-connector-aws] via GitHub
• 2025/04/25 Re: [PR] [FLINK-26425][yarn] Support rolling log aggregation [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-26425][yarn] Support rolling log aggregation [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-26425][yarn] Support rolling log aggregation [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-26425][yarn] Support rolling log aggregation [flink] via GitHub
• 2025/04/25 [jira] [Updated] (FLINK-26425) Support rolling log aggregation on YARN Ferenc Csaky (Jira)
• 2025/04/25 [jira] [Updated] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink ASF GitHub Bot (Jira)
• 2025/04/25 [PR] [FLINK-26425][yarn] Support YARN rolling log aggregation [flink] via GitHub
• 2025/04/25 [jira] [Created] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket Yanquan Lv (Jira)
• 2025/04/25 Re: [PR] [hotfix][core] Optimize the merge logic lines calling in Histogram.java. [flink] via GitHub
• 2025/04/25 Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
• 2025/04/25 [jira] [Updated] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink Ferenc Csaky (Jira)
• 2025/04/25 [jira] [Assigned] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink Ferenc Csaky (Jira)
• 2025/04/25 [jira] [Updated] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink Ferenc Csaky (Jira)
• 2025/04/25 Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
• 2025/04/25 Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
• 2025/04/25 [jira] [Updated] (FLINK-37729) Implement ResultTypeQueryable for Avro serialization schema ASF GitHub Bot (Jira)
• 2025/04/25 [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2025/04/25 [jira] [Resolved] (FLINK-37509) Increment scan source no need to buffer data when enable skipping backfill. Ruan Hang (Jira)
• 2025/04/25 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/25 [jira] [Assigned] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed Leonard Xu (Jira)
• 2025/04/25 [jira] [Resolved] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed Leonard Xu (Jira)
• 2025/04/25 Re: [PR] [FLINK-37453][tests] Add state restoration Pipeline E2e cases [flink-cdc] via GitHub
• 2025/04/25 [jira] [Resolved] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot. Leonard Xu (Jira)
• 2025/04/25 Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot #3 [flink-cdc] via GitHub
• 2025/04/25 Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
• 2025/04/25 [jira] [Updated] (FLINK-37541) Deprecate getTargetColumns in DynamicTableSink.Context xiangyu feng (Jira)
• 2025/04/25 Re: [PR] Add support for GaussDB database type [flink-connector-jdbc] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/25 [jira] [Created] (FLINK-37730) Collect job exceptions as kubernetes events Robert Metzger (Jira)
• 2025/04/25 Re: [PR] [FLINK-37536] [TABLE-SQL] Improve SQL Gateway documentation [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37536] [TABLE-SQL] Improve SQL Gateway documentation [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37536] [TABLE-SQL] Improve SQL Gateway documentation [flink] via GitHub
• 2025/04/25 [jira] [Created] (FLINK-37729) Implement ResultTypeQueryable for Avro serialization schema Pawel Leszczynski (Jira)
• 2025/04/25 Re: [PR] Add support for GaussDB database type [flink-connector-jdbc] via GitHub
• 2025/04/25 [PR] [FLINK-37728][python] fix incorrect import org.apache.flink.table.runtime.operators.window.Window [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] via GitHub
• 2025/04/25 [jira] [Commented] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Vinh Pham (Jira)
• 2025/04/25 [jira] [Assigned] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype Leonard Xu (Jira)
• 2025/04/25 Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37728][python] fix incorrect import org.apache.flink.table.runtime.operators.window.Window [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-35713][common] Support set parallelism in source and sink [flink-cdc] via GitHub
• 2025/04/25 [jira] [Updated] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java ASF GitHub Bot (Jira)
• 2025/04/25 [jira] [Updated] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype Leonard Xu (Jira)
• 2025/04/25 [jira] [Resolved] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype Leonard Xu (Jira)
• 2025/04/25 Re: [PR] [FLINK-37720][table-planner] Enable sink reuse table optimizer by default and apply plan changes to existing test cases [flink] via GitHub
• 2025/04/25 Re: [PR] [FLINK-36973] DateFormat function supports LocalZonedTimestampData type [flink-cdc] via GitHub
• 2025/04/25 [jira] [Assigned] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java Shuyi Chen (Jira)
• 2025/04/25 [jira] [Created] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java Shuyi Chen (Jira)
• 2025/04/25 Re: [PR] [docs] Cleanup pipeline example / remove 'will soon' from reference to transform support [flink-cdc] via GitHub
• 2025/04/25 Re: [PR] [FLINK-37536] [TABLE-SQL] Improve SQL Gateway documentation [flink] via GitHub
• 2025/04/25 [jira] [Created] (FLINK-37727) java.lang.UnsatisfiedLinkError error on pemja.core.PythonInterpreter$MainInterpreter.initialize() Shuyi Chen (Jira)
• 2025/04/25 Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
• 2025/04/25 Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
• 2025/04/25 [jira] [Updated] (FLINK-37720) Enable sink reuse table optimizer by default and apply plan changes to existing test cases xiangyu feng (Jira)
• 2025/04/25 [jira] [Updated] (FLINK-37720) Enable table.optimizer.reuse-sink by default xiangyu feng (Jira)
• 2025/04/25 Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
• 2025/04/24 Re: [PR] [FLINK-36876] Support external eventLoopGroup for RestClient [flink] via GitHub
• 2025/04/24 Re: [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 9.37.2 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37153] Monitor late event count in temporal join [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37207][runtime] Don't clear distributed cache in StreamExecutionEnvironment.configure [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37103] The parameters passed when calling method FactoryUtil.createDynamicTableSource are inconsistent [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink] via GitHub
• 2025/04/24 Re: [PR] [hotfix] Fixed a typo in state_backends.md [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/24 [jira] [Commented] (FLINK-37542) Support sink reuse in streaming mode Xuyang Zhong (Jira)
• 2025/04/24 [jira] [Closed] (FLINK-37542) Support sink reuse in streaming mode Xuyang Zhong (Jira)
• 2025/04/24 Re: [PR] [FLINK-37542][table-planner] Support sink reuse in streaming mode [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/24 [jira] [Commented] (FLINK-37677) [cdc-connector] Sink support skip create table event JunboWang (Jira)
• 2025/04/24 [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
• 2025/04/24 [jira] (FLINK-37677) [cdc-connector] Sink support skip create table event JunboWang (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
• 2025/04/24 [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)

• Earlier messages
• Later messages