issues  

Messages by Date

• 2026/08/11 Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
• 2026/08/11 [jira] [Updated] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
• 2026/08/11 [jira] [Commented] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 [jira] [Assigned] (FLINK-39824) [mysql-cdc] High CPU usage caused by repeated regex table filtering in large table synchronization Yanquan Lv (Jira)
• 2026/08/11 [jira] [Created] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
• 2026/08/11 Re: [PR] [infra] Add an api/ contract review guide [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [infra] Add an api/ contract review guide [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [test][python] Assert long-term memory content instead of an exact LLM item count [flink-agents] via GitHub
• 2026/08/11 Re: [I] [Feature] Add VLLM_CONNECTION to the ChatModel out-of-the-box [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [integration] Add out of the box vLLM chat model support for Java and Python [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [test][python] Assert long-term memory content instead of an exact LLM item count [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [api][runtime][python] Add Agent Trace recording to Event Log [flink-agents] via GitHub
• 2026/08/11 Re: [I] [Tech Debt] De-flake the long-term memory e2e test, which asserts an exact LLM consolidation count [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
• 2026/08/11 [jira] [Commented] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Joey Pereira (Jira)
• 2026/08/11 [jira] [Updated] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Joey Pereira (Jira)
• 2026/08/11 Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/08/11 [jira] [Created] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Joey Pereira (Jira)
• 2026/08/11 Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot [flink] via GitHub
• 2026/08/11 Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
• 2026/08/11 [jira] [Created] (FLINK-40369) ARRAY functions might lead to wrong results Sergey Nuyanzin (Jira)
• 2026/08/11 [jira] [Updated] (FLINK-40367) Make Kafka consumer poll timeout configurable ASF GitHub Bot (Jira)
• 2026/08/11 [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka] via GitHub
• 2026/08/11 [jira] [Created] (FLINK-40368) Deduplicate output should only be insert-only when ordered by time attribute David Anderson (Jira)
• 2026/08/11 [jira] [Updated] (FLINK-37005) Make StreamExecDeduplicate output insert only where possible David Anderson (Jira)
• 2026/08/11 [jira] [Created] (FLINK-40367) Make Kafka consumer poll timeout configurable Robert Metzger (Jira)
• 2026/08/11 Re: [PR] [FLINK-36434][Connectors/Kafka] Create the KafkaConsumer lazily on the split fetcher thread [flink-connector-kafka] via GitHub
• 2026/08/11 Re: [PR] [FLINK-36434][Connectors/Kafka] Create the KafkaConsumer lazily on the split fetcher thread [flink-connector-kafka] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40208][runtime] Add test coverage and blank-key validation for JobMdcRegistry [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40208][runtime] Add test coverage and blank-key validation for JobMdcRegistry [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• 2026/08/11 [PR] [hotfix][runtime] Respect UDF precedence during type validation [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39565] Eliminate maven build warnings across all modules [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39565] Eliminate maven build warnings across all modules [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
• 2026/08/11 [jira] [Created] (FLINK-40366) INSERT INTO with a column list or static partition fails for set-semantic PTFs Gustavo de Morais (Jira)
• 2026/08/11 [jira] [Updated] (FLINK-40366) INSERT INTO with a column list or static partition fails for set-semantic PTFs Gustavo de Morais (Jira)
• 2026/08/11 Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [api][runtime][python] Add Agent Trace recording to Event Log [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/11 [jira] [Closed] (FLINK-35746) Add logic to override observed config based on settings observed through REST API Gyula Fora (Jira)
• 2026/08/11 Re: [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/11 [jira] [Reopened] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins Robert Metzger (Jira)
• 2026/08/11 [jira] [Updated] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Robert Metzger (Jira)
• 2026/08/11 Re: [PR] [draft] Monotonic counters draft [flink] via GitHub
• 2026/08/11 [PR] [draft] Monotonic counters draft [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator] via GitHub
• 2026/08/11 [jira] [Resolved] (FLINK-40240) Support TRY_CAST, IFNULL and NULLIF in YAML Transform Yanquan Lv (Jira)
• 2026/08/11 [jira] [Resolved] (FLINK-40312) Support EXTRACT, date-part functions, and interval arithmetic in YAML Transform Yanquan Lv (Jira)
• 2026/08/11 Re: [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40240][runtime] Support TRY_CAST, IFNULL and NULLIF in YAML Transform [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40240][runtime] Support TRY_CAST, IFNULL and NULLIF in YAML Transform [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-36434][Connectors/Kafka] Create the KafkaConsumer lazily on the split fetcher thread [flink-connector-kafka] via GitHub
• 2026/08/11 [jira] [Commented] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect Dale Lane (Jira)
• 2026/08/11 [jira] [Updated] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect ASF GitHub Bot (Jira)
• 2026/08/11 [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] [FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration [flink-kubernetes-operator] via GitHub
• 2026/08/11 [jira] [Created] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect Dale Lane (Jira)
• 2026/08/11 Re: [PR] Bump org.jsoup:jsoup from 1.15.3 to 1.23.1 in /flink-kubernetes-docs [flink-kubernetes-operator] via GitHub
• 2026/08/11 Re: [PR] Bump org.jsoup:jsoup from 1.15.3 to 1.23.1 in /flink-kubernetes-docs [flink-kubernetes-operator] via GitHub
• 2026/08/11 [jira] [Closed] (FLINK-39791) Helm chart silently ignores defaultConfiguration.config.yaml; always mounts flink-conf.yaml from chart defaults Gyula Fora (Jira)
• 2026/08/11 Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator] via GitHub
• 2026/08/11 [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40191][python] Add aggregation support to PyFlink DataFrame API [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40240][runtime] Support TRY_CAST, IFNULL and NULLIF in YAML Transform [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink] via GitHub
• 2026/08/11 [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
• 2026/08/11 [jira] [Assigned] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation Roman Khachatryan (Jira)
• 2026/08/11 Re: [PR] [FLINK-32212][runtime] Match library BLOBs by content in BlobLibraryCacheManager [flink] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink] via GitHub
• 2026/08/11 [PR] [runtime] Introduce AI model client function API [flink-cdc] via GitHub
• 2026/08/11 Re: [PR] [DRAFT] Add parallel compile for test jobs [flink] via GitHub
• 2026/08/11 [PR] [DRAFT] Add parallel compile for test jobs [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40240][runtime] Support TRY_CAST, IFNULL and NULLIF in YAML Transform [flink-cdc] via GitHub
• 2026/08/10 [PR] [hotfix] Add help handling to build script [flink-agents] via GitHub
• 2026/08/10 Re: [PR] Kafka 4.x Queue Semantics support [flink-connector-kafka] via GitHub
• 2026/08/10 Re: [PR] Kafka 4.x Queue Semantics support [flink-connector-kafka] via GitHub
• 2026/08/10 Re: [PR] [FLINK-32940] [SQL] Unnest projection and filter pushdown [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-38987] Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-38050][UI] Correct Flink UI Dropdown Width [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/10 [jira] [Created] (FLINK-40364) flink-connector-pulsar Flink 2.x support Hongbo Miao (Jira)
• 2026/08/10 [jira] [Updated] (FLINK-40364) flink-connector-pulsar Flink 2.x support Hongbo Miao (Jira)
• 2026/08/10 Re: [I] [Tech Debt] De-flake the long-term memory e2e test, which asserts an exact LLM consolidation count [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [runtime] CDC YAML supports inline Python UDF definition [flink-cdc] via GitHub
• 2026/08/10 [jira] [Commented] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation Samrat Deb (Jira)
• 2026/08/10 Re: [PR] [hotfix][checkpoint] Refactor common behavior into ChannelStateFilteringHandler#getGateFilterHandler and GateFilterHandler#getVirtualChannelBy to reduce code duplication [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator] via GitHub
• 2026/08/10 Re: [PR] [infra] Add an api/ contract review guide [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [infra] Add an api/ contract review guide [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator [flink] via GitHub
• 2026/08/10 Re: [PR] [hotfix][checkpoint] Refactor common behavior into ChannelStateFilteringHandler#getGateFilterHandler and GateFilterHandler#getVirtualChannelBy to reduce code duplication [flink] via GitHub
• 2026/08/10 Re: [PR] [hotfix][checkpoint] Refactor common behavior into ChannelStateFilteringHandler#getGateFilterHandler and GateFilterHandler#getVirtualChannelBy to reduce code duplication [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator [flink] via GitHub
• 2026/08/10 [PR] [hotfix][checkpoint] Refactor common behavior into ChannelStateFilteringHandler#getGateFilterHandler and GateFilterHandler#getVirtualChannelBy to reduce code duplication in ChannelStateFilteringHandler.java [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
• 2026/08/10 Re: [PR] [integrations][openai] Let provider exceptions reach the caller unwrapped [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [infra] Update main version to 0.4-SNAPSHOT [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [infra] Include model in AI provenance [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator] via GitHub
• 2026/08/10 Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator] via GitHub
• 2026/08/10 [PR] [hotfix][java][python] Update main version to 0.4-SNAPSHOT [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [FLINK-39824][mysql] Cache table filter results to reduce regex matching [flink-cdc] via GitHub
• 2026/08/10 [jira] [Resolved] (FLINK-39732) Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) Leonard Xu (Jira)
• 2026/08/10 [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
• 2026/08/10 Re: [PR] [integrations][azureai] Remove the deprecated Azure AI Inference integration [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [integrations][azureai] Remove the deprecated Azure AI Inference integration [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [infra] Add a docs-only review guide [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [FLINK-38262][table] Add DROP CONNECTION operation [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator [flink] via GitHub
• 2026/08/10 [jira] [Updated] (FLINK-40172) Support processing-time early fire on a row-time interval join ASF GitHub Bot (Jira)
• 2026/08/10 [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub
• 2026/08/10 [jira] [Resolved] (FLINK-40363) MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN is unstable Sergey Nuyanzin (Jira)
• 2026/08/10 [jira] [Commented] (FLINK-40363) MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN is unstable Sergey Nuyanzin (Jira)
• 2026/08/10 [jira] [Updated] (FLINK-40171) Emit and retract early-fire results in the interval join operator ASF GitHub Bot (Jira)
• 2026/08/10 Re: [PR] [FLINK-40363][table] Make `MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN` more stable [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator [flink] via GitHub
• 2026/08/10 [PR] [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator [flink] via GitHub
• 2026/08/10 Re: [PR] [hotfix][tests] Add `computeDigest` to `DummyStructuredType` [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-39786][s3]closeForCommit() leaks orphan multipart uploads on upload failure [flink] via GitHub
• 2026/08/10 [jira] [Updated] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure ASF GitHub Bot (Jira)
• 2026/08/10 [PR] [FLINK-39786][s3]closeForCommit() leaks orphan multipart uploads on upload failure [flink] via GitHub
• 2026/08/10 [jira] [Updated] (FLINK-39250) Introduce Streaming support in native-s3-fs Samrat Deb (Jira)
• 2026/08/10 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics [flink] via GitHub
• 2026/08/10 [jira] [Commented] (FLINK-40361) Extract license check into a separate job in Azure Sergey Nuyanzin (Jira)
• 2026/08/10 [jira] [Resolved] (FLINK-40361) Extract license check into a separate job in Azure Sergey Nuyanzin (Jira)
• 2026/08/10 [jira] [Updated] (FLINK-40361) Extract license check into a separate job in Azure ASF GitHub Bot (Jira)
• 2026/08/10 Re: [PR] [FLINK-40361][ci] Extract license check into a separate job in Azure [flink] via GitHub
• 2026/08/10 [PR] [FLINK-40363][table] Make `MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN` more stable [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40363][table] Make `MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN` more stable [flink] via GitHub
• 2026/08/10 [jira] [Updated] (FLINK-40363) MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN is unstable ASF GitHub Bot (Jira)
• 2026/08/10 Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
• 2026/08/10 [jira] [Created] (FLINK-40363) MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN is unstable Sergey Nuyanzin (Jira)
• 2026/08/10 Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
• 2026/08/10 Re: [PR] [hotfix][tests] Add `computeDigest` to `DummyStructuredType` [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40271][table] Fix SQL serialization of Table API group window properties [flink] via GitHub
• 2026/08/10 [PR] [hotfix][tests] Add `computeDigest` to `DummyStructuredType` [flink] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40139] Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40190][python] Add PyFlink DataFrame creation and conversion APIs [flink] via GitHub
• 2026/08/10 Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 [flink-kubernetes-operator] via GitHub
• 2026/08/10 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/08/10 [jira] [Updated] (FLINK-40137) Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator Sylwester Lachiewicz (Jira)
• 2026/08/10 [jira] [Reopened] (FLINK-40137) Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator Sylwester Lachiewicz (Jira)
• 2026/08/10 Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• 2026/08/10 [jira] [Updated] (FLINK-40136) DynamicKafkaSourceEnumeratorTest flaky due to ConcurrentModificationException in metadata event polling Sylwester Lachiewicz (Jira)
• 2026/08/10 Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/08/10 Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/08/10 [jira] [Updated] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update ASF GitHub Bot (Jira)
• 2026/08/10 [PR] [FLINK-40362] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• 2026/08/10 [jira] [Updated] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Sylwester Lachiewicz (Jira)
• 2026/08/10 [jira] [Created] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Sylwester Lachiewicz (Jira)
• 2026/08/10 [jira] [Closed] (FLINK-40137) Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator Sylwester Lachiewicz (Jira)
• 2026/08/10 [jira] [Created] (FLINK-40361) Extract license check into a separate job in Azure Sergey Nuyanzin (Jira)
• 2026/08/10 [jira] [Updated] (FLINK-40137) Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator Sylwester Lachiewicz (Jira)
• 2026/08/10 Re: [PR] [FLINK-25802][FLINK-30499][table-planner] Fix TIMESTAMP codegen for RANGE OVER window bounds [flink] via GitHub

• Earlier messages
• Later messages