issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/06/04
Re: [PR] [FLINK-39136][BP 2.0][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink]
via GitHub
2026/06/04
[jira] [Resolved] (FLINK-39836) Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard
Yuepeng Pan (Jira)
2026/06/04
[jira] [Commented] (FLINK-39836) Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard
Yuepeng Pan (Jira)
2026/06/04
Re: [PR] [FLINK-39136][BP 2.1][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink]
via GitHub
2026/06/04
Re: [PR] [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard [flink]
via GitHub
2026/06/04
Re: [PR] [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard [flink]
via GitHub
2026/06/04
[jira] [Commented] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency
Yunfeng Zhou (Jira)
2026/06/04
[jira] [Commented] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning
Yunfeng Zhou (Jira)
2026/06/04
Re: [PR] [hotfix][docs] Fix typo and heading level in state backends documentation [flink]
via GitHub
2026/06/04
Re: [PR] [hotfix][table-runtime] Fix typo in RowTimeMiniBatchAssignerOperator class name [flink]
via GitHub
2026/06/04
Re: [PR] [hotfix] Fix flaky tests [flink]
via GitHub
2026/06/04
[jira] [Closed] (FLINK-39826) Strengthen autoscaler configuration validation
Gyula Fora (Jira)
2026/06/04
Re: [PR] [hotfix] Correct fabric8 version to 7.3.1 in NOTICE files [flink-kubernetes-operator]
via GitHub
2026/06/04
[PR] [metric] Add key-value metric group for model and action dimensions [flink-agents]
via GitHub
2026/06/04
Re: [PR] [FLINK-39826][autoscaler] Strengthen autoscaler configuration validation [flink-kubernetes-operator]
via GitHub
2026/06/04
Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink]
via GitHub
2026/06/04
Re: [PR] [hotfix][test] Finalize JUnit 5 migration and prune unused test dependencies [flink-kubernetes-operator]
via GitHub
2026/06/04
Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink]
via GitHub
2026/06/04
[jira] [Closed] (FLINK-39808) Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern
Gyula Fora (Jira)
2026/06/04
Re: [PR] [FLINK-39808] Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern [flink-kubernetes-operator]
via GitHub
2026/06/04
[jira] [Closed] (FLINK-39819) Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString
Gyula Fora (Jira)
2026/06/04
Re: [PR] [FLINK-39819] Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString [flink-kubernetes-operator]
via GitHub
2026/06/04
[jira] [Commented] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning
Jira
2026/06/04
[jira] [Updated] (FLINK-39845) SavepointITCase.testStopWithSavepointFailsOverToSavepoint fails on AdaptiveScheduler after JUnit5 migration
Martijn Visser (Jira)
2026/06/04
[jira] [Created] (FLINK-39845) SavepointITCase.testStopWithSavepointFailsOverToSavepoint fails on AdaptiveScheduler after JUnit5 migration
Martijn Visser (Jira)
2026/06/04
[I] [Tech Debt] Manual verification memory section of user documentation [flink-agents]
via GitHub
2026/06/04
Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink]
via GitHub
2026/06/04
[I] [Tech Debt] Manual verification workflow section of user documentation [flink-agents]
via GitHub
2026/06/04
Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink]
via GitHub
2026/06/04
Re: [PR] [FLINK-39839][table] Supports timeout in AsyncTableFunction [flink]
via GitHub
2026/06/04
[jira] [Commented] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning
Yunfeng Zhou (Jira)
2026/06/04
Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink]
via GitHub
2026/06/04
Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink]
via GitHub
2026/06/04
Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink]
via GitHub
2026/06/04
[PR] [FLINK-39839][table] Supports timeout in AsyncTableFunction [flink]
via GitHub
2026/06/04
[jira] [Updated] (FLINK-39839) FLIP-580:AsyncTableFunction supports user-defined timeout handling logic
ASF GitHub Bot (Jira)
2026/06/04
Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink]
via GitHub
2026/06/04
[jira] [Commented] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions
Yunfeng Zhou (Jira)
2026/06/04
[jira] [Updated] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode
Yuepeng Pan (Jira)
2026/06/04
[jira] [Updated] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode
Yunfeng Zhou (Jira)
2026/06/04
Re: [PR] [FLINK-39816] Ship parsson into es8 uber jar [flink-connector-elasticsearch]
via GitHub
2026/06/04
[jira] [Commented] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode
Yunfeng Zhou (Jira)
2026/06/04
Re: [PR] [FLINK-38980][table] Migrate RemoveRedundantLocalSortAggRule to java [flink]
via GitHub
2026/06/04
Re: [PR] [FLINK-38374][SQL API] Introduce new ARTIFACT keyword as an alternative to JAR [flink]
via GitHub
2026/06/04
Re: [PR] [FLINK-39608] Change KafkaDatasetFacet to extend DatasetConfigFacet to fix classloader issues [flink-connector-kafka]
via GitHub
2026/06/04
[jira] [Closed] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage
Jira
2026/06/04
[jira] [Assigned] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage
Jira
2026/06/04
Re: [PR] [FLINK-39608] Change KafkaDatasetFacet to extend DatasetConfigFacet to fix classloader issues [flink-connector-kafka]
via GitHub
2026/06/04
Re: [PR] [FLINK-39608] Change KafkaDatasetFacet to extend DatasetConfigFacet to fix classloader issues [flink-connector-kafka]
via GitHub
2026/06/04
[jira] [Updated] (FLINK-39844) PostgreSQL CDC: filter table columns by schema name to fix LIKE-wildcard cross-schema column leakage
ASF GitHub Bot (Jira)
2026/06/04
[PR] [FLINK-39844][postgres] Filter snapshot table columns by schema name to fix LIKE-wildcard cross-schema column leakage [flink-cdc]
via GitHub
2026/06/04
Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink]
via GitHub
2026/06/04
[jira] [Created] (FLINK-39844) PostgreSQL CDC: filter table columns by schema name to fix LIKE-wildcard cross-schema column leakage
Di Wu (Jira)
2026/06/04
Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink]
via GitHub
2026/06/04
Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc]
via GitHub
2026/06/04
Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink]
via GitHub
2026/06/04
[PR] [FLINK-39838] Bump Flink version to 1.20.4 [flink-kubernetes-operator]
via GitHub
2026/06/04
[jira] [Updated] (FLINK-39840) Oracle pipeline connector emits incomplete table identifiers for data and schema change events
tianfy (Jira)
2026/06/04
[jira] [Updated] (FLINK-39838) Bump Flink version to 1.20.4 in flink-kubernetes-operator
ASF GitHub Bot (Jira)
2026/06/04
[I] [Tech Debt] Add document for Mem0 vector store provider [flink-agents]
via GitHub
2026/06/04
[PR] [api][java][python] Introduce EventType constants and unify Action trigger entry [flink-agents]
via GitHub
2026/06/04
[jira] [Updated] (FLINK-39843) Support Oracle CDC streaming with the XStream adapter
ASF GitHub Bot (Jira)
2026/06/04
[PR] [FLINK-39843][oracle-cdc] Support Oracle XStream streaming [flink-cdc]
via GitHub
2026/06/04
[jira] [Updated] (FLINK-39842) Support timestamp startup mode for Oracle CDC by resolving timestamps to SCN
ASF GitHub Bot (Jira)
2026/06/04
[jira] [Updated] (FLINK-39841) Add an option to skip Oracle ANALYZE TABLE before incremental snapshot chunk planning
ASF GitHub Bot (Jira)
2026/06/04
[PR] [FLINK-39842][oracle-cdc] Support timestamp startup by resolving SCN [flink-cdc]
via GitHub
2026/06/04
[PR] [FLINK-39841][oracle-cdc] Add option to skip analyze table before chunk planning [flink-cdc]
via GitHub
2026/06/04
[jira] [Updated] (FLINK-39840) Oracle pipeline connector emits incomplete table identifiers for data and schema change events
ASF GitHub Bot (Jira)
2026/06/04
[PR] [FLINK-39840][pipeline-connector/oracle] Fix Oracle pipeline table identifiers [flink-cdc]
via GitHub
2026/06/04
[jira] [Created] (FLINK-39843) Support Oracle CDC streaming with the XStream adapter
tianfy (Jira)
2026/06/04
[jira] [Created] (FLINK-39842) Support timestamp startup mode for Oracle CDC by resolving timestamps to SCN
tianfy (Jira)
2026/06/04
[jira] [Created] (FLINK-39841) Add an option to skip Oracle ANALYZE TABLE before incremental snapshot chunk planning
tianfy (Jira)
2026/06/04
[jira] [Created] (FLINK-39840) Oracle pipeline connector emits incomplete table identifiers for data and schema change events
tianfy (Jira)
2026/06/04
[I] [Tech Debt] Update FAQ: cross-language async limitation is outdated [flink-agents]
via GitHub
2026/06/03
[jira] [Updated] (FLINK-39839) FLIP-580:AsyncTableFunction supports user-defined timeout handling logic
Yuan Kui (Jira)
2026/06/03
[jira] [Updated] (FLINK-39839) FLIP-580:AsyncTableFunction supports user-defined timeout handling logic
Yuan Kui (Jira)
2026/06/03
[jira] [Updated] (FLINK-39839) FLIP-580:AsyncTableFunction supports user-defined timeout handling logic
Yuan Kui (Jira)
2026/06/03
[jira] [Created] (FLINK-39839) AsyncTableFunction supports user-defined timeout handling logic
Yuan Kui (Jira)
2026/06/03
Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink]
via GitHub
2026/06/03
Re: [I] [Tech Debt] Add a document for Support TTL on Short Term Memory [flink-agents]
via GitHub
2026/06/03
[jira] [Created] (FLINK-39838) Bump Flink version to 1.20.4 in flink-kubernetes-operator
Purushottam Sinha (Jira)
2026/06/03
Re: [PR] [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard [flink]
via GitHub
2026/06/03
[PR] [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard [flink]
via GitHub
2026/06/03
[I] [Feature] Track Action by Event Field Values work [flink-agents]
via GitHub
2026/06/03
Re: [I] [Tech Debt] Add a document for Support TTL on Short Term Memory [flink-agents]
via GitHub
2026/06/03
[I] [Tech Debt] Add a document for Support TTL on Short Term Memory [flink-agents]
via GitHub
2026/06/03
Re: [PR] [docs] Update the FAQ section for release 0.3 [flink-agents]
via GitHub
2026/06/03
Re: [D] [Discussion] Trigger action by Event Field Values [flink-agents]
via GitHub
2026/06/03
Re: [I] [Tech Debt] Add document for retries ability of MCPServer [flink-agents]
via GitHub
2026/06/03
[I] [Tech Debt] Add document for retries ability of MCPServer [flink-agents]
via GitHub
2026/06/03
[I] [Tech Debt] Fix JAR copy instruction in installation doc after common/thin JAR split [flink-agents]
via GitHub
2026/06/03
Re: [I] [Tech Debt] Add document for async execution support of cross-language resources [flink-agents]
via GitHub
2026/06/03
[I] [Tech Debt] Add document for async execution support of cross-language resources [flink-agents]
via GitHub
2026/06/03
[I] [Tech Debt] Update Document version number from 0.2.0 and 0.2.1 [flink-agents]
via GitHub
2026/06/03
[I] [Tech Debt] Add Document for Table API Example [flink-agents]
via GitHub
2026/06/03
Re: [PR] [FLINK-39832] Fix Oracle NUMBER(p,0) with p>=19 incorrectly mapped to BIGINT [flink-cdc]
via GitHub
2026/06/03
[I] [Tech Debt] Add document for retries ability of MPCServer, MCPTool and MCPPrompt [flink-agents]
via GitHub
2026/06/03
Re: [PR] [FLINK-39797] Support disabling automatic table creation [flink-cdc]
via GitHub
2026/06/03
[I] [Tech Debt] Add document for custom job name [flink-agents]
via GitHub
2026/06/03
Re: [PR] [FLINK-39816] Ship parsson into es8 uber jar [flink-connector-elasticsearch]
via GitHub
2026/06/03
Re: [PR] [hotfix] Use explicit UTF-8 charset in coerceToBytes and guard Optional.get() in Kafka serializers [flink-cdc]
via GitHub
2026/06/03
[PR] [hotfix] Guard Optional.get() in Kafka and StarRocks connector schema lookups [flink-cdc]
via GitHub
2026/06/03
[PR] [hotfix] Guard Optional.get() in Doris connector schema lookups [flink-cdc]
via GitHub
2026/06/03
[PR] [hotfix] Use explicit UTF-8 charset in getBytes() calls across connectors [flink-cdc]
via GitHub
2026/06/03
Re: [PR] [hotfix] Use explicit UTF-8 charset in coerceToBytes and guard Optional.get() in Kafka serializers [flink-cdc]
via GitHub
2026/06/03
[jira] [Commented] (FLINK-39836) Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard
Yuepeng Pan (Jira)
2026/06/03
Re: [PR] [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-XXXXX][table] Refactor changelog inference program [flink]
via GitHub
2026/06/03
[PR] [FLINK-XXXXX][table] Refactor changelog inference program [flink]
via GitHub
2026/06/03
[jira] [Comment Edited] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant
Robert Yokota (Jira)
2026/06/03
Re: [PR] [FLINK-39711][runtime] Expose maxExceptions on exception message parameters [flink]
via GitHub
2026/06/03
[jira] [Comment Edited] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant
Robert Yokota (Jira)
2026/06/03
Re: [PR] [FLINK-39478][mysql] Persist checkpointIdToFinish and expose enumerat or metrics [flink-cdc]
via GitHub
2026/06/03
[jira] [Comment Edited] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant
Robert Yokota (Jira)
2026/06/03
[jira] [Commented] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant
Robert Yokota (Jira)
2026/06/03
Re: [PR] [hotfix] Correct fabric8 version to 7.3.1 in NOTICE files [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive]
via GitHub
2026/06/03
Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive]
via GitHub
2026/06/03
Re: [PR] [FLINK-39481][tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets [flink]
via GitHub
2026/06/03
[jira] [Created] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability
Xin Gao (Jira)
2026/06/03
Re: [PR] [FLINK-39481][tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets [flink]
via GitHub
2026/06/03
Re: [PR] Rewrite security page with precise trust model and operator coverage [flink-web]
via GitHub
2026/06/03
Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink]
via GitHub
2026/06/03
Re: [PR] [docs] Update the FAQ section for release 0.3 [flink-agents]
via GitHub
2026/06/03
Re: [PR] [docs] Update the FAQ section for release 0.3 [flink-agents]
via GitHub
2026/06/03
Re: [PR] [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink]
via GitHub
2026/06/03
[jira] [Updated] (FLINK-39836) Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard
ASF GitHub Bot (Jira)
2026/06/03
[PR] [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard [flink]
via GitHub
2026/06/03
[jira] [Created] (FLINK-39836) Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard
Yuepeng Pan (Jira)
2026/06/03
Re: [PR] Rewrite security page with precise trust model and operator coverage [flink-web]
via GitHub
2026/06/03
Re: [PR] Rewrite security page with precise trust model and operator coverage [flink-web]
via GitHub
2026/06/03
Re: [PR] [FLINK-39752] Thread EventRecorder through FlinkResourceContext instead of holding it on the factory [flink-kubernetes-operator]
via GitHub
2026/06/03
[jira] [Updated] (FLINK-39752) Thread EventRecorder through FlinkResourceContext instead of holding it on the factory
Dennis-Mircea Ciupitu (Jira)
2026/06/03
Re: [PR] [FLINK-39816] Ship parsson into es8 uber jar [flink-connector-elasticsearch]
via GitHub
2026/06/03
Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive]
via GitHub
2026/06/03
Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive]
via GitHub
2026/06/03
Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive]
via GitHub
2026/06/03
Re: [PR] [FLINK-39752] Thread EventRecorder through FlinkResourceContext instead of holding it on the factory [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] [FLINK-39819] Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] [FLINK-39808] Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern [flink-kubernetes-operator]
via GitHub
2026/06/03
[jira] [Closed] (FLINK-39814) FlinkStateSnapshot-triggered savepoints ignore the referenced FlinkSessionJob state.savepoints.dir
Gyula Fora (Jira)
2026/06/03
Re: [PR] [FLINK-39814] Honor FlinkSessionJob savepoint dir in snapshots [flink-kubernetes-operator]
via GitHub
2026/06/03
[jira] [Commented] (FLINK-39800) Extend Restore test coverage for TO_CHANGELOG / FROM_CHANGELOG
Gustavo de Morais (Jira)
2026/06/03
[jira] [Closed] (FLINK-39800) Extend Restore test coverage for TO_CHANGELOG / FROM_CHANGELOG
Gustavo de Morais (Jira)
2026/06/03
Re: [PR] [FLINK-39136][BP 1.20][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink]
via GitHub
2026/06/03
[PR] [FLINK-39136][BP 1.20][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39136][BP 2.2][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39136][BP 2.3][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink]
via GitHub
2026/06/03
[jira] [Closed] (FLINK-39216) [Kubernetes Operator] Add PKCS12 profile option for webhook certificate to support FIPS environments
Gyula Fora (Jira)
2026/06/03
Re: [PR] [FLINK-39216][helm] Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator]
via GitHub
2026/06/03
[jira] [Closed] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules
Gyula Fora (Jira)
2026/06/03
Re: [PR] [FLINK-39691] Fix toString for AggregatedMetric [flink-kubernetes-operator]
via GitHub
2026/06/03
[jira] [Closed] (FLINK-39692) Include caught exceptions in warn/error log statements
Gyula Fora (Jira)
2026/06/03
Re: [PR] [FLINK-39692][Kubernetes-Operator] Include caught exceptions in warn/error log statements [flink-kubernetes-operator]
via GitHub
2026/06/03
[jira] [Closed] (FLINK-39713) flink-kubernetes-operator: Bump log4j, jackson, and Beam to retire CVEs
Gyula Fora (Jira)
2026/06/03
Re: [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] Rewrite security page with precise trust model and operator coverage [flink-web]
via GitHub
2026/06/03
Re: [PR] Rewrite security page with precise trust model and operator coverage [flink-web]
via GitHub
2026/06/03
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
2026/06/03
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
2026/06/03
Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink]
via GitHub
2026/06/03
Re: [PR] [hotfix] Correct fabric8 version to 7.3.1 in NOTICE files [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] Rewrite security page with precise trust model and operator coverage [flink-web]
via GitHub
2026/06/03
[PR] [hotfix] Correct fabric8 version to 7.3.1 in NOTICE files [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] [hotfix] Bump `flink-connector-parent` to 1.1.0 [flink-connector-aws]
via GitHub
2026/06/03
[jira] [Closed] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis
Ferenc Csaky (Jira)
2026/06/03
Re: [PR] [FLINK-27941][connectors/aws] Migrate remaining tests to JUnit 5 [flink-connector-aws]
via GitHub
2026/06/03
Re: [PR] [FLINK-27941][connectors/aws] Migrate remaining tests to JUnit 5 [flink-connector-aws]
via GitHub
2026/06/03
[jira] [Assigned] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis
Ferenc Csaky (Jira)
2026/06/03
[jira] [Updated] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis
Ferenc Csaky (Jira)
2026/06/03
[jira] [Updated] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis
Ferenc Csaky (Jira)
2026/06/03
[jira] [Closed] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions'
Ferenc Csaky (Jira)
2026/06/03
[jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions'
Ferenc Csaky (Jira)
2026/06/03
[jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions'
Ferenc Csaky (Jira)
2026/06/03
Re: [PR] [FLINK-20979][elasticsearch] Fix docs: use '-1' to disable bulk-flush options [flink-connector-elasticsearch]
via GitHub
2026/06/03
[jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions'
Ferenc Csaky (Jira)
2026/06/03
[jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions'
Ferenc Csaky (Jira)
2026/06/03
Re: [PR] [FLINK-36602][table] Upgrade Calcite version to 1.38.0 [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39817][table] Upgrade Calcite version to 1.39.0 [flink]
via GitHub
2026/06/03
Re: [PR] Bump org.postgresql:postgresql from 42.5.6 to 42.7.11 in /flink-autoscaler-plugin-jdbc [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] Bump org.postgresql:postgresql from 42.5.6 to 42.7.11 in /flink-autoscaler-plugin-jdbc [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] Bump org.postgresql:postgresql from 42.5.6 to 42.7.11 in /flink-autoscaler-plugin-jdbc [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] [FLINK-39136][BP 2.3][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39835][runtime] AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39777] Support configurable HashFunction strategies in PrePartitionOperator [flink-cdc]
via GitHub
2026/06/03
[jira] [Updated] (FLINK-39680) Enable unaligned checkpoint for pointwise connection by FORCE_UNALIGNED
Gen Luo (Jira)
2026/06/03
[jira] [Updated] (FLINK-39835) AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint
ASF GitHub Bot (Jira)
2026/06/03
[PR] [FLINK-39835][runtime] AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39680][runtime] AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint [flink]
via GitHub
2026/06/03
[jira] [Updated] (FLINK-39680) Enable unaligned checkpoint for pointwise connection by FORCE_UNALIGNED
ASF GitHub Bot (Jira)
2026/06/03
[PR] [FLINK-39680][runtime] AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink]
via GitHub
2026/06/03
Re: [PR] [FLINK-39691] Fix toString for AggregatedMetric [flink-kubernetes-operator]
via GitHub
2026/06/03
Re: [PR] [FLINK-39692][Kubernetes-Operator] Include caught exceptions in warn/error log statements [flink-kubernetes-operator]
via GitHub
2026/06/03
[jira] [Created] (FLINK-39835) AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint
Gen Luo (Jira)
Earlier messages
Later messages