issues  

Messages by Thread

• • Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive] via GitHub
  • Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive] via GitHub
  • Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive] via GitHub
  • Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive] via GitHub
  • Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive] via GitHub
• [jira] [Closed] (FLINK-39106) Support ROW and ARRAY<ROW> data types in DynamoDB Table API / SQL sink Ferenc Csaky (Jira)
• Re: [I] [Doc] Add doc and example for using skills [flink-agents] via GitHub
• [jira] [Created] (FLINK-39789) AvroSchemaConverter.convertToDataType(String) ignores local-timestamp-* and timestamp-nanos logical types, silently maps to BIGINT Shekhar Prasad Rajak (Jira)
• Re: [I] [Feature] Support YAML api [flink-agents] via GitHub
• Re: [I] [doc] Add doc and example for introducing YAML API [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39788) Pekko error "Actor not found" when Kubernetes namespace starts from digit Vladislav Keda (Jira)
  • [jira] [Updated] (FLINK-39788) Pekko error "Actor not found" when Kubernetes namespace starts from digit Vladislav Keda (Jira)
• [jira] [Created] (FLINK-39788) Pekko error "Actor not found" when Kubernetes namespace starts from digit Vladislav Keda (Jira)
• Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-http] via GitHub
  • Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-http] via GitHub
• [jira] [Created] (FLINK-39787) Build broken for flink-benchmarks David Anderson (Jira)
• [jira] [Created] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure Samrat Deb (Jira)
• [jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join Martijn Visser (Jira)
• [jira] [Created] (FLINK-39785) Add end-to-end tests for LATERAL SNAPSHOT join Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39783) Add translation rules to convert lateral call of SNAPSHOT function into join operator Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39784) Add translation rule to block usage of SNAPSHOT function outside of LATERAL context Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39782) Add SNAPSHOT built-in table function definition Fabian Hueske (Jira)
• [jira] [Updated] (FLINK-39778) Recoverable writer silently loses the in-flight tail on resume ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39781) Add operator for LATERAL SNAPSHOT Join Fabian Hueske (Jira)
• [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
  • Re: [PR] [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume [flink] via GitHub
• [jira] [Created] (FLINK-39780) Make TABLE keyword optional in LATERAL context Fabian Hueske (Jira)
• [jira] [Assigned] (FLINK-39779) FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39779) FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39778) Recoverable writer silently loses the in-flight tail on resume Samrat Deb (Jira)
• Re: [D] Community Sync - 2026 [flink-agents] via GitHub
  • Re: [D] Community Sync - 2026 [flink-agents] via GitHub
  • Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• Re: [I] [Feature] [Integration][Java] Add built-in support for Azure OpenAI Chat Model [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator Mao Jiayi (Jira)
• [jira] [Updated] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator Yanquan Lv (Jira)
  • [jira] [Updated] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator Yanquan Lv (Jira)
  • [jira] [Updated] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-39776) Expose JobInfo on Source contexts Rui Fan (Jira)
• [jira] [Commented] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered Qilong Wang (Jira)
  • [jira] [Commented] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered Qilong Wang (Jira)
• [jira] [Created] (FLINK-39776) Expose JobInfo on Source contexts Aleksandr Savonin (Jira)
• Re: [PR] [FLINK-39732] Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation Samrat Deb (Jira)
• [jira] [Updated] (FLINK-39322) Add some restore tests about cascaded delta join ASF GitHub Bot (Jira)
• [PR] [FLINK-39322][table] Add restore tests for cascaded delta join [flink] via GitHub
  • Re: [PR] [FLINK-39322][table] Add restore tests for cascaded delta join [flink] via GitHub
• [jira] [Updated] (FLINK-39775) Snapshot split metadata is not released after switching to stream phase, causing large JobManager coordinator state and OOM with many snapshot splits yuanfenghu (Jira)
  • [jira] [Updated] (FLINK-39775) Snapshot split metadata is not released after switching to stream phase, causing large JobManager coordinator state and OOM with many snapshot splits ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39775) Snapshot split metadata is not released after switching to stream phase, causing large JobManager coordinator state and OOM with many snapshot splits yuanfenghu (Jira)
• [jira] [Updated] (FLINK-39764) Support dynamic table options in Table API ASF GitHub Bot (Jira)
• [PR] [FLINK-39764] Support dynamic table options in Table API [flink] via GitHub
  • Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink] via GitHub
  • Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink] via GitHub
  • Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink] via GitHub
  • Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink] via GitHub
  • Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink] via GitHub
  • Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink] via GitHub
• [jira] [Assigned] (FLINK-39650) REGEXP_REPLACE does not validate literal regex patterns at plan time and logs errors on the hot path Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-39648) Validate literal regex patterns at plan time and stop logging on the hot path for the regex function family Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-39651) REGEXP predicate does not validate literal regex patterns at plan time and logs errors on the hot path Ramin Gharib (Jira)
• [PR] [FLINK-39774] Format YEAR-MONTH interval keys as months instead of days [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-39774] Format YEAR-MONTH interval keys as months instead of days [flink-connector-elasticsearch] via GitHub
• [jira] [Created] (FLINK-39774) Format YEAR-MONTH interval keys as months instead of days Fan Deng (Jira)
• [PR] [FLINK-39773][tests] Use random ports in `ClusterEntryPointTest` [flink] via GitHub
  • Re: [PR] [FLINK-39773][tests] Use random ports in `ClusterEntryPointTest` [flink] via GitHub
  • Re: [PR] [FLINK-39773][tests] Use random ports in `ClusterEntryPointTest` [flink] via GitHub
  • Re: [PR] [FLINK-39773][tests] Use random ports in `ClusterEntryPointTest` [flink] via GitHub
  • Re: [PR] [FLINK-39773][tests] Use random ports in `ClusterEntryPointTest` [flink] via GitHub
• [jira] [Updated] (FLINK-39773) ClusterEntryPointTest fails on java25 Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39773) ClusterEntryPointTest fails on java25 Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39773) ClusterEntryPointTest fails on java25 ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39773) ClusterEntryPointTest fails on java25 Sergey Nuyanzin (Jira)
• Re: [PR] [hotfix][docs] Fix code examples and minor issues in DataStream documentation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix code examples and minor issues in DataStream documentation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix code examples and minor issues in DataStream documentation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix code examples and minor issues in DataStream documentation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix code examples and minor issues in DataStream documentation [flink] via GitHub
• [jira] [Assigned] (FLINK-39768) [JUnit5 Migration] Module: flink-avro - migrate AvroStreamingFileSinkITCase straggler Robert Metzger (Jira)
• [jira] [Updated] (FLINK-36267) SPLIT doesn't support SMP characters if delimiter is empty ASF GitHub Bot (Jira)
• [PR] [FLINK-36267][table] Fix SPLIT not preserving SMP characters when delimiter is empty [flink] via GitHub
  • Re: [PR] [FLINK-36267][table] Fix SPLIT not preserving SMP characters when delimiter is empty [flink] via GitHub
  • Re: [PR] [FLINK-36267][table] Fix SPLIT not preserving SMP characters when delimiter is empty [flink] via GitHub
• Re: [PR] [docs] Fix code examples and minor issues in DataStream documentation [flink] via GitHub
• [jira] [Resolved] (FLINK-39719) TemporalRowTimeJoinOperator produces wrong results for late probe-side records Fabian Hueske (Jira)
• Re: [PR] [FLINK-39719][table] Drop late probe records from TemporalRowTimeJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39719][table] Drop late probe records from TemporalRowTimeJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39719][table] Drop late probe records from TemporalRowTimeJoinOperator [flink] via GitHub
• Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
  • Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
  • Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
  • Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
  • Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
  • Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
  • Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
  • Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
  • Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
  • Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
• [jira] [Updated] (FLINK-39160) [Runtime][Rpc][Metrics] Expose RPC response frame size and oversized-response rejection metrics ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Yunfeng Zhou (Jira)
  • [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Yuepeng Pan (Jira)
• Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
  • Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
• Re: [PR] [FLINK-39160][Rpc] Add RPC response frame size metrics [flink] via GitHub
• Re: [PR] [FLINK-36540][Runtime] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink] via GitHub
• [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
  • Re: [PR] [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - AvroStreamingFileSinkITCase straggler [flink] via GitHub
• [jira] [Commented] (FLINK-39758) Fix error in canal json mysqlType when mysql type is varchar with no length Mao Jiayi (Jira)
• [jira] [Commented] (FLINK-39757) Fix kafka sink could not serialize debezium json with column default values Mao Jiayi (Jira)
• [jira] [Commented] (FLINK-39756) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-39756) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Yanquan Lv (Jira)
• Re: [PR] [FLINK-39414] TaskExecutorPartitionLifecycleTest#testEnableBatchJobRecoveryAnd* take long time to complete [flink] via GitHub
• [jira] [Assigned] (FLINK-39216) [Kubernetes Operator] Add PKCS12 profile option for webhook certificate to support FIPS environments Gyula Fora (Jira)
• [jira] [Assigned] (FLINK-39771) [JUnit5 Migration] Module: flink-cep Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39771) [JUnit5 Migration] Module: flink-cep Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39770) [JUnit5 Migration] Module: flink-state-processing-api Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-39770) [JUnit5 Migration] Module: flink-state-processing-api Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-39769) [JUnit5 Migration] Module: flink-examples-streaming Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39769) [JUnit5 Migration] Module: flink-examples-streaming Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-39767) [JUnit5 Migration] Module: flink-statebackend-forst Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
  • Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• [jira] [Commented] (FLINK-39639) Split assignment accepted after source finished reading leads to silent data loss Calico Shop (Jira)
• [jira] [Resolved] (FLINK-39751) Introduce FailsOnJava25 Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39751) Introduce FailsOnJava25 Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• [jira] [Assigned] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0 Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0 Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
  • Re: [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
  • Re: [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
  • Re: [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
• [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) [flink] via GitHub
  • Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) [flink] via GitHub
  • Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) [flink] via GitHub
  • Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) [flink] via GitHub
  • Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) [flink] via GitHub
• [jira] [Commented] (FLINK-38468) Performance drops when the coalesce parameter includes functions Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-38468][flink-table-planner] When the coalesce parameter contains a function, convert it to case when [flink] via GitHub
  • Re: [PR] [FLINK-38468][flink-table-planner] When the coalesce parameter contains a function, convert it to case when [flink] via GitHub
• [jira] [Resolved] (FLINK-38468) Performance drops when the coalesce parameter includes functions Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39577) Reuse Calcite's COALESCE to apply simplifications from RexSimplify Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39577) Reuse Calcite's COALESCE to apply simplifications from RexSimplify Sergey Nuyanzin (Jira)
• Re: [PR] [hotfix][build] Update CI to support Flink 2.0 [flink-connector-aws] via GitHub
  • Re: [PR] [hotfix][build] Update CI to support Flink 2.0 [flink-connector-aws] via GitHub
• Re: [PR] [hotfix][build] Update Python CI Java version to fix CI [flink-connector-aws] via GitHub
  • Re: [PR] [hotfix][build] Update Python CI Java version to fix CI [flink-connector-aws] via GitHub
• [jira] [Assigned] (FLINK-39660) Kinesis Connector - Cascading failure in EFO subscription lifecycle Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-39660) Kinesis Connector - Cascading failure in EFO subscription lifecycle Ferenc Csaky (Jira)
• [jira] [Closed] (FLINK-39660) Kinesis Connector - Cascading failure in EFO subscription lifecycle Ferenc Csaky (Jira)
• [jira] [Closed] (FLINK-37949) FlinkKinesisConsumer on EFO mode runs into Netty deadlock on client close during stop-with-savepoint Ferenc Csaky (Jira)
• [jira] [Closed] (FLINK-37648) Flink Kinesis connector lost track of 1 shard. Ferenc Csaky (Jira)
• [jira] [Assigned] (FLINK-39540) Kinesis Connector -Address end of subscription behavior bug for Kinesis EFO Ferenc Csaky (Jira)
• [jira] [Closed] (FLINK-39540) Kinesis Connector -Address end of subscription behavior bug for Kinesis EFO Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-39540) Kinesis Connector -Address end of subscription behavior bug for Kinesis EFO Ferenc Csaky (Jira)
• [jira] [Resolved] (FLINK-39145) UnalignedCheckpointITCase.execute fails Rui Fan (Jira)

• Earlier messages
• Later messages