issues  

Messages by Date

• 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)
• 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] [Commented] (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] [Assigned] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Leonard Xu (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 Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37720][table-planner] Set the default value of table.optimizer.reuse-sink-enabled as true [flink] via GitHub
• 2025/04/24 [jira] [Commented] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• 2025/04/24 [jira] [Assigned] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• 2025/04/24 [jira] [Commented] (FLINK-37726) Read incremental data for existing tables tianzhu.wen (Jira)
• 2025/04/24 [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data Leonard Xu (Jira)
• 2025/04/24 Re: [PR] [FLINK-37542][table-planner] Support sink reuse in streaming mode [flink] via GitHub
• 2025/04/24 [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data Leonard Xu (Jira)
• 2025/04/24 [jira] [Assigned] (FLINK-37726) Read incremental data for existing tables Leonard Xu (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• 2025/04/24 [jira] [Created] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• 2025/04/24 Re: [PR] [FLINK-36794] [cdc-composer/cli] pipeline cdc connector support multiple data sources [flink-cdc] via GitHub
• 2025/04/24 Re: [PR] [FLINK-36580][pipeline-connector-mysql] Fix column.[in|ex]clude.list parameter causing schema inconsistency [flink-cdc] via GitHub
• 2025/04/24 Re: [PR] Makes Async calcs share correlate split rule with Python [flink] via GitHub
• 2025/04/24 [PR] Makes Async calcs share correlate split rule with Python [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/04/24 Re: [PR] Fixes janino bug returning incorrect results [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/04/24 [PR] Fixes janino bug returning incorrect results [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-36546] Handle batch sources in DataSinkTranslator [flink-cdc] via GitHub
• 2025/04/24 [jira] [Created] (FLINK-37720) Enable table.optimizer.reuse-sink by default xiangyu feng (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar Alan Sheinberg (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar Alan Sheinberg (Jira)
• 2025/04/24 [jira] [Created] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar Alan Sheinberg (Jira)
• 2025/04/24 [jira] [Created] (FLINK-37724) Add AsyncTableFunction as new UDF type Alan Sheinberg (Jira)
• 2025/04/24 [jira] [Created] (FLINK-37723) FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg (Jira)
• 2025/04/24 Re: [PR] Upgrade Kafka connector to 4.0.0 for Flink 2.0 [flink-web] via GitHub
• 2025/04/24 Re: [PR] [FLINK-36659][docs] Update Kafka connector docs for 4.0.0 [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37709][metrics] add file descriptor jvm metrics [flink] via GitHub
• 2025/04/24 [jira] [Created] (FLINK-37721) Fix Janino Bug which resulted in Alan Sheinberg (Jira)
• 2025/04/24 [PR] [FLINK-37720][table-planner] Set the default value of table.optimizer.reuse-sink-enabled as true [flink] via GitHub
• 2025/04/24 [jira] [Created] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs Zhanghao Chen (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-37721) Fix janino bug returning incorrect results Alan Sheinberg (Jira)
• 2025/04/24 [jira] [Closed] (FLINK-37243) Ensure that async callback processing happen on known thread Alan Sheinberg (Jira)
• 2025/04/24 Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] via GitHub
• 2025/04/24 [jira] [Assigned] (FLINK-37243) Ensure that async callback processing happen on known thread Alan Sheinberg (Jira)
• 2025/04/24 Re: [PR] [FLINK-36902] Remove support for FlinkSecurityManager [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37720][table-planner] Set the default value of table.optimizer.reuse-sink-enabled as true [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37720][table-planner] Set the default value of table.optimizer.reuse-sink-enabled as true [flink] via GitHub
• 2025/04/24 [jira] [Updated] (FLINK-37720) Enable table.optimizer.reuse-sink by default ASF GitHub Bot (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-36902) Security Manager removal Liam Miller-Cushon (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-36902) Security Manager removal Liam Miller-Cushon (Jira)
• 2025/04/24 Re: [PR] [FLINK-36902] Remove support for FlinkSecurityManager [flink] via GitHub
• 2025/04/24 [jira] [Created] (FLINK-37719) Support Java 25 (LTS) Liam Miller-Cushon (Jira)
• 2025/04/24 [jira] [Updated] (FLINK-36902) Security Manager removal Liam Miller-Cushon (Jira)
• 2025/04/24 Re: [PR] [FLINK-37709][metrics] add file descriptor jvm metrics [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-32097][Connectors/Kinesis] Implement support for Kinesis deaggregation [flink-connector-aws] via GitHub
• 2025/04/24 [jira] [Closed] (FLINK-37705) JobPlanInfo properties adjustments in OpenAPI spec Roman Khachatryan (Jira)
• 2025/04/24 Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37705][rest] JobPlanInfo properties spec adjustments [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37542][table-planner] Support sink reuse in streaming mode [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37718] Refactor ApplicationSubmissionContextReflector to centralize method retrieval and invocation. [flink] via GitHub
• 2025/04/24 [jira] [Updated] (FLINK-37718) Refactor ApplicationSubmissionContextReflector ASF GitHub Bot (Jira)
• 2025/04/24 [PR] [FLINK-37718] Refactor ApplicationSubmissionContextReflector to centralize method retrieval and invocation. [flink] via GitHub
• 2025/04/24 [jira] [Created] (FLINK-37718) Refactor ApplicationSubmissionContextReflector tianzhu.wen (Jira)
• 2025/04/24 Re: [PR] [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37705][rest] JobPlanInfo properties spec adjustments [flink] via GitHub
• 2025/04/24 [jira] [Created] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
• 2025/04/24 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 [jira] [Commented] (FLINK-36947) Rate limiting the GetRecord call frequency Darshan Siby (Jira)
• 2025/04/24 [jira] [Resolved] (FLINK-37714) KafkaTableITCase generates artifacts in main path Sergey Nuyanzin (Jira)
• 2025/04/24 [jira] [Commented] (FLINK-37714) KafkaTableITCase generates artifacts in main path Sergey Nuyanzin (Jira)
• 2025/04/24 [jira] [Assigned] (FLINK-37714) KafkaTableITCase generates artifacts in main path Sergey Nuyanzin (Jira)
• 2025/04/24 Re: [PR] [FLINK-37714][Connector/Kafka] Generate entities in a temporary folder while tests [flink-connector-kafka] via GitHub
• 2025/04/24 Re: [PR] Upgrade Kafka connector to 4.0.0 for Flink 2.0 [flink-web] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37705][rest] JobPlanInfo properties spec adjustments [flink] via GitHub
• 2025/04/24 Re: [PR] Upgrade Kafka connector to 4.0.0 for Flink 2.0 [flink-web] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-36659][docs] Update Kafka connector docs for 4.0.0 [flink] via GitHub
• 2025/04/24 [PR] [FLINK-36659][docs] Update Kafka connector docs for 4.0.0 [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/24 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/24 [jira] [Resolved] (FLINK-36742) Filter unacked split for no capture tables when task restore from state Leonard Xu (Jira)
• 2025/04/24 Re: [PR] [FLINK-36742][cdc-base][oracle] Filter unacked split for no capture tables when task restore from state [flink-cdc] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37678][pipeline-connector/doris] Upgrade the version of doris connector. [flink-cdc] via GitHub
• 2025/04/24 [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/24 [jira] [Resolved] (FLINK-37573) Deprecate Java 8 in Kafka Arvid Heise (Jira)
• 2025/04/24 Re: [PR] [FLINK-37678][pipeline-connector/doris] Upgrade the version of doris connector. [flink-cdc] via GitHub
• 2025/04/24 [jira] [Updated] (FLINK-37573) Remove Java 8 support from flink-connector-kafka Arvid Heise (Jira)
• 2025/04/24 Re: [PR] [FLINK-37705][rest] JobPlanInfo properties spec adjustments [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-36742][cdc-base][oracle] Filter unacked split for no capture tables when task restore from state [flink-cdc] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37705][rest] JobPlanInfo properties spec adjustments [flink] via GitHub
• 2025/04/24 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-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
• 2025/04/24 [jira] [Assigned] (FLINK-37705) JobPlanInfo properties adjustments in OpenAPI spec Roman Khachatryan (Jira)
• 2025/04/24 [jira] [Resolved] (FLINK-37566) table.exclude was invalid in binlog reading phase when scan.binlog.newly-added-table.enabled was true. Leonard Xu (Jira)
• 2025/04/24 Re: [PR] [FLINK-37566] Avoid processing events of excluded tables. [flink-cdc] via GitHub
• 2025/04/24 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-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/24 Re: [PR] [FLINK-37587][runtime] Fix error when adding a column using transform which has the same column name with one column of source table. [flink-cdc] via GitHub
• 2025/04/24 Re: [PR] [FLINK-36902] Remove support for FlinkSecurityManager [flink] via GitHub
• 2025/04/24 Re: [PR] [hotfix][runtime] Remove the redundant 'format' calling. [flink] via GitHub
• 2025/04/24 Re: [PR] [hotfix][runtime] Remove the redundant 'format' calling. [flink] via GitHub
• 2025/04/24 [jira] [Resolved] (FLINK-37680) Add subclass cache for PojoSerializer Junrui Lee (Jira)
• 2025/04/24 [jira] [Assigned] (FLINK-37680) Add subclass cache for PojoSerializer Junrui Lee (Jira)
• 2025/04/23 Re: [PR] [FLINK-37680][serializer] Add subclass cache for PojoSerializer [flink] via GitHub
• 2025/04/23 [jira] [Updated] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover Leonard Xu (Jira)
• 2025/04/23 Re: [PR] [FLINK-37566] Avoid processing events of excluded tables. [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37566] Avoid processing events of excluded tables. [flink-cdc] via GitHub
• 2025/04/23 [jira] [Assigned] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover Leonard Xu (Jira)
• 2025/04/23 [jira] [Resolved] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover Leonard Xu (Jira)
• 2025/04/23 Re: [PR] [FLINK-37713][runtime] Fix SchemaManager was recreated in SchemaRegistry after job failover. [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37680][serializer] Add subclass cache for PojoSerializer [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37587][runtime] Fix error when adding a column using transform which has the same column name with one column of source table. [flink-cdc] via GitHub
• 2025/04/23 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/23 Re: [PR] [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph [flink] via GitHub
• 2025/04/23 [jira] [Updated] (FLINK-37716) Simplify YarnClusterDescriptor by removing parameter JobGraph ASF GitHub Bot (Jira)
• 2025/04/23 [PR] [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph [flink] via GitHub
• 2025/04/23 Re: [PR] [hotfix][runtime] Delete the unused BoundedInputStream.java. [flink] via GitHub
• 2025/04/23 [jira] [Created] (FLINK-37716) Simplify YarnClusterDescriptor by removing parameter JobGraph Jiaan Geng (Jira)
• 2025/04/23 Re: [PR] [hotfix][runtime] Delete the unused BoundedInputStream.java. [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37653] Refactor incremental snapshot framework to support multiple stream splits [flink-cdc] via GitHub
• 2025/04/23 [jira] [Commented] (FLINK-37317) Checkpoint asyncOperationsThreadPool has only one thread running Hangxiang Yu (Jira)
• 2025/04/23 Re: [PR] [FLINK-37604] Generate static UIDs for pipeline operators [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37653] Refactor incremental snapshot framework to support multiple stream splits [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37709][metrics] add file descriptor jvm metrics [flink] via GitHub
• 2025/04/23 Re: [PR] [hotfix][core] Optimize the merge logic lines calling in Histogram.java. [flink] via GitHub
• 2025/04/23 Re: [PR] [hotfix][core] Optimize the merge logic lines calling in Histogram.java. [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws] via GitHub
• 2025/04/23 Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37709][metrics] add file descriptor jvm metrics [flink] via GitHub
• 2025/04/23 [jira] [Updated] (FLINK-37317) Checkpoint asyncOperationsThreadPool has only one thread running Jufang He (Jira)
• 2025/04/23 [jira] [Updated] (FLINK-37317) Checkpoint asyncOperationsThreadPool has only one thread running Jufang He (Jira)
• 2025/04/23 [jira] [Updated] (FLINK-37317) Checkpoint asyncOperationsThreadPool has only one thread running Jufang He (Jira)
• 2025/04/23 Re: [PR] [FLINK-36902] Remove support for FlinkSecurityManager [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37604] Generate static UIDs for pipeline operators [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [FLINK-36902] Remove support for FlinkSecurityManager [flink] via GitHub
• 2025/04/23 Re: [PR] [hotfix][core] Optimize the merge logic lines calling in Histogram.java. [flink] via GitHub
• 2025/04/23 [jira] [Commented] (FLINK-37685) process the callback immediately when the processing key equals to the key in record context Renxiang Zhou (Jira)
• 2025/04/23 [jira] [Closed] (FLINK-37691) Can't consume changelog stream with upsert-kafka connector Dawid Wysakowicz (Jira)
• 2025/04/23 Re: [PR] [FLINK-37691] Do not remove ChangelogNormalize if deduplication was requested [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37683][Connectors/AWS] Enable SSO credentials [flink-connector-aws] via GitHub
• 2025/04/23 [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Nick M (Jira)
• 2025/04/23 Re: [PR] [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils [flink] via GitHub
• 2025/04/23 [jira] [Updated] (FLINK-37715) Flink try use winutils.exe even without hadoop Nick M (Jira)
• 2025/04/23 [jira] [Created] (FLINK-37715) Flink try use winutils.exe even without hadoop Nick M (Jira)
• 2025/04/23 Re: [PR] [FLINK-37653] Refactor incremental snapshot framework to support multiple stream splits [flink-cdc] via GitHub
• 2025/04/23 [jira] [Closed] (FLINK-37685) process the callback immediately when the processing key equals to the key in record context Renxiang Zhou (Jira)
• 2025/04/23 [jira] [Commented] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Nick M (Jira)
• 2025/04/23 Re: [PR] [FLINK-37653] Refactor incremental snapshot framework to support multiple stream splits [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37653] Refactor incremental snapshot framework to support multiple stream splits [flink-cdc] via GitHub
• 2025/04/23 [PR] [FLINK-37691] Do not remove ChangelogNormalize if deduplication was requested [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37691] Do not remove ChangelogNormalize if deduplication was requested [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37691] Do not remove ChangelogNormalize if deduplication was requested [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
• 2025/04/23 [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Nick M (Jira)
• 2025/04/23 [jira] [Updated] (FLINK-37691) Can't consume changelog stream with upsert-kafka connector ASF GitHub Bot (Jira)
• 2025/04/23 Re: [PR] [FLINK-37104] Refactor transform module, code cleanup [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37653] Refactor incremental snapshot framework to support multiple stream splits [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37653] Refactor incremental snapshot framework to support multiple stream splits [flink-cdc] via GitHub
• 2025/04/23 [jira] [Assigned] (FLINK-36546) Handle batch sources in DataSinkTranslator Leonard Xu (Jira)
• 2025/04/23 [jira] [Resolved] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform Leonard Xu (Jira)
• 2025/04/23 [jira] [Updated] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform Leonard Xu (Jira)
• 2025/04/23 Re: [PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-37693][state] Avoid reading NOT_OWNED file by local file system when restoring [flink] via GitHub
• 2025/04/23 Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
• 2025/04/23 Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
• 2025/04/23 Re: [PR] [FLINK-36971][Connectors/Sqs] Add Sqs SQL connector [flink-connector-aws] via GitHub
• 2025/04/23 Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
• 2025/04/23 Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
• 2025/04/23 Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
• 2025/04/22 [jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci dalongliu (Jira)
• 2025/04/22 [jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci dalongliu (Jira)
• 2025/04/22 [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline dalongliu (Jira)
• 2025/04/22 [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline dalongliu (Jira)

• Later messages