issues  

Messages by Thread

• [jira] [Created] (FLINK-41279) Support the PostgreSQL-style :: cast operator Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-41214) Declare a materialized table with Table#materializeInto Timo Theusner (Jira)
• [jira] [Updated] (FLINK-41278) Distinguish DEFAULT arguments from explicit NULL during type inference ASF GitHub Bot (Jira)
• [PR] [FLINK-41278][table] Distinguish DEFAULT arguments from explicit NULL during type inference [flink] via GitHub
  • Re: [PR] [FLINK-41278][table] Distinguish DEFAULT arguments from explicit NULL during type inference [flink] via GitHub
• [jira] [Commented] (FLINK-41211) List materialized tables of a given catalog and database Gustavo de Morais (Jira)
• [jira] [Resolved] (FLINK-41211) List materialized tables of a given catalog and database Gustavo de Morais (Jira)
• [PR] [docs][release-0.4] Standardize Alibaba Cloud Model Studio naming [flink-agents] via GitHub
• [jira] [Created] (FLINK-41278) Distinguish DEFAULT arguments from explicit NULL during type inference dylanhz (Jira)
• [jira] [Created] (FLINK-41277) test_file_sink.sh hangs in the second OpenSSL linkage run Sergey Nuyanzin (Jira)
• [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] via GitHub
  • Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] via GitHub
• Re: [PR] [FLINK-41045][e2e] Increase slot request timeout in Kerberized YARN Docker tests [flink] via GitHub
• Re: [PR] [runtime][java] Complete batch workflows before key switches [flink-agents] via GitHub
• [PR] [runtime][java][python] Preserve internal subagent framework faults through tool calls and the Python bridge [flink-agents] via GitHub
• [jira] [Updated] (FLINK-41276) Make License check CI parallel ASF GitHub Bot (Jira)
• [PR] [FLINK-41276][ci] Run the License task in parallel and regroup its log so the license checks still work [flink] via GitHub
  • Re: [PR] [FLINK-41276][ci] Run the License task in parallel and regroup its log so the license checks still work [flink] via GitHub
• [jira] [Created] (FLINK-41276) Make License check CI parallel Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Dian Fu (Jira)
• Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-41275][e2e] Start containers in e2e per class rather than per test in SQL e2e [flink] via GitHub
• [jira] [Resolved] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Dian Fu (Jira)
• [PR] [BP-2.4][FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
• [jira] [Comment Edited] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed Biao Geng (Jira)
• [PR] [FLINK-41206][python] Log Python worker process exits [flink] via GitHub
  • Re: [PR] [FLINK-41206][python] Log Python worker process exits [flink] via GitHub
• [jira] [Resolved] (FLINK-41228) Thread-mode PyFlink DataStream converters mishandle rows in arrays, lists and maps Dian Fu (Jira)
• [jira] [Commented] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed Sangkyoon Nam (Jira)
  • [jira] [Commented] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed Biao Geng (Jira)
• Re: [PR] [FLINK-39382][docs] Clarify auto.offset.reset support in Kafka SQL connector [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39382][docs] Clarify auto.offset.reset support in Kafka SQL connector [flink-connector-kafka] via GitHub
• [jira] [Assigned] (FLINK-41271) PyFlink tasks remain RUNNING after a Beam data RPC failure Dian Fu (Jira)
• [jira] [Updated] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Dian Fu (Jira)
• [PR] [FLINK-41269][runtime] Do not treat task clean-up failure as fatal [flink] via GitHub
  • Re: [PR] [FLINK-41269][runtime] Do not treat task clean-up failure as fatal [flink] via GitHub
• [jira] [Created] (FLINK-41257) Deeply nested data structure might fail with StackOverflow Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-41203) Help users pick between the Kafka, Upsert Kafka and Dynamic Kafka SQL connectors Martijn Visser (Jira)
• [PR] [FLINK-30644][tests] Fix flaky ChangelogCompatibilityITCase [flink] via GitHub
  • Re: [PR] [FLINK-30644][tests] Fix flaky ChangelogCompatibilityITCase [flink] via GitHub
  • Re: [PR] [FLINK-30644][tests] Fix flaky ChangelogCompatibilityITCase [flink] via GitHub
  • Re: [PR] [FLINK-30644][tests] Fix flaky ChangelogCompatibilityITCase [flink] via GitHub
• [jira] [Closed] (FLINK-41150) Release Testing Instructions: FLIP-599: State Catalog Gyula Fora (Jira)
• Re: [PR] [FLINK-40872][runtime] Close AsyncExecutionController when async state operators close [flink] via GitHub
• [PR] [hotfix][ci] Log Python test exit codes and repeat Flink 1.20 jobs [flink-agents] via GitHub
• [PR] [FLINK-41047][Connectors/AWS] Don't assert JDK-specific connection-refused text in sink writer tests [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-41047][Connectors/AWS] Don't assert JDK-specific connection-refused text in sink writer tests [flink-connector-aws] via GitHub
• [jira] [Resolved] (FLINK-41242) status.error reports every exception of a failed job as `org.apache.flink.util.SerializedThrowable` Santwana Verma (Jira)
• [jira] [Closed] (FLINK-41153) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• [PR] [BP-2.4][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] via GitHub
• Re: [I] [Feature] Add PostgreSQL pgvector vector store (Java) [flink-agents] via GitHub
• Re: [PR] [FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode [flink] via GitHub
• [PR] [runtime] Fix action-state key collisions between event occurrences with identical attributes [flink-agents] via GitHub
• Re: [PR] [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• [PR] [FLINK-40508][pipeline-connector/db2] Support DB2 pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40508][pipeline-connector/db2] Support DB2 pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40508][pipeline-connector/db2] Support DB2 pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40508][pipeline-connector/db2] Support DB2 pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40508][pipeline-connector/db2] Support DB2 pipeline connector [flink-cdc] via GitHub
• [jira] [Created] (FLINK-41271) PyFlink tasks remain RUNNING after a Beam data RPC failure Biao Geng (Jira)
• [jira] [Created] (FLINK-41254) Two-phase window aggregation loses buffered records when a source subtask becomes idle Mate Czagany (Jira)
• [PR] [FLINK-41210][table] Add StartMode factories for each START_MODE clause [flink] via GitHub
  • Re: [PR] [FLINK-41210][table] Add StartMode factories for each START_MODE clause [flink] via GitHub
  • Re: [PR] [FLINK-41210][table] Add StartMode factories for each START_MODE clause [flink] via GitHub
• [jira] [Created] (FLINK-41264) FileSinkAvroWritersTests.test_avro_basic_write fails with AssertionError: False != True Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41243) VARIANT field access with a non-literal key fails in code generation Ramin Gharib (Jira)
• Re: [PR] [FLINK-40407] Add reason tags to the autoscaler.scalings counter [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-41265) Add a metric for JSON messages with ignored parse errors Hao Yu (Jira)
• [jira] [Created] (FLINK-41269) Exception thrown from an operator's `close()` during failure cleanup is TaskManager-fatal since FLINK-38180 (it was suppressed before) Dries Samyn (Jira)
• [PR] [runtime] Add cross-release state migration test for ActionExecutionOperator [flink-agents] via GitHub
• [jira] [Created] (FLINK-41265) Add a metric for JSON messages with ignored parse errors Hao Yu (Jira)
• [jira] [Resolved] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41270) [Kafka] Explicit auto.offset.reset silently changes committedOffsets() startup position Han You (Jira)
• [jira] [Closed] (FLINK-41217) VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits Piotr Nowojski (Jira)
• [jira] [Updated] (FLINK-41252) flink-sql-connector-kudu fails with "Invalid lambda deserialization" for tables with a primary key Harsh Mishra (Jira)
  • [jira] [Updated] (FLINK-41252) flink-sql-connector-kudu fails with "Invalid lambda deserialization" for tables with a primary key ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-40273) JDBC docs: update for the 4.x module split and Sink V2 API Martijn Visser (Jira)
• [jira] [Created] (FLINK-41266) Upgrade Java versions for CVE-2026-91403 Chanhae Oh (Jira)
• Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
• [jira] [Resolved] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-41271) PyFlink tasks remain RUNNING after a Beam data RPC failure ASF GitHub Bot (Jira)
• Re: [PR] [docs] Add Kubernetes deployment guide [flink-agents] via GitHub
• [jira] [Created] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-41137) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-40938) Support AT_TIMESTAMP feature in DynamDB Streams connector Ferenc Csaky (Jira)
• [jira] [Closed] (FLINK-41222) Autoscaler reports an error when a ConfigMap write is applied but the client's retry conflicts Gyula Fora (Jira)
• [jira] [Created] (FLINK-41273) Allow UNION, INTERSECT and EXCEPT on unbounded tables in the Table API Timo Theusner (Jira)
• [jira] [Commented] (FLINK-41225) Mini-batch join: the unique-key bundles fold an UPDATE_AFTER and the following DELETE into nothing, so the stored row is never retracted Gustavo de Morais (Jira)
• [jira] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
• [jira] [Updated] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Updated] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Updated] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Updated] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Updated] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Updated] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Updated] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
• [jira] [Commented] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Commented] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Commented] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
• [jira] [Updated] (FLINK-41261) Support ORDER BY in ARRAY_AGG/JSON_ARRAY_AGG Rion Williams (Jira)
  • [jira] [Updated] (FLINK-41261) Support ORDER BY in ARRAY_AGG/JSON_ARRAY_AGG Rion Williams (Jira)
• [jira] [Updated] (FLINK-41260) ARRAY_AGG/JSON_ARRAY_AGG with ORDER BY ignores the ordering and cannot be serialized into a compiled plan Rion Williams (Jira)
  • [jira] [Updated] (FLINK-41260) ARRAY_AGG/JSON_ARRAY_AGG with ORDER BY ignores the ordering and cannot be serialized into a compiled plan Rion Williams (Jira)
• [jira] [Comment Edited] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Comment Edited] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Comment Edited] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Comment Edited] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Comment Edited] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Comment Edited] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
  • [jira] [Comment Edited] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
• [jira] [Created] (FLINK-41272) [mysql-cdc] NULL values of nullable columns with a DEFAULT are emitted as the default value in Debezium JSON Seungki Kim (Jira)
• Re: [PR] [FLINK-39565] Eliminate maven build warnings across all modules [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39565] Eliminate maven build warnings across all modules [flink-kubernetes-operator] via GitHub
• Re: [PR] FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (ADVANCED transition mode) [flink-kubernetes-operator] via GitHub
• [jira] [Closed] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused Ferenc Csaky (Jira)
• [PR] [FLINK-41271][python] Fail Python tasks when the data RPC terminates [flink] via GitHub
  • Re: [PR] [FLINK-41271][python] Fail Python tasks when the data RPC terminates [flink] via GitHub
• [jira] [Comment Edited] (FLINK-31040) Looping pattern notFollowedBy at end missing an element Mohammad Bani Hani (Jira)
• [jira] [Updated] (FLINK-41270) [Kafka] Explicit auto.offset.reset silently changes committedOffsets() startup position ASF GitHub Bot (Jira)
• [PR] [FLINK-41270][Connectors/Kafka] Clarify auto.offset.reset with committed offsets [flink-connector-kafka] via GitHub
• [jira] [Commented] (FLINK-33224) Flink Batch Job does not complete when using Kafka topics with empty partitions Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE Martijn Visser (Jira)
• [jira] [Commented] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Sangkyoon Nam (Jira)
  • [jira] [Commented] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Dian Fu (Jira)
• [jira] [Commented] (FLINK-41244) PTF clearAllTimers() deletes unnamed timers across all keys and corrupts the key context Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41269) Exception thrown from an operator's `close()` during failure cleanup is TaskManager-fatal since FLINK-38180 (it was suppressed before) Dries Samyn (Jira)
• [jira] [Updated] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-41269) Exception thrown from an operator's `close()` during failure cleanup is TaskManager-fatal since FLINK-38180 (it was suppressed before) Dries Samyn (Jira)
  • [jira] [Updated] (FLINK-41269) Exception thrown from an operator's `close()` during failure cleanup is TaskManager-fatal since FLINK-38180 (it was suppressed before) Dries Samyn (Jira)
  • [jira] [Updated] (FLINK-41269) Exception thrown from an operator's `close()` during failure cleanup is TaskManager-fatal since FLINK-38180 (it was suppressed before) Dries Samyn (Jira)
  • [jira] [Updated] (FLINK-41269) Exception thrown from an operator's `close()` during failure cleanup is TaskManager-fatal since FLINK-38180 (it was suppressed before) Dries Samyn (Jira)
  • [jira] [Updated] (FLINK-41269) Exception thrown from an operator's `close()` during failure cleanup is TaskManager-fatal since FLINK-38180 (it was suppressed before) ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41269) Exception thrown from an operator's `close()` during failure cleanup is TaskManager-fatal since FLINK-38180 (it was suppressed before) Dries Samyn (Jira)
• [jira] [Updated] (FLINK-41264) FileSinkAvroWritersTests.test_avro_basic_write fails with AssertionError: False != True Martijn Visser (Jira)
• [PR] [FLINK-41262][operator] Delete the JobManager on suspend when HA is disabled [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41262][operator] Delete the JobManager on suspend when HA is disabled [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41262][operator] Delete the JobManager on suspend when HA is disabled [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-41268) Source idleness lets a watermark overtake on-time records after two shuffles Mate Czagany (Jira)
• [PR] [hotfix][docs] Use 0.4.0 release defaults on release-0.4 [flink-agents] via GitHub
  • Re: [PR] [hotfix][docs] Use 0.4.0 release defaults on release-0.4 [flink-agents] via GitHub
• Re: [I] [Bug][runtime] Durable action-state keys collide for distinct events with identical attributes [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] Durable action-state keys collide for distinct events with identical attributes [flink-agents] via GitHub
• [PR] [BP-2.2][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] via GitHub
• [jira] [Assigned] (FLINK-41137) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Timo Walther (Jira)
• [jira] [Updated] (FLINK-41210) Add fluent StartMode factories ASF GitHub Bot (Jira)
• [PR] [FLINK-41252][Connectors/Kudu] Fix deserialization of KuduTableUtils lambdas [flink-connector-kudu] via GitHub
• Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-40938) Support AT_TIMESTAMP feature in DynamDB Streams connector Ferenc Csaky (Jira)
• [PR] [FLINK-41267] Skip state size in cluster info when checkpointing is disabled [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-41267) Cluster info fails for jobs without checkpointing, logging a WARN on every reconcile Santwana Verma (Jira)
  • [jira] [Updated] (FLINK-41267) Cluster info fails for jobs without checkpointing, logging a WARN on every reconcile ASF GitHub Bot (Jira)
• [PR] [hotfix][docs] Finalize Flink Agents 0.4.0 release defaults [flink-agents] via GitHub
  • Re: [PR] [hotfix][docs] Finalize Flink Agents 0.4.0 release defaults [flink-agents] via GitHub
• [jira] [Created] (FLINK-41267) Cluster info fails for jobs without checkpointing, logging a WARN on every reconcile Santwana Verma (Jira)
• [PR] [BP-2.1][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] via GitHub
• [PR] [BP-2.3][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] via GitHub
• [jira] [Assigned] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store Robert Metzger (Jira)
• [PR] [FLINK-41265][formats] Add a metric for JSON messages with ignored parse errors. [flink] via GitHub
  • Re: [PR] [FLINK-41265][formats] Add a metric for JSON messages with ignored parse errors. [flink] via GitHub
• [jira] [Updated] (FLINK-41265) Add a metric for JSON messages with ignored parse errors ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-28852) Closed metrics could be found in metric dashboard from WebUI Robert Metzger (Jira)
• [jira] [Commented] (FLINK-41266) Upgrade Java versions for CVE-2026-91403 Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-41266) Upgrade Java versions for CVE-2026-91403 Chanhae Oh (Jira)
  • [jira] [Commented] (FLINK-41266) Upgrade Java versions for CVE-2026-91403 Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-41266) Upgrade Java versions for CVE-2026-91403 Chanhae Oh (Jira)
• [jira] [Closed] (FLINK-31849) Enforce some some simple validation directly through the CRD Gyula Fora (Jira)
• [jira] [Commented] (FLINK-40508) Support DB2 pipeline connector suntectec (Jira)
• [jira] [Updated] (FLINK-34475) ZooKeeperLeaderElectionDriverTest failed with exit code 2 Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-34475) ZooKeeperLeaderElectionDriverTest failed with exit code 2 Martijn Visser (Jira)
• [jira] [Reopened] (FLINK-34475) ZooKeeperLeaderElectionDriverTest failed with exit code 2 Martijn Visser (Jira)
• Re: [PR] [FLINK-31849] Adds basic CRD validations [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-39891] Add option to cancel orphaned session jobs on submit [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39891] Add option to cancel orphaned session jobs on submit [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-39890] Fix NaN in observed scaling coefficient when baseline rate is zero [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39890] Fix NaN in observed scaling coefficient when baseline rate is zero [flink-kubernetes-operator] via GitHub
• Re: [PR] Move setLastReconciledSpec to after successful transition start [flink-kubernetes-operator] via GitHub
  • Re: [PR] Move setLastReconciledSpec to after successful transition start [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-39165] Prevent concurrent FlinkSessionJob / FlinkDeployment update [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39165] Prevent concurrent FlinkSessionJob / FlinkDeployment update [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-36297) SIGSEGV caused CI failure Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40596) Closing metric might lead to a number of test failure Martijn Visser (Jira)
• Re: [PR] [FLINK-40405] Add reason tags to the autoscaler.balanced counter [flink-kubernetes-operator] via GitHub
• [jira] [Comment Edited] (FLINK-41137) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Chanhae Oh (Jira)
• [jira] [Closed] (FLINK-41050) Canary health checks revert canary metadata changes and restart a healthy operator Gyula Fora (Jira)
• [jira] [Commented] (FLINK-20789) Add a metric named `deserializeFailedCount` for formats which has option `ignore-parse-errors` Hao Yu (Jira)

• Earlier messages