issues  

Messages by Date

• 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)
• 2025/04/22 Re: [PR] [FLINK-37714][Connector/Kafka] Generate entities in a temporary folder while tests [flink-connector-kafka] via GitHub
• 2025/04/22 Re: [PR] [FLINK-33584][Filesystems] Update Hadoop Filesystem dependencies to 3.3.6 [flink] via GitHub
• 2025/04/22 Re: [PR] [hotfix][docs] Use flink-connector-jdbc-core for maven dependency [flink-connector-jdbc] via GitHub
• 2025/04/22 [PR] [hotfix][docs] Use flink-connector-jdbc-core for maven dependency [flink-connector-jdbc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2025/04/22 [jira] [Commented] (FLINK-37714) KafkaTableITCase generates artifacts in main path Ferenc Csaky (Jira)
• 2025/04/22 [jira] [Comment Edited] (FLINK-37714) KafkaTableITCase generates artifacts in main path Ferenc Csaky (Jira)
• 2025/04/22 Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] Postgres CDC Jdbc query should use debezium.snapshot.fetch.size rather than debezium.query.fetch.size. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] Postgres CDC Jdbc query should use debezium.snapshot.fetch.size rather than debezium.query.fetch.size. [flink-cdc] via GitHub
• 2025/04/22 [jira] [Closed] (FLINK-27383) Make Application mode wait with cluster shutdown until cleanup is done Junrui Lee (Jira)
• 2025/04/22 [jira] [Resolved] (FLINK-37697) ExecutionGraphInfo may not be archived when cluster shutdown in application mode Junrui Lee (Jira)
• 2025/04/22 Re: [PR] [FLINK-37697][runtime] Fix application mode cluster shut down before … [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37604] Generate static UIDs for pipeline operators [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-35600] Add timestamp for low and high watermark [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [hotfix][cdc-base] Fix split not serialize isSnapshotCompleted [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [hotfix][cdc-base] Fix split not serialize isSnapshotCompleted [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37604] Generate static UIDs for pipeline operators [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37697][runtime] Fix application mode cluster shut down before … [flink] via GitHub
• 2025/04/22 Re: [PR] [docs] Cleanup pipeline example / remove 'will soon' from reference to transform support [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] Flink 36798 [flink-cdc] via GitHub
• 2025/04/22 [jira] [Commented] (FLINK-37618) Support PTFs INTERVAL argument juntaozhang (Jira)
• 2025/04/22 Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2025/04/22 [jira] [Updated] (FLINK-37714) KafkaTableITCase generates artifacts in main path ASF GitHub Bot (Jira)
• 2025/04/22 [jira] [Updated] (FLINK-37714) KafkaTableITCase generates artifacts in main path Sergey Nuyanzin (Jira)
• 2025/04/22 [jira] [Updated] (FLINK-37714) KafkaTableITCase generates artifacts in main path Sergey Nuyanzin (Jira)
• 2025/04/22 [jira] [Created] (FLINK-37714) KafkaTableITCase generates artifacts in main path Sergey Nuyanzin (Jira)
• 2025/04/22 Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
• 2025/04/22 [jira] [Resolved] (FLINK-34874) [MongoDB] Support initial.snapshotting.pipeline related configs in table api Leonard Xu (Jira)
• 2025/04/22 [jira] [Assigned] (FLINK-34874) [MongoDB] Support initial.snapshotting.pipeline related configs in table api Leonard Xu (Jira)
• 2025/04/22 Re: [PR] [FLINK-34874][cdc-connector][mongodb] Support initial.snapshotting.pipeline related configs in table api [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] via GitHub
• 2025/04/22 [jira] [Commented] (FLINK-37618) Support PTFs INTERVAL argument Timo Walther (Jira)
• 2025/04/22 Re: [PR] [FLINK-37693][state] Avoid reading NOT_OWNED file by local file system when restoring [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-34874][cdc-connector][mongodb] Support initial.snapshotting.pipeline related configs in table api [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] Postgres CDC Jdbc query should use debezium.snapshot.fetch.size rather than debezium.query.fetch.size. [flink-cdc] via GitHub
• 2025/04/22 [jira] [Updated] (FLINK-36793) There is a problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large. Leonard Xu (Jira)
• 2025/04/22 [jira] [Resolved] (FLINK-36793) There is a problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large. Leonard Xu (Jira)
• 2025/04/22 [jira] [Assigned] (FLINK-36793) There is a problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large. Leonard Xu (Jira)
• 2025/04/22 Re: [PR] [FLINK-36793][cdc-source-connectors] Fix the problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2025/04/22 [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot ASF GitHub Bot (Jira)
• 2025/04/22 [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2025/04/22 [jira] [Updated] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover ASF GitHub Bot (Jira)
• 2025/04/22 [jira] [Commented] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover Yanquan Lv (Jira)
• 2025/04/22 [jira] [Created] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover Yanquan Lv (Jira)
• 2025/04/22 Re: [PR] [FLINK-36793][cdc-source-connectors] Fix the problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large [flink-cdc] via GitHub
• 2025/04/22 [jira] [Commented] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• 2025/04/22 [jira] [Comment Edited] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• 2025/04/22 Re: [PR] [FLINK-37104] Refactor transform module, code cleanup [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37693][state] Avoid reading NOT_OWNED file by local file system when restoring [flink] via GitHub
• 2025/04/22 [jira] [Comment Edited] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• 2025/04/22 [jira] [Comment Edited] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• 2025/04/22 Re: [PR] [FLINK-37511][rest] Use Jackson serialization in JobPlanInfo.Plan [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37693][state] Avoid reading NOT_OWNED file by local file system when restoring [flink] via GitHub
• 2025/04/22 [jira] [Updated] (FLINK-37693) ForSt fails to restore from reused checkpoint ASF GitHub Bot (Jira)
• 2025/04/22 [PR] [FLINK-37693][state] Avoid reading NOT_OWNED file by local file system when restoring [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36793][cdc-source-connectors] Fix the problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large [flink-cdc] via GitHub
• 2025/04/22 [PR] [FLINK-36793][cdc-source-connectors] Fix the problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36793][cdc-source-connectors] Fix the problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37697][runtime] Fix application mode cluster shut down before … [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37697][runtime] Fix application mode cluster shut down before … [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-33463][Connector/JDBC] Support the implementation of dynamic source tables based on the new source [flink-connector-jdbc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37552] Support switching between ForStKeyedStatebackend and ForStSyncKeyedStatebackend [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37653] Refactor incremental snapshot framework to support multiple stream splits [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] Adding JDBC Connector v4.0.0 [flink-web] via GitHub
• 2025/04/22 Re: [PR] [hotfix] Update jdbc connector version to v3.3 in docs [flink] via GitHub
• 2025/04/22 Re: [PR] [hotfix] Update jdbc connector version to v4.0 in docs [flink] via GitHub
• 2025/04/22 Re: [PR] [hotfix] Use jdbc connector v3.3 in docs [flink] via GitHub
• 2025/04/22 Re: [PR] [hotfix][test] Remove redundant keywords and lines for ForStGeneralMultiGetOperationTest.java [flink] via GitHub
• 2025/04/22 Re: [PR] Adding JDBC Connector v3.3.0 [flink-web] via GitHub
• 2025/04/22 Re: [PR] [hotfix][core] Optimize the merge logic lines calling in Histogram.java. [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37697][runtime] Fix application mode cluster shut down before … [flink] via GitHub
• 2025/04/22 Re: [PR] [hotfix][build] mount git sub module to offer release_utils scripts [flink-connector-jdbc] via GitHub
• 2025/04/22 Re: [PR] [hotfix][build] mount git sub module to offer release_utils scripts [flink-connector-jdbc] via GitHub
• 2025/04/22 Re: [PR] [hotfix][build] mount git sub module to offer release_utils scripts [flink-connector-jdbc] via GitHub
• 2025/04/22 Re: [PR] [hotfix] Update jdbc connector version to v4.0 in docs [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36651][Connectors/Elasticsearch] Fix IT test not compatible with 1.20, drop main branch tests for 1.18 [flink-connector-elasticsearch] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36651][Connectors/Elasticsearch] Fix IT test not compatible with 1.20, drop main branch tests for 1.18 [flink-connector-elasticsearch] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [hotfix] Update jdbc connector version to v3.3 in docs [flink] via GitHub
• 2025/04/22 [PR] [hotfix] Update jdbc connector version to v4.0 in docs [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [hotfix] Use jdbc connector v3.3 in docs [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 [PR] [hotfix] Update jdbc connector version to v3.3 in docs [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37697][runtime] Fix application mode cluster shut down before … [flink] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37697][runtime] Fix application mode cluster shut down before … [flink] via GitHub
• 2025/04/22 Re: [PR] [hotfix][build] mount git sub module to offer release_utils scripts [flink-connector-jdbc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions [flink] via GitHub
• 2025/04/22 [jira] [Updated] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name Leonard Xu (Jira)
• 2025/04/22 [jira] [Comment Edited] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• 2025/04/22 Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization. [flink-cdc] via GitHub
• 2025/04/22 [jira] [Comment Edited] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 [jira] [Comment Edited] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• 2025/04/22 [jira] [Comment Edited] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• 2025/04/22 [jira] [Commented] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• 2025/04/22 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/04/22 Re: [PR] [hotfix][cdc-base] Fix split not serialize isSnapshotCompleted [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization. [flink-cdc] via GitHub
• 2025/04/22 Re: [PR] [hotfix][cdc-base] Fix split not serialize isSnapshotCompleted [flink-cdc] via GitHub
• 2025/04/22 [PR] [hotfix][cdc-base] Fix split not serialize isSnapshotCompleted [flink-cdc] via GitHub
• 2025/04/22 [jira] [Commented] (FLINK-31163) Unexpected correlate variable $cor0 in the plan error in where clause Yashoda Krishna (Jira)
• 2025/04/22 [jira] [Resolved] (FLINK-35152) Flink CDC Doris Sink Auto create table event should support setting auto partition fields for each table Leonard Xu (Jira)
• 2025/04/22 [jira] [Assigned] (FLINK-35152) Flink CDC Doris Sink Auto create table event should support setting auto partition fields for each table Leonard Xu (Jira)
• 2025/04/22 Re: [PR] [FLINK-35152][pipeline-connector/doris] Support create doris auto partition table [flink-cdc] via GitHub
• 2025/04/21 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/21 Re: [PR] [FLINK-37542][table-planner] Support sink reuse in streaming mode [flink] via GitHub
• 2025/04/21 Re: [PR] [FLINK-37705][rest] JobPlanInfo properties spec adjustments [flink] via GitHub
• 2025/04/21 [jira] [Commented] (FLINK-37537) Duplicate key when job failover in SchemaOperator Yanquan Lv (Jira)
• 2025/04/21 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/21 [jira] [Assigned] (FLINK-37712) Met TableNotFound exception when reading ParallelMetadataSource to Paimon Sink Leonard Xu (Jira)
• 2025/04/21 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/21 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/21 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/21 Re: [PR] [FLINK-37509] Increment scan source no need to buffer data when enable skipping backfill. [flink-cdc] via GitHub
• 2025/04/21 Re: [PR] [FLINK-36546] Handle batch sources in DataSinkTranslator [flink-cdc] via GitHub
• 2025/04/21 [jira] [Assigned] (FLINK-37709) Add file descriptor usage in default JVM metrics Leonard Xu (Jira)
• 2025/04/21 [jira] [Resolved] (FLINK-36931) FlinkCDC YAML supports synchronizing the full amount of data of the entire database in Batch mode Leonard Xu (Jira)
• 2025/04/21 Re: [PR] [FLINK-36931][cdc] FlinkCDC YAML supports batch mode [flink-cdc] via GitHub
• 2025/04/21 [jira] [Commented] (FLINK-37684) ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.keySelector Ferenc Csaky (Jira)
• 2025/04/21 Re: [PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc] via GitHub
• 2025/04/21 Re: [PR] [hotfix] Rename SessionDispatcherFactory to DefaultDispatcherFactory [flink] via GitHub

• Earlier messages
• Later messages