issues  

Messages by Thread

• [jira] [Assigned] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Rui Fan (Jira)
• [PR] [hotfix][doc] Add flink-s3-fs-native in AGENTS.md [flink] via GitHub
  • Re: [PR] [hotfix][doc] Add flink-s3-fs-native in AGENTS.md [flink] via GitHub
  • Re: [PR] [hotfix][doc] Add flink-s3-fs-native in AGENTS.md [flink] via GitHub
• [jira] [Commented] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Aleksandr Savonin (Jira)
• [jira] [Commented] (FLINK-39709) Update documentation for native-s3-fs Gabor Somogyi (Jira)
• [jira] [Resolved] (FLINK-39709) Update documentation for native-s3-fs Gabor Somogyi (Jira)
• [jira] [Closed] (FLINK-39709) Update documentation for native-s3-fs Gabor Somogyi (Jira)
• [D] [Feature] Cross Language Actions [flink-agents] via GitHub
  • Re: [D] [Feature] Cross Language Actions [flink-agents] via GitHub
• [jira] [Commented] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters in Java clients Aleksandr Savonin (Jira)
  • [jira] [Commented] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters in Java clients Jubin Soni (Jira)
  • [jira] [Commented] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters in Java clients Aleksandr Savonin (Jira)
• [jira] [Resolved] (FLINK-35856) Upgrade Calcite version to 1.37.0 Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-35856) Upgrade Calcite version to 1.37.0 Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-36602) Upgrade Calcite version to 1.38.0 Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-35856) Upgrade Calcite version to 1.37.0 Sergey Nuyanzin (Jira)
• [jira] [Comment Edited] (FLINK-39692) Several catch blocks log the message but discard the captured exception Pavel Zeger (Jira)
• [jira] [Updated] (FLINK-39692) Several catch blocks log the message but discard the captured exception ASF GitHub Bot (Jira)
• [PR] [FLINK-39692][logging] Include caught exceptions in warn/error log statements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39692][logging] Include caught exceptions in warn/error log statements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39692][Kubernetes-Operator] Include caught exceptions in warn/error log statements [flink-kubernetes-operator] via GitHub
• [PR] FLINK-39691: fix toString for AggregatedMetric [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39691] Fix toString for AggregatedMetric [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-36567) Planner module didn't use the setting from flink-conf.yaml ASF GitHub Bot (Jira)
• [PR] [FLINK-36567][table] Honor io.tmp.dirs from flink-conf.yaml when extracting planner JAR [flink] via GitHub
  • Re: [PR] [FLINK-36567][table] Honor io.tmp.dirs from flink-conf.yaml when extracting planner JAR [flink] via GitHub
• [jira] [Updated] (FLINK-39718) Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
• [jira] [Updated] (FLINK-36561) ResultSet.wasNull() does not reflect null values in Flink JDBC Driver ASF GitHub Bot (Jira)
• [PR] [FLINK-36561][table] Fix ResultSet.wasNull() not reflecting per-column null values in JDBC driver [flink] via GitHub
  • Re: [PR] [FLINK-36561][table] Fix ResultSet.wasNull() not reflecting per-column null values in JDBC driver [flink] via GitHub
• [jira] [Comment Edited] (FLINK-39722) Support Fluss CDC Yaml Source liting liu (Jira)
• [jira] [Commented] (FLINK-39722) Support Fluss CDC Yaml Source Thorne (Jira)
  • [jira] [Commented] (FLINK-39722) Support Fluss CDC Yaml Source liting liu (Jira)
• [jira] [Assigned] (FLINK-39722) Support Fluss CDC Yaml Source Hongshun Wang (Jira)
• [jira] [Created] (FLINK-39722) Support Fluss CDC Yaml Source Hongshun Wang (Jira)
• [PR] [FLINK-39721] Support flink 1.18 compatibility for cdc runtime. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39721] Support flink 1.18 compatibility for cdc runtime. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39721] Support flink 1.18 compatibility for cdc runtime. [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39721) Flink CDC YAML framework should be compatibility with Flink 1.18. ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-39721) Flink CDC YAML framework should be compatibility with Flink 1.18. Hongshun Wang (Jira)
• [jira] [Created] (FLINK-39721) Flink CDC YAML framework should be compatibility with Flink 1.18. Hongshun Wang (Jira)
• [jira] [Updated] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode ASF GitHub Bot (Jira)
• [PR] [FLINK-39715] [table-planner] Fix IndexOutOfBoundsException in FlinkExpandConversionRule for global aggregate after sort [flink] via GitHub
  • Re: [PR] [FLINK-39715] [table-planner] Fix IndexOutOfBoundsException in FlinkExpandConversionRule for global aggregate after sort [flink] via GitHub
• [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink] via GitHub
  • Re: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink] via GitHub
  • Re: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink] via GitHub
• [jira] [Updated] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs lincoln lee (Jira)
• Re: [PR] [FLINK-39391][cdc-connector] Propagate scan.snapshot.fetch.size to Debezium properties in Oracle, SqlServer, DB2, and Postgres connectors [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39391][cdc-connector] Propagate scan.snapshot.fetch.size to Debezium properties in Oracle, SqlServer, DB2, and Postgres connectors [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39391][cdc-connector] Propagate scan.snapshot.fetch.size to Debezium properties in Oracle, SqlServer, DB2, and Postgres connectors [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39391][cdc-connector] Propagate scan.snapshot.fetch.size to Debezium properties in Oracle, SqlServer, DB2, and Postgres connectors [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-39709) Update documentation for native-s3-fs Gabor Somogyi (Jira)
• [jira] [Updated] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-39608] Change KafkaDatasetFacet to extend DatasetConfigFacet to fix classloader issues [flink-connector-kafka] via GitHub
• [PR] [FLINK-39718][paimon] Fix PaimonHashFunction failing when target table does not exist [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39718][pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39718][pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-22543) layout of exception history tab isn't very usable with Flink SQL Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters in Java clients Aleksandr Savonin (Jira)
  • [jira] [Updated] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters in Java clients Aleksandr Savonin (Jira)
• Re: [I] [Feature] Dynamically update the tool list when skill is loaded [flink-agents] via GitHub
• Re: [I] [Feature] Support loading agent skills form jar resource. [flink-agents] via GitHub
• [I] [Doc] Add doc and example for using skills [flink-agents] via GitHub
• Re: [I] [Feature] Support loading agent skills form python package. [flink-agents] via GitHub
• Re: [I] [Feature] Support loading skills from remote urls [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39383) [Docs] Improve scan.incremental.snapshot.chunk.key-column documentation for MySQL/PostgreSQL/Oracle/DB2/SQLServer connectors ASF GitHub Bot (Jira)
• [PR] [FLINK-39383][Docs] Improve scan.incremental.snapshot.chunk.key-column documentation for MySQL/PostgreSQL/Oracle/DB2/SQLServer connectors [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters Aleksandr Savonin (Jira)
  • [jira] [Updated] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters Aleksandr Savonin (Jira)
  • [jira] [Updated] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters Aleksandr Savonin (Jira)
• [jira] [Assigned] (FLINK-39719) TemporalRowTimeJoinOperator produces wrong results for late probe-side records Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39719) TemporalRowTimeJoinOperator produces wrong results for late probe-side records Fabian Hueske (Jira)
• [jira] [Updated] (FLINK-39705) Remove not needed ZooKeeper references from flink-connector-kafka ASF GitHub Bot (Jira)
• [PR] [FLINK-39705] Remove Zookeeper references [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39705] Remove Zookeeper references [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-39324][table-planner] Allow MultiJoin to respect IS_NOT_DISTICT_FROM when extracting join keys [flink] via GitHub
  • Re: [PR] [FLINK-39324][table-planner] Allow MultiJoin to respect IS_NOT_DISTICT_FROM when extracting join keys [flink] via GitHub
• [PR] [hotfix] Amend title in docs [flink-connector-http] via GitHub
  • Re: [PR] [hotfix] Amend title in docs [flink-connector-http] via GitHub
  • Re: [PR] [hotfix] Amend title in docs [flink-connector-http] via GitHub
• [jira] [Commented] (FLINK-34231) Fix typo in doc Arvind Kandpal (Jira)
• [PR] [FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document [flink] via GitHub
  • Re: [PR] [FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document [flink] via GitHub
  • Re: [PR] [FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document [flink] via GitHub
  • Re: [PR] [FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document [flink] via GitHub
  • Re: [PR] [FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document [flink] via GitHub
• [jira] [Commented] (FLINK-37422) Typo in streaming analytics zh document Arvind Kandpal (Jira)
  • [jira] [Commented] (FLINK-37422) Typo in streaming analytics zh document Arvind Kandpal (Jira)
• [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
  • [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
  • [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
  • [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
  • [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
  • [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
  • [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
  • [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
  • [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist Ran Tao (Jira)
  • [jira] [Updated] (FLINK-39718) [pipeline][paimon] Paimon pipeline sink fails with distributed source when target table does not exist ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39718) [pipeline][paimon] Paimon sink fails with distributed source when target table does not exist Ran Tao (Jira)
• [jira] [Commented] (FLINK-39383) [Docs] Improve scan.incremental.snapshot.chunk.key-column documentation for MySQL/PostgreSQL/Oracle/DB2/SQLServer connectors Thorne (Jira)
• [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.3) [flink] via GitHub
  • Re: [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.3) [flink] via GitHub
  • Re: [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.3) [flink] via GitHub
• [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.2) [flink] via GitHub
  • Re: [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.2) [flink] via GitHub
  • Re: [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.2) [flink] via GitHub
  • Re: [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.2) [flink] via GitHub
  • Re: [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.2) [flink] via GitHub
  • Re: [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.2) [flink] via GitHub
  • Re: [PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings (backport 2.2) [flink] via GitHub
• [jira] [Resolved] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39538) Support FROM_CHANGELOG: Flat stream with op codes → upsert stream Fabian Hueske (Jira)
• [PR] [FLINK-39379] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
  • Re: [PR] [FLINK-39379][table] Add state management to PTF test harness [flink] via GitHub
• [jira] [Updated] (FLINK-39379) Add support for state in ProcessTableFunctionTestHarness ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode Arvind Kandpal (Jira)
  • [jira] [Commented] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode Arvind Kandpal (Jira)
  • [jira] [Commented] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode Yaoxuan Wu (Jira)
  • [jira] [Commented] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode Arvind Kandpal (Jira)
  • [jira] [Commented] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode Arvind Kandpal (Jira)
• [jira] [Updated] (FLINK-39492) [Bug][StarRocks Connector] TIMESTAMP/TIMESTAMP_LTZ precision (microseconds) lost when sinking to StarRocks ASF GitHub Bot (Jira)
• [PR] FLINK-39492[starrocks] Fix microsecond precision loss for TIMESTAMP types in StarRocks sink [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39492][starrocks] Fix microsecond precision loss for TIMESTAMP types in StarRocks sink [flink-cdc] via GitHub
• [PR] [Flink 39717][docs] Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE [flink] via GitHub
  • Re: [PR] [Flink 39717][docs] Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE [flink] via GitHub
  • Re: [PR] [Flink 39717][docs] Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE [flink] via GitHub
• Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink] via GitHub
• Re: [PR] [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors [flink] via GitHub
  • Re: [PR] [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors [flink] via GitHub
• Re: [PR] [hotfix] make previousCpuTicks and previousProcCpuTicks volatile to increase visibility for all threads [flink] via GitHub
  • Re: [PR] [hotfix] make previousCpuTicks and previousProcCpuTicks volatile to increase visibility for all threads [flink] via GitHub
• Re: [PR] [FLINK-37422][docs] Fix typo in streaming analytics zh document [flink] via GitHub
  • Re: [PR] [FLINK-37422][docs] Fix typo in streaming analytics zh document [flink] via GitHub
• Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink] via GitHub
  • Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink] via GitHub
• Re: [PR] [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire [flink] via GitHub
  • Re: [PR] [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire [flink] via GitHub
• Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] via GitHub
• Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] via GitHub
  • Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] via GitHub
• Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] via GitHub
  • Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] via GitHub
• Re: [PR] [FLINK-31275] extend lineage listener with QueryOperationEvent [flink] via GitHub
  • Re: [PR] [FLINK-31275] extend lineage listener with QueryOperationEvent [flink] via GitHub
• Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink] via GitHub
  • Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink] via GitHub
• Re: [PR] [FLINK-37593][table] Add some Reduce Expression Rules [flink] via GitHub
  • Re: [PR] [FLINK-37593][table] Add some Reduce Expression Rules [flink] via GitHub
• Re: [PR] [FLINK-36161][docs]Update Integration Test Example with Sink API. [flink] via GitHub
  • Re: [PR] [FLINK-36161][docs]Update Integration Test Example with Sink API. [flink] via GitHub
• Re: [PR] add array aggregate function [flink] via GitHub
  • Re: [PR] add array aggregate function [flink] via GitHub
• Re: [PR] [FLINK-33449][table]Support array_contains_seq function [flink] via GitHub
  • Re: [PR] [FLINK-33449][table]Support array_contains_seq function [flink] via GitHub
• [jira] [Created] (FLINK-39717) Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE Ramin Gharib (Jira)
• [jira] [Commented] (FLINK-39034) fullWindowPartition + sortStream + STREAMING causes timestamps to be set to null Zhe Wang (Jira)
• [PR] [hotfix] Fix checkNotNull for Elasticsearch8AsyncSinkBuilder#setHeaders [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [hotfix] Fix checkNotNull for Elasticsearch8AsyncSinkBuilder#setHeaders [flink-connector-elasticsearch] via GitHub
• [jira] [Updated] (FLINK-39716) ES timeout related config used the wrong time unit ASF GitHub Bot (Jira)
• [PR] [FLINK-39716] Fix time unit for network timeout options [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-39716] Fix time unit for network timeout options [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-39716] Fix time unit for network timeout options [flink-connector-elasticsearch] via GitHub
• [jira] [Resolved] (FLINK-39672) Update doc about Java Records Leonard Xu (Jira)
• [jira] [Comment Edited] (FLINK-39672) Update doc about Java Records Leonard Xu (Jira)
• [jira] [Updated] (FLINK-39034) fullWindowPartition + sortStream + STREAMING causes timestamps to be set to null ASF GitHub Bot (Jira)
• [PR] [FLINK-39034][streaming] Fix timestamp loss in SortPartitionOperator [flink] via GitHub
  • Re: [PR] [FLINK-39034][streaming] Fix timestamp loss in SortPartitionOperator [flink] via GitHub
  • Re: [PR] [FLINK-39034][streaming] Fix timestamp loss in SortPartitionOperator [flink] via GitHub
• [jira] [Created] (FLINK-39716) ES timeout related config used the wrong time unit reswqa (Jira)
• [jira] [Commented] (FLINK-39492) [Bug][StarRocks Connector] TIMESTAMP/TIMESTAMP_LTZ precision (microseconds) lost when sinking to StarRocks Thorne (Jira)
• [jira] [Resolved] (FLINK-39706) Remove flink 2.1 testing from es connector main branch Weijie Guo (Jira)
• [jira] [Commented] (FLINK-39706) Remove flink 2.1 testing from es connector main branch Weijie Guo (Jira)
• [jira] [Updated] (FLINK-39622) [postgres] CustomPostgresSchema re-reads JDBC metadata for every split, causing O(N²) snapshot startup ASF GitHub Bot (Jira)
• [PR] [FLINK-39622] [postgres] Fix O(N²) JDBC metadata lookups in CustomPostgresSchema d… [flink-cdc] via GitHub
• [PR] [Feature][Integration][Java] Add built-in support for Azure OpenAI Chat Model [flink-agents] via GitHub
  • Re: [PR] [Feature][Integration][Java] Add built-in support for Azure OpenAI Chat Model [flink-agents] via GitHub
  • Re: [PR] [Feature][Integration][Java] Add built-in support for Azure OpenAI Chat Model [flink-agents] via GitHub

• Earlier messages
• Later messages