issues  

Messages by Date

• 2026/01/18 Re: [PR] [FLINK-38878][runtime] Add parse_json function. [flink-cdc] via GitHub
• 2026/01/18 Re: [PR] [FLINK-36986][table] Migrate SplitRemoteConditionFromJoinRule to java [flink] via GitHub
• 2026/01/18 [PR] [FLINK-36986][table] Migrate SplitRemoteConditionFromJoinRule to java [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] via GitHub
• 2026/01/18 Re: [PR] Update datagen.md [flink] via GitHub
• 2026/01/18 [PR] Update datagen.md [flink] via GitHub
• 2026/01/18 [I] [Feature] [doc] Create a separate section document for MCP. [flink-agents] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38878][runtime] Add parse_json function. [flink-cdc] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38878][runtime] Add parse_json function. [flink-cdc] via GitHub
• 2026/01/18 Re: [I] [Feature][doc] Add guidelines for how to choose between java / python apis [flink-agents] via GitHub
• 2026/01/18 Re: [PR] Add documentation for adding Maven dependencies [flink-agents] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38878][runtime] Add parse_json function. [flink-cdc] via GitHub
• 2026/01/18 [PR] [FLINK-38878][runtime] Add parse_json function. [flink-cdc] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38878][runtime] Add parse_json function. [flink-cdc] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay [flink] via GitHub
• 2026/01/18 [jira] [Created] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint Roman Khachatryan (Jira)
• 2026/01/18 [jira] [Created] (FLINK-38939) Pause sources until the 1st checkpoint to prioritize processing recovered records Roman Khachatryan (Jira)
• 2026/01/18 Re: [PR] [FLINK-38851] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38851] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38851] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2026/01/18 Re: [PR] [FLINK-37908] Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts [flink-connector-aws] via GitHub
• 2026/01/18 Re: [PR] [FLINK-36456] feat: Add support to pass Datadog API Key as environment variable [flink] via GitHub
• 2026/01/18 [jira] [Updated] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft ASF GitHub Bot (Jira)
• 2026/01/18 [PR] [FLINK-38937] Introduce TestKafkaContainer wrapper to support Confluent and Apache Kafka images with KRaft [flink-connector-kafka] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] via GitHub
• 2026/01/18 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2026/01/17 [jira] [Assigned] (FLINK-37002) Migrate DecomposeGroupingSetsRule Sergey Nuyanzin (Jira)
• 2026/01/17 [jira] [Resolved] (FLINK-37002) Migrate DecomposeGroupingSetsRule Sergey Nuyanzin (Jira)
• 2026/01/17 [jira] [Commented] (FLINK-37002) Migrate DecomposeGroupingSetsRule Sergey Nuyanzin (Jira)
• 2026/01/17 Re: [PR] [FLINK-37002][table] Migrate DecomposeGroupingSetsRule to java [flink] via GitHub
• 2026/01/17 Re: [PR] [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` [flink] via GitHub
• 2026/01/17 Re: [PR] [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` [flink] via GitHub
• 2026/01/17 Re: [PR] [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` [flink] via GitHub
• 2026/01/17 Re: [PR] [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` [flink] via GitHub
• 2026/01/17 Re: [PR] [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` [flink] via GitHub
• 2026/01/17 Re: [PR] [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` [flink] via GitHub
• 2026/01/17 [jira] [Updated] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException ASF GitHub Bot (Jira)
• 2026/01/17 [PR] [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` [flink] via GitHub
• 2026/01/17 [jira] [Updated] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException Sergey Nuyanzin (Jira)
• 2026/01/17 [jira] [Created] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException Sergey Nuyanzin (Jira)
• 2026/01/17 [jira] [Assigned] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft Fabian Paul (Jira)
• 2026/01/17 Re: [I] [Feature][doc] Add guidelines for how to choose between java / python apis [flink-agents] via GitHub
• 2026/01/17 Re: [PR] docs: add guidelines for choosing Java vs Python API [flink-agents] via GitHub
• 2026/01/17 [PR] docs: add guidelines for choosing Java vs Python API [flink-agents] via GitHub
• 2026/01/17 Re: [PR] [FLINK-38913][table-planner] ArrayIndexOutOfBoundsException unparsing CAST. [flink] via GitHub
• 2026/01/17 Re: [I] [Feature][runtime] Support async execution for actions [flink-agents] via GitHub
• 2026/01/17 Re: [I] [Feature][runtime][java] Support async execution for actions in java [flink-agents] via GitHub
• 2026/01/17 Re: [PR] [FLINK-38913][table-planner] ArrayIndexOutOfBoundsException unparsing CAST. [flink] via GitHub
• 2026/01/17 Re: [PR] [FLINK-38913][table-planner] ArrayIndexOutOfBoundsException unparsing CAST. [flink] via GitHub
• 2026/01/17 Re: [PR] Add async execution support for built-in actions [flink-agents] via GitHub
• 2026/01/17 Re: [I] [Feature] Support async execution for built-in actions [flink-agents] via GitHub
• 2026/01/17 Re: [PR] [plan][java] Built-in actions support async execution. [flink-agents] via GitHub
• 2026/01/17 Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] via GitHub
• 2026/01/17 [jira] [Commented] (FLINK-32416) Initial DynamicKafkaSource Implementation wangkang (Jira)
• 2026/01/17 [jira] [Comment Edited] (FLINK-32416) Initial DynamicKafkaSource Implementation wangkang (Jira)
• 2026/01/17 [jira] [Created] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft Aleksandr Savonin (Jira)
• 2026/01/17 [I] [Tech Debt] Cross language resource can't support async execution. [flink-agents] via GitHub
• 2026/01/17 Re: [I] [Feature] Improve event logging [flink-agents] via GitHub
• 2026/01/17 Re: [PR] [log] Improve event logging [flink-agents] via GitHub
• 2026/01/17 [jira] [Commented] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 liuerbao (Jira)
• 2026/01/17 [jira] [Updated] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 liuerbao (Jira)
• 2026/01/17 [jira] [Updated] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 liuerbao (Jira)
• 2026/01/17 Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
• 2026/01/17 [PR] support mcp without list_prompts interface [flink-agents] via GitHub
• 2026/01/16 [jira] [Created] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 liuerbao (Jira)
• 2026/01/16 Re: [PR] [fix][runtime] Fix async compaction of long-term memory in python [flink-agents] via GitHub
• 2026/01/16 Re: [PR] Support connecting to remote MCP with predefined prompts [flink-agents] via GitHub
• 2026/01/16 Re: [PR] [plan][java] Built-in actions support async execution. [flink-agents] via GitHub
• 2026/01/16 Re: [PR] Support connecting to remote MCP with predefined prompts [flink-agents] via GitHub
• 2026/01/16 Re: [PR] Support connecting to remote MCP with predefined prompts [flink-agents] via GitHub
• 2026/01/16 [jira] [Updated] (FLINK-38867) FlinkBlueGreenDeployment: savepointRedeployNonce does not respect user-provided initialSavepointPath ASF GitHub Bot (Jira)
• 2026/01/16 [PR] [FLINK-38867] FlinkBlueGreenDeployment used initialSavepointPath on restartSavepointNonce [flink-kubernetes-operator] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation [flink] via GitHub
• 2026/01/16 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/01/16 [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
• 2026/01/16 Re: [PR] [hotfix] Add sleep to stop intermittent failure in ExecutionTimeBasedSlowTaskDetectorTest [flink] via GitHub
• 2026/01/16 [PR] [hotfix] Add sleep to stop intermittent failure in ExecutionTimeBasedSlowTaskDetectorTest [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38935] Change case of Bearer keyword [flink-connector-http] via GitHub
• 2026/01/16 [PR] [FLINK-38935] Change case of Bearer keyword [flink-connector-http] via GitHub
• 2026/01/16 [jira] [Updated] (FLINK-38935) HTTP Connector Fix Bearer token casing in OIDC Change Authorization header from "BEARER" to "Bearer" to comply with RFC 6750. ASF GitHub Bot (Jira)
• 2026/01/16 Re: [PR] Support connecting to remote MCP with predefined prompts [flink-agents] via GitHub
• 2026/01/16 Re: [PR] [FLINK-36456] feat: Add support to pass Datadog API Key as environment variable [flink] via GitHub
• 2026/01/16 [PR] feat: Add support to pass Datadog API Key as environment variable [flink] via GitHub
• 2026/01/16 [jira] [Updated] (FLINK-38935) HTTP Connector Fix Bearer token casing in OIDC Change Authorization header from "BEARER" to "Bearer" to comply with RFC 6750. David Radley (Jira)
• 2026/01/16 [jira] [Created] (FLINK-38935) HTTP Connector Fixe Bearer token casing in OIDC Change Authorization header from "BEARER" to "Bearer" to comply with RFC 6750. David Radley (Jira)
• 2026/01/16 Re: [PR] [FLINK-36456] Add support to pass Datadog API Key as environment variable [flink] via GitHub
• 2026/01/16 [jira] [Updated] (FLINK-38934) Add binlog.ssl.protocol configuration for binlog client TLS ASF GitHub Bot (Jira)
• 2026/01/16 [PR] [FLINK-38934][cdc connector mysql] honour ssl protocol setting configured in debeziumProps [flink-cdc] via GitHub
• 2026/01/16 [jira] [Updated] (FLINK-38934) Add binlog.ssl.protocol configuration for binlog client TLS John Watson (Jira)
• 2026/01/16 [jira] [Comment Edited] (FLINK-38904) MySQL CDC binlog reader hangs due to TLS 1.3 KeyUpdate deadlock (potentially JDK-8241239) John Watson (Jira)
• 2026/01/16 Re: [PR] [plan][java] Built-in actions support async execution. [flink-agents] via GitHub
• 2026/01/16 [jira] [Updated] (FLINK-38934) Add binlog.ssl.protocol configuration for binlog client TLS John Watson (Jira)
• 2026/01/16 [jira] [Updated] (FLINK-38934) Add binlog.ssl.protocol configuration for binlog client TLS John Watson (Jira)
• 2026/01/16 [PR] [plan][java] Built-in actions support async execution. [flink-agents] via GitHub
• 2026/01/16 [jira] [Commented] (FLINK-38887) YAML Transform module supports nested types SkylerLin (Jira)
• 2026/01/16 Re: [PR] [log] Improve event logging [flink-agents] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38913][table-planner] ArrayIndexOutOfBoundsException unparsing CAST. [flink] via GitHub
• 2026/01/16 [jira] [Updated] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with computed rows including casts to null ASF GitHub Bot (Jira)
• 2026/01/16 [PR] [FLINK-38913][table-planner] ArrayIndexOutOfBoundsException unparsing CAST. [flink] via GitHub
• 2026/01/16 Re: [PR] [plan][python] Built-in actions support async execution. [flink-agents] via GitHub
• 2026/01/16 [jira] [Commented] (FLINK-38934) Debezium config 'binlog.ssl.protocol' is ignored John Watson (Jira)
• 2026/01/16 [jira] [Commented] (FLINK-38904) MySQL CDC binlog reader hangs due to TLS 1.3 KeyUpdate deadlock (potentially JDK-8241239) John Watson (Jira)
• 2026/01/16 [jira] [Created] (FLINK-38934) Debezium config 'binlog.ssl.protocol' is ignored John Watson (Jira)
• 2026/01/16 [PR] [log] Add config to set the event log path [flink-agents] via GitHub
• 2026/01/16 [I] [Feature] Improve event logging [flink-agents] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38886] Introduce `GenericRecordData` and Internal / External converters in flink-cdc-common [flink-cdc] via GitHub
• 2026/01/16 Re: [PR] checking Lyft diffs [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38878][runtime] Add parse_json function. [flink-cdc] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. [flink-cdc] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38886] Introduce `GenericRecordData` and Internal / External converters in flink-cdc-common [flink-cdc] via GitHub
• 2026/01/16 Re: [PR] checking Lyft diffs [flink] via GitHub
• 2026/01/16 Re: [PR] [hotfix] re-enable unit tests test_kafka.py for pyflink [flink] via GitHub
• 2026/01/16 Re: [PR] [hotfix] re-enable unit tests test_kafka.py for pyflink [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38909] Fix Unable to delete S3 checkpoint due to presence of default file [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38927] Support ON CONFLICT in SqlParser [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay [flink] via GitHub
• 2026/01/16 Re: [I] [Feature] Support Java Async Execution [flink-agents] via GitHub
• 2026/01/16 Re: [I] [Feature] Support Fine-Grain Durable Execution [flink-agents] via GitHub
• 2026/01/16 [I] [Feature][doc] Update documentation for async & durable execution [flink-agents] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay [flink] via GitHub
• 2026/01/16 Re: [I] [Feature] Support Fine-Grain Durable Execution [flink-agents] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] via GitHub
• 2026/01/16 Re: [I] [Feature] Support Java Async Execution [flink-agents] via GitHub
• 2026/01/16 Re: [PR] [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay [flink] via GitHub
• 2026/01/16 [jira] [Updated] (FLINK-38777) HistoryServer supports application archives ASF GitHub Bot (Jira)
• 2026/01/16 Re: [PR] [runtime] Support Java async execution [flink-agents] via GitHub
• 2026/01/16 [PR] [FLINK-38777][history] HistoryServer supports application archives [flink] via GitHub
• 2026/01/16 Re: [PR] [plan][python] Built-in actions support async execution. [flink-agents] via GitHub
• 2026/01/16 [jira] [Updated] (FLINK-38777) HistoryServer supports application archives Yi Zhang (Jira)
• 2026/01/16 Re: [PR] [runtime] Support Java async execution [flink-agents] via GitHub
• 2026/01/16 Re: [PR] [plan][python] Built-in actions support async execution. [flink-agents] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38289] Update to Flink 2.1 [flink-connector-kafka] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38924][docs] Redirect users to documentation home page when encountering a 404 [flink] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38289] Update to Flink 2.1 [flink-connector-kafka] via GitHub
• 2026/01/15 [jira] [Commented] (FLINK-38924) Redirect users to documentation home page when encountering a 404 Martijn Visser (Jira)
• 2026/01/15 [jira] [Updated] (FLINK-38924) Redirect users to documentation home page when encountering a 404 Martijn Visser (Jira)
• 2026/01/15 [jira] [Comment Edited] (FLINK-38817) Out of order data seen while running tpc-ds queries Zhu Zhu (Jira)
• 2026/01/15 [jira] [Commented] (FLINK-38817) Out of order data seen while running tpc-ds queries Zhu Zhu (Jira)
• 2026/01/15 Re: [PR] [fix][runtime] Fix async compaction of long-term memory in python [flink-agents] via GitHub
• 2026/01/15 [jira] [Updated] (FLINK-38933) python udx aligns with java udx Jacky Lau (Jira)
• 2026/01/15 [jira] [Updated] (FLINK-38933) python udx aligns with java udx Jacky Lau (Jira)
• 2026/01/15 [jira] [Created] (FLINK-38933) python udx supports get_index_of_this_subtask Jacky Lau (Jira)
• 2026/01/15 Re: [PR] Fix async compation [flink-agents] via GitHub
• 2026/01/15 [PR] Fix async compation [flink-agents] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay [flink] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay [flink] via GitHub
• 2026/01/15 [jira] [Updated] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay ASF GitHub Bot (Jira)
• 2026/01/15 [PR] [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay [flink] via GitHub
• 2026/01/15 [jira] [Created] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay Zhanghao Chen (Jira)
• 2026/01/15 Re: [PR] [FLINK-38851] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2026/01/15 [jira] [Created] (FLINK-38931) Support finish method in Python Table Function Dian Fu (Jira)
• 2026/01/15 Re: [PR] [fix][runtime] Fix not switch memory context for async action task. [flink-agents] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38920] create Table source and factory for DynamicKafkaSource in Flink Table API [flink-connector-kafka] via GitHub
• 2026/01/15 Re: [I] [Feature] Use class name to declare resources and provide constant for built-in resources. [flink-agents] via GitHub
• 2026/01/15 Re: [PR] [api ]Provide constant to point a resource to avoid importing integration package. [flink-agents] via GitHub
• 2026/01/15 Re: [PR] [fix][runtime] Fix not switch memory context for async action task. [flink-agents] via GitHub
• 2026/01/15 Re: [PR] [fix][runtime] Fix not switch memory context for async action task. [flink-agents] via GitHub
• 2026/01/15 [PR] [fix][runtime] Fix not switch memory context for async action task. [flink-agents] via GitHub
• 2026/01/15 [jira] [Updated] (FLINK-38530) create Dynamic Kafka Source for pyflink Dian Fu (Jira)
• 2026/01/15 [jira] [Closed] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka Dian Fu (Jira)
• 2026/01/15 Re: [PR] [FLINK-38917] add doc of pyflink DynamicKafkaSource to flink-connector-kafka [flink-connector-kafka] via GitHub
• 2026/01/15 Re: [PR] [hotfix] re-enable unit tests test_kafka.py for pyflink [flink] via GitHub
• 2026/01/15 Re: [PR] [hotfix] re-enable unit tests in pyflink test_kafka.py [flink] via GitHub
• 2026/01/15 [PR] [hotfix] re-enable unit tests in pyflink test_kafka.py [flink] via GitHub
• 2026/01/15 [jira] [Closed] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
• 2026/01/15 Re: [PR] [hotfix] re-enable unit tests test_kafka.py for pyflink [flink] via GitHub
• 2026/01/15 Re: [PR] [hotfix] re-enable unit tests in pyflink test_kafka.py [flink] via GitHub
• 2026/01/15 Re: [PR] [hotfix] re-enable unit tests in pyflink test_kafka.py [flink] via GitHub
• 2026/01/15 [PR] [hotfix] re-enable unit tests in pyflink test_kafka.py [flink] via GitHub
• 2026/01/15 Re: [PR] [hotfix] re-enable unit tests in pyflink test_kafka.py [flink] via GitHub
• 2026/01/15 Re: [PR] [hotfix] re-enable unit tests in pyflink test_kafka.py [flink] via GitHub
• 2026/01/15 [jira] [Commented] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
• 2026/01/15 Re: [PR] [FLINK-38876] Support per-cluster offset in Dynamic Kafka Source [flink-connector-kafka] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38876] Support per-cluster offset in Dynamic Kafka Source [flink-connector-kafka] via GitHub
• 2026/01/15 Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38851] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38876] Support per-cluster offset in Dynamic Kafka Source [flink-connector-kafka] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38876] Support per-cluster offset in Dynamic Kafka Source [flink-connector-kafka] via GitHub
• 2026/01/15 Re: [PR] [FLINK-38924][docs] Redirect users to documentation home page when encountering a 404 [flink] via GitHub
• 2026/01/15 [jira] [Commented] (FLINK-38925) Update Matomo URL to the right domain Martijn Visser (Jira)
• 2026/01/15 [jira] [Commented] (FLINK-38925) Update Matomo URL to the right domain Martijn Visser (Jira)
• 2026/01/15 [jira] [Commented] (FLINK-38925) Update Matomo URL to the right domain Martijn Visser (Jira)
• 2026/01/15 [jira] [Commented] (FLINK-38925) Update Matomo URL to the right domain Martijn Visser (Jira)
• 2026/01/15 [jira] [Closed] (FLINK-38922) Cache Maven dependencies during documentation build Martijn Visser (Jira)

• Earlier messages
• Later messages