issues  

Messages by Thread

• [PR] [flink-xxx][runtime] support dynamic rate limit source [flink] via GitHub
  • Re: [PR] [flink-xxx][runtime] support dynamic rate limit source (PoC) [flink] via GitHub
  • Re: [PR] [flink-xxx][runtime] support dynamic rate limit source (PoC) [flink] via GitHub
• [jira] [Commented] (FLINK-41150) Release Testing Instructions: FLIP-599: State Catalog Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu (Jira)
• [jira] [Updated] (FLINK-41231) Publish SBOM artifacts for flink-connector-jdbc ASF GitHub Bot (Jira)
• [PR] [FLINK-41233][build] Skip japicmp in the fast profile again [flink-connector-shared-utils] via GitHub
• [PR] [FLINK-41232][build] Enable SBOM generation in connectors [flink-connector-shared-utils] via GitHub
• [jira] [Updated] (FLINK-41234) Bump build plugins in flink-connector-parent ASF GitHub Bot (Jira)
• [PR] [FLINK-41230][build] Declare flink-connector-base as provided [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-41230][build] Declare flink-connector-base as provided [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-41230) Declare flink-connector-base as provided in flink-connector-jdbc ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-41233) The fast profile in flink-connector-parent no longer skips japicmp ASF GitHub Bot (Jira)
• [PR] [FLINK-41234][build] Bump build plugins [flink-connector-shared-utils] via GitHub
• [jira] [Updated] (FLINK-41232) Enable SBOM generation in flink-connector-parent ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-41235) Remove maven-eclipse-plugin from flink-connector-parent ASF GitHub Bot (Jira)
• [PR] [FLINK-41235][build] Remove maven-eclipse-plugin [flink-connector-shared-utils] via GitHub
• [PR] [FLINK-41231][build] Publish SBOM artifacts [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-41231][build] Publish SBOM artifacts [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-41231][build] Publish SBOM artifacts [flink-connector-jdbc] via GitHub
• [jira] [Created] (FLINK-41233) The fast profile in flink-connector-parent no longer skips japicmp Martijn Visser (Jira)
• [jira] [Created] (FLINK-41234) Bump build plugins in flink-connector-parent Martijn Visser (Jira)
• [jira] [Created] (FLINK-41235) Remove maven-eclipse-plugin from flink-connector-parent Martijn Visser (Jira)
• [jira] [Created] (FLINK-41231) Publish SBOM artifacts for flink-connector-jdbc Martijn Visser (Jira)
• [jira] [Created] (FLINK-41232) Enable SBOM generation in flink-connector-parent Martijn Visser (Jira)
• [jira] [Created] (FLINK-41230) Declare flink-connector-base as provided in flink-connector-jdbc Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-41230) Declare flink-connector-base as provided in flink-connector-jdbc Martijn Visser (Jira)
• [jira] [Commented] (FLINK-31040) Looping pattern notFollowedBy at end missing an element Mohammad Bani Hani (Jira)
• [jira] [Created] (FLINK-41222) Autoscaler reports an error when a ConfigMap write is applied but the client's retry conflicts Alex Kukhar (Jira)
• [PR] [hotfix][Test] Close Pulsar sink test resources [flink-connector-pulsar] via GitHub
• [D] [Discussion] Quality-triggered escalation for model routing [flink-agents] via GitHub
  • Re: [D] [Discussion] Quality-triggered escalation for model routing [flink-agents] via GitHub
• [PR] [BP-2.4][FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 [flink-benchmarks] via GitHub
  • Re: [PR] [BP-2.4][FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 [flink-benchmarks] via GitHub
  • Re: [PR] [BP-2.4][FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 [flink-benchmarks] via GitHub
• [jira] [Updated] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• [PR] [hotfix][ci] Use blobless fetch in Azure single-branch checkout [flink] via GitHub
  • Re: [PR] [hotfix][ci] Use blobless fetch in Azure single-branch checkout [flink] via GitHub
• [jira] [Commented] (FLINK-41181) Filesystem sink silently drops all rows when the last partition column name starts with '_' or '.' Shawn (Jira)
• [jira] [Resolved] (FLINK-40277) Add HTTP sink response classification and retry support Bharath Reddy Gunapati (Jira)
• [jira] [Commented] (FLINK-41173) Migrate AbstractQueryableStateTestBase sources to Source V2 Shawn (Jira)
• [jira] [Resolved] (FLINK-41154) Make the connector release scripts work reliably on macOS and Linux Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Yuepeng Pan (Jira)
• Re: [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink-benchmarks] via GitHub
  • Re: [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink-benchmarks] via GitHub
  • Re: [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink-benchmarks] via GitHub
• [PR] [FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 [flink-benchmarks] via GitHub
  • Re: [PR] [FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 [flink-benchmarks] via GitHub
  • Re: [PR] [FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 [flink-benchmarks] via GitHub
• [jira] [Created] (FLINK-41229) StreamNetworkThroughputBenchmark hangs instead of failing when the receiver thread fails Martijn Visser (Jira)
• [jira] [Commented] (FLINK-41138) Release Testing Instructions: FLIP-566: Introduce a new IMMUTABLE columns constraint Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41193) Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 Rui Fan (Jira)
• [PR] [BP-2.2][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
• [jira] [Commented] (FLINK-41143) Release Testing Instructions: FLIP-579: LATERAL SNAPSHOT Join Yuepeng Pan (Jira)
• [PR] [FLINK-41039][table-planner] Only push projections into the inputs of UNION ALL [flink] via GitHub
  • Re: [PR] [FLINK-41039][table-planner] Only push projections into the inputs of UNION ALL [flink] via GitHub
• [jira] [Commented] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match Gustavo de Morais (Jira)
• [jira] [Commented] (FLINK-41114) Document the uid argument for FROM_CHANGELOG and TO_CHANGELOG Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed Biao Geng (Jira)
• [jira] [Created] (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 Yoni (Jira)
• [jira] [Assigned] (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] [Assigned] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Martijn Visser (Jira)
• [jira] [Created] (FLINK-41217) VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits Hanyu Zheng (Jira)
• [PR] [FLINK-41155] Add stage_source_release_atr.sh for Apache Trusted Releases [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41155] Add stage_source_release_atr.sh for Apache Trusted Releases [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41155] Add stage_source_release_atr.sh for Apache Trusted Releases [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41155] Add stage_source_release_atr.sh for Apache Trusted Releases [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41155] Add stage_source_release_atr.sh for Apache Trusted Releases [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41155] Add stage_source_release_atr.sh for Apache Trusted Releases [flink-connector-shared-utils] via GitHub
• [jira] [Commented] (FLINK-41132) Release Testing Instructions: FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41134) Release Testing Instructions: FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41134) Release Testing Instructions: FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Gustavo de Morais (Jira)
• [jira] [Commented] (FLINK-41141) Release Testing Instructions: FLIP-574 Metadata Filter Push-Down for Table Sources Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41141) Release Testing Instructions: FLIP-574 Metadata Filter Push-Down for Table Sources Jim Hughes (Jira)
• [jira] [Comment Edited] (FLINK-41152) Release Testing Instructions: Upgrade Calcite to 1.41.0 Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41216) Retracting ROW_NUMBER Top-N emits +U before -U for rows moving up, so operators keyed by the input upsert key lose rows Gustavo de Morais (Jira)
• Re: [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
  • Re: [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
  • Re: [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
  • Re: [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
  • Re: [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
• [jira] [Created] (FLINK-41213) Submit refresh jobs from programs deployed in application mode Timo Theusner (Jira)
• [jira] [Updated] (FLINK-41209) Run and control materialized table refresh jobs from any TableEnvironment Timo Theusner (Jira)
  • [jira] [Updated] (FLINK-41209) Run and control materialized table refresh jobs from any TableEnvironment ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-41139) Release Testing Instructions: FLIP-567: Introduce a ProcessTableFunction Test Harness Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41139) Release Testing Instructions: FLIP-567: Introduce a ProcessTableFunction Test Harness Mika Naylor (Jira)
• [jira] [Commented] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Yuepeng Pan (Jira)
• [jira] [Comment Edited] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-41208) JdbcSourceBuilder accepts ResultSet.CONCUR_READ_ONLY as a result set type for exactly-once ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41208) JdbcSourceBuilder accepts ResultSet.CONCUR_READ_ONLY as a result set type for exactly-once Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41208) JdbcSourceBuilder accepts ResultSet.CONCUR_READ_ONLY as a result set type for exactly-once Martijn Visser (Jira)
• [jira] [Comment Edited] (FLINK-41149) Release Testing Instructions: FLIP-585: Introduce Lazy Loading for HistoryServer Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Yuepeng Pan (Jira)
• [jira] [Comment Edited] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-41107) schema.change.behavior: lenient or exclude.schema.changes is ignored by Hudi and MaxCompute sinks because their MetadataApplier implementations do not honor accepted schema evolution types ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-41221) Support changelog streams in the HTTP table sink Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-41228) Thread-mode PyFlink DataStream converters mishandle rows in arrays, lists and maps Sangkyoon Nam (Jira)
• [jira] [Commented] (FLINK-41133) Release Testing Instructions: FLIP-529: Connections in Flink SQL and TableAPI Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41227) AVG on TINYINT, SMALLINT and INT overflows when SplitAggregateRule splits distinct aggregates Ankur Kotwal. (Jira)
• [jira] [Resolved] (FLINK-41147) Release Testing Instructions: FLIP-583: Expose JobInfo on Source contexts Rui Fan (Jira)
• [jira] [Commented] (FLINK-41151) Release Testing Instructions: FLINK-39268：Support Common Subexpression Elimination (CSE) in Calc Code Generation Yuepeng Pan (Jira)
• [PR] [BP-2.4][FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• [jira] [Created] (FLINK-41218) Add per-record result processing for HTTP sink batch responses Bharath Reddy Gunapati (Jira)
• [jira] [Commented] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
• [PR] [FLINK-41217][table] Run VALUES as a FLIP-27 source that checkpoints its position [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] Run VALUES as a FLIP-27 source that checkpoints its position [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
  • Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• [PR] [BP-1.20][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
• [PR] [BP-2.4][FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes [flink] via GitHub
• [PR] [BP-2.3][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
• [PR] [BP-2.4][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
• [jira] [Commented] (FLINK-41153) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41153) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• [PR] Add Kafka Connector 5.1.0 [flink-web] via GitHub
• [jira] [Resolved] (FLINK-41110) Find VARIANT object fields by comparing UTF-8 bytes Ramin Gharib (Jira)
• [jira] [Resolved] (FLINK-41180) VARIANT objects sort and search field names in UTF-16 order instead of UTF-8 byte order Ramin Gharib (Jira)
• [jira] [Commented] (FLINK-41140) Release Testing Instructions: FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41140) Release Testing Instructions: FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais (Jira)
• [jira] [Commented] (FLINK-41137) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41137) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Timo Walther (Jira)
• [jira] [Commented] (FLINK-41142) Release Testing Instructions: FLIP-578: In-place Table to Materialized Table conversion Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41147) Release Testing Instructions: FLIP-583: Expose JobInfo on Source contexts Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41147) Release Testing Instructions: FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin (Jira)
  • [jira] [Commented] (FLINK-41147) Release Testing Instructions: FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin (Jira)
• [jira] [Commented] (FLINK-41146) Release Testing Instructions: FLIP-547 V2: Filtering record before processing with spilling strategy Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41146) Release Testing Instructions: FLIP-547 V2: Filtering record before processing with spilling strategy Rui Fan (Jira)
• [jira] [Commented] (FLINK-41148) Release Testing Instructions: FLIP-584: Support Pluggable Storage Backend for HistoryServer Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41149) Release Testing Instructions: FLIP-585: Introduce Lazy Loading for HistoryServer Yuepeng Pan (Jira)
• [jira] (FLINK-41153) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41152) Release Testing Instructions: Upgrade Calcite to 1.41.0 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-41216) Retracting ROW_NUMBER Top-N emits +U before -U for rows moving up, so operators keyed by the input upsert key lose rows Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41224) Filter out rows with a NULL join key before streaming inner joins Gustavo de Morais (Jira)
• [jira] [Resolved] (FLINK-40072) request.timeout is declared as a Duration option but parsed as integer seconds, crashing at query time on any unit-suffixed value Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-41223) Batch joins drop NULL-safe matches on IS NOT DISTINCT FROM keys when column statistics report many NULLs Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-41192) HTTP sink request never completes when a retry attempt throws ASF GitHub Bot (Jira)
• [PR] [FLINK-41192][connector-http] Fail the HTTP sink request when a retry attempt throws [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-41192][connector-http] Fail the HTTP sink request when a retry attempt throws [flink-connector-http] via GitHub
• [jira] [Closed] (FLINK-40280) Document HTTP sink retry, error handling, and configuration parity Bharath Reddy Gunapati (Jira)
• [PR] [FLINK-40123][e2e] heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh [flink] via GitHub
  • Re: [PR] [FLINK-40123][e2e] heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh [flink] via GitHub
  • Re: [PR] [FLINK-40123][e2e] heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh [flink] via GitHub
• [jira] [Created] (FLINK-41219) Add an idempotency key header per HTTP sink request entry Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-41220) Honour Retry-After and add jitter to HTTP sink retry delays Bharath Reddy Gunapati (Jira)
• [jira] [Updated] (FLINK-41217) VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits Hanyu Zheng (Jira)
  • [jira] [Updated] (FLINK-41217) VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits Hanyu Zheng (Jira)
  • [jira] [Updated] (FLINK-41217) VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits Hanyu Zheng (Jira)
  • [jira] [Updated] (FLINK-41217) VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-41155) Add stage_source_release_atr.sh for Apache Trusted Releases Martijn Visser (Jira)
• [jira] [Created] (FLINK-41215) Drop a materialized table by path from TableEnvironment Timo Theusner (Jira)
• [jira] [Created] (FLINK-41214) Declare a materialized table with Table#materializeInto Timo Theusner (Jira)
• [jira] [Created] (FLINK-41212) Reject FULL refresh mode from a plain TableEnvironment Timo Theusner (Jira)
• [jira] [Created] (FLINK-41211) List materialized tables of a given catalog and database Timo Theusner (Jira)
• [jira] [Created] (FLINK-41210) Add fluent StartMode factories Timo Theusner (Jira)
• [jira] [Created] (FLINK-41209) Run and control materialized table refresh jobs from any TableEnvironment Timo Theusner (Jira)
• [jira] [Commented] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result Manish (Jira)
  • [jira] [Commented] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result Yaoxuan Wu (Jira)
• [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant ASF GitHub Bot (Jira)
• [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub

• Earlier messages
• Later messages