issues  

Messages by Thread

• [jira] [Resolved] (FLINK-38907) Records lost using filtered autocreate mode Hongshun Wang (Jira)
• [jira] [Assigned] (FLINK-38907) Records lost using filtered autocreate mode Hongshun Wang (Jira)
• [jira] [Updated] (FLINK-38907) Records lost using filtered autocreate mode Hongshun Wang (Jira)
  • [jira] [Updated] (FLINK-38907) Records lost using filtered autocreate mode Hongshun Wang (Jira)
• Re: [PR] [FLINK-40808] Add PyPI publishing support for apache-flink-connector-aws [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-40808] Add PyPI publishing support for apache-flink-connector-aws [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-40808] Add PyPI publishing support for apache-flink-connector-aws [flink-connector-aws] via GitHub
• [PR] [FLINK-40992][operator] Allow the job parallelism to take effect when TaskManager replicas are set [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Gyula Fora (Jira)
  • [jira] [Commented] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Tomoyuki NAKAMURA (Jira)
  • [jira] [Commented] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Gyula Fora (Jira)
• [jira] [Closed] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Dian Fu (Jira)
• [jira] [Comment Edited] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Dian Fu (Jira)
• [jira] [Created] (FLINK-40992) Allow spec.job.parallelism to take effect when spec.taskManager.replicas is set, to support standby TaskManagers in standalone mode Tomoyuki NAKAMURA (Jira)
• [jira] [Updated] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Tomoyuki NAKAMURA (Jira)
• [PR] [FLINK-40991] Read the legacy ClusterHealthInfo healthy field [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Tomoyuki NAKAMURA (Jira)
• Re: [PR] [FLINK-40835][state] Forward bulk reads in CompressibleFSDataInputStream [flink] via GitHub
• [PR] [fix] Updated documentation based on changes in version 3.7.0. [flink-cdc] via GitHub
  • Re: [PR] [fix] Updated documentation based on changes in version 3.7.0. [flink-cdc] via GitHub
• Re: [I] [Feature] Support registering ReActAgent as a general-purpose subagent [flink-agents] via GitHub
• [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
• [I] [Doc] Improve Skills usage and source-loading documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Skills usage and source-loading documentation [flink-agents] via GitHub
• [I] [Doc] Improve Chat with Models and message documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Chat with Models and message documentation [flink-agents] via GitHub
• [I] [Doc] Improve Chat Models and built-in provider documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Chat Models and built-in provider documentation [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee Xiqian Yu (Jira)
• Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
  • Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
  • Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
  • Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
  • Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
• Re: [PR] [api][plan][runtime][java][python] Support bounded internal sub-agent batches [flink-agents] via GitHub
  • Re: [PR] [api][plan][runtime][java][python] Support bounded internal sub-agent batches [flink-agents] via GitHub
• [PR] [BP-2.3][FLINK-40969][runtime] Fix rescale details lookup for evicted latest events. [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40969][runtime] Fix rescale details lookup for evicted latest events. [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40969][runtime] Fix rescale details lookup for evicted latest events. [flink] via GitHub
• Re: [PR] [FLINK-39440]support mysql capture-data-with-rate-limit [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39440]support mysql capture-data-with-rate-limit [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee ASF GitHub Bot (Jira)
• [PR] [FLINK-40983][docs][pipeline-connector/kafka] Document sink.delivery-guarantee [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40983][docs][pipeline-connector/kafka] Document sink.delivery-guarantee [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40153) CREATE TABLE LIKE cannot resolve inherited metadata columns in a derived watermark expression lincoln lee (Jira)
• [jira] [Created] (FLINK-40988) Bump JUnit to 5.14 Martijn Visser (Jira)
• [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
• [PR] [FLINK-40986][python] Make named Row hashing consistent with equality [flink] via GitHub
  • Re: [PR] [FLINK-40986][python] Make named Row hashing consistent with equality [flink] via GitHub
  • Re: [PR] [FLINK-40986][python] Make named Row hashing consistent with equality [flink] via GitHub
• [jira] [Created] (FLINK-40987) Allow overriding or disabling a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
• Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
• [PR] [FLINK-33020][ci] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch] via GitHub
  • Re: [PR] [FLINK-33020][ci] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch] via GitHub
  • Re: [PR] [FLINK-33020][ci] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch] via GitHub
• [PR] [integrations][java] List Jackson enum values in OpenAI, Azure and Anthropic native schemas [flink-agents] via GitHub
  • Re: [PR] [integrations][java] List Jackson enum values in OpenAI, Azure and Anthropic native schemas [flink-agents] via GitHub
• Re: [PR] [FLINK-40354][state/forst] Configure the TTL compaction filter for State V2 states [flink] via GitHub
• [PR] [FLINK-40988][tests] Bump JUnit to 5.14.4 [flink] via GitHub
  • Re: [PR] [FLINK-40988][tests] Bump JUnit to 5.14.4 [flink] via GitHub
  • Re: [PR] [FLINK-40988][tests] Bump JUnit to 5.14.4 [flink] via GitHub
• [PR] [runtime] Count restored input runs once when tasks identify them first [flink-agents] via GitHub
  • Re: [PR] [runtime] Count restored input runs once when tasks identify them first [flink-agents] via GitHub
  • Re: [PR] [runtime] Count restored input runs once when tasks identify them first [flink-agents] via GitHub
  • Re: [PR] [runtime] Count restored input runs once when tasks identify them first [flink-agents] via GitHub
• [jira] [Created] (FLINK-40990) MySQL CDC source suppresses terminal missing-schema errors and keeps checkpointing without CDC Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-40989) MAP equality compares numeric values by reference Martijn Visser (Jira)
• Re: [PR] [FLINK-24908][table-planner] Show the position and the failing line in parse errors [flink] via GitHub
  • Re: [PR] [FLINK-24908][table-planner] Show the position and the failing line in parse errors [flink] via GitHub
• [jira] [Resolved] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40988) Bump JUnit to 5.14 Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40988) Bump JUnit to 5.14 ASF GitHub Bot (Jira)
• [PR] [FLINK-40968][table] Fix Table API map() op_mapping in changelog PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40968][table] Fix Table API map() op_mapping in changelog PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40968][table] Fix Table API map() op_mapping in changelog PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40968][table] Fix Table API map() op_mapping in changelog PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40968][table] Fix Table API map() op_mapping in changelog PTFs [flink] via GitHub
• [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Mohsen Rezaei (Jira)
  • [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Mohsen Rezaei (Jira)
  • [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Zakelly Lan (Jira)
  • [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Zakelly Lan (Jira)
  • [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Mohsen Rezaei (Jira)
• [jira] [Updated] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Zakelly Lan (Jira)
• Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
• [jira] [Comment Edited] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Mohsen Rezaei (Jira)
• [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
  • Re: [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
  • Re: [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
  • Re: [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
  • [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
  • Re: [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
  • [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
  • Re: [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
  • Re: [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
• Re: [PR] [FLINK-40615][Connectors/Kafka] fix: Prevent duplicate partition assignment in KafkaSourceEnumerator [flink-connector-kafka] via GitHub
• [I] [Bug][integrations][java] OpenAI, Azure OpenAI and Anthropic native schemas list annotated enums by Java name [flink-agents] via GitHub
  • Re: [I] [Bug][integrations][java] OpenAI, Azure OpenAI and Anthropic native schemas list annotated enums by Java name [flink-agents] via GitHub
• Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
  • Re: [PR] [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster [flink] via GitHub
• [jira] [Commented] (FLINK-40962) LAG() unsupported for TIMESTAMP_LTZ arguments in batch mode ChenZhuo (Jira)
• [jira] [Closed] (FLINK-39163) Support ML_PREDICT in Flink Python API Dian Fu (Jira)
• [jira] [Closed] (FLINK-40439) Add model provider management to DataFrame API Dian Fu (Jira)
• [jira] [Closed] (FLINK-40425) Add OVER window aggregation support to DataFrame API Dian Fu (Jira)
• [PR] [docs] Restructure documentation navigation and guides for 0.4 [flink-agents] via GitHub
  • Re: [PR] [docs] Restructure documentation navigation and guides for 0.4 [flink-agents] via GitHub
• [jira] [Comment Edited] (FLINK-40962) LAG() unsupported for TIMESTAMP_LTZ arguments in batch mode ChenZhuo (Jira)
• [jira] [Updated] (FLINK-35376) When flink submits the job by calling the rest api, the dependent jar package generated to the tmp is not removed ASF GitHub Bot (Jira)
• [PR] [FLINK-35376][runtime] Avoid duplicate PackagedProgram in REST JAR handlers [flink] via GitHub
  • Re: [PR] [FLINK-35376][runtime] Avoid duplicate PackagedProgram in REST JAR handlers [flink] via GitHub
  • Re: [PR] [FLINK-35376][runtime] Avoid duplicate PackagedProgram in REST JAR handlers [flink] via GitHub
  • Re: [PR] [FLINK-35376][runtime] Avoid duplicate PackagedProgram in REST JAR handlers [flink] via GitHub
  • Re: [PR] [FLINK-35376][runtime] Avoid duplicate PackagedProgram in REST JAR handlers [flink] via GitHub
• [jira] [Updated] (FLINK-40986) Equal named Rows can have different hash values in PyFlink ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Dian Fu (Jira)
• [I] [Feature] Support decision models in Flink Agents [flink-agents] via GitHub
  • Re: [I] [Feature] Support decision models in Flink Agents [flink-agents] via GitHub
• [jira] [Created] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Biao Geng (Jira)
• [PR] [FLINK-40902][docs] Remove equi-predicate requirement from Table API LATERAL SNAPSHOT join docs [flink] via GitHub
  • Re: [PR] [FLINK-40902][docs] Remove equi-predicate requirement from Table API LATERAL SNAPSHOT join docs [flink] via GitHub
  • Re: [PR] [FLINK-40902][docs] Remove equi-predicate requirement from Table API LATERAL SNAPSHOT join docs [flink] via GitHub
• [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
• Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
  • Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• [jira] [Created] (FLINK-40985) [Iceberg] Support per-table location override in Iceberg pipeline sink VISHAL B (Jira)
• [jira] [Resolved] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40902) LATERAL SNAPSHOT join wrongly rejected when a local filter targets the join key column Fabian Hueske (Jira)
• [jira] [Resolved] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation Martijn Visser (Jira)
• Re: [PR] [FLINK-40853][postgres] Skip LSN commit for checkpoints without a stream offset [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40853][postgres] Skip LSN commit for checkpoints without a stream offset [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40853][postgres] Skip LSN commit for checkpoints without a stream offset [flink-cdc] via GitHub

• Earlier messages
• Later messages