issues  

Messages by Thread

• • 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-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
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
  • Re: [PR] [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET [flink] via GitHub
• [PR] Flink 41061 drafted [flink-benchmarks] via GitHub
  • Re: [PR] Flink 41061 drafted [flink-benchmarks] via GitHub
• [PR] FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (ADVANCED transition mode, gate in code) [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-40281) Improve HTTP sink failure observability ASF GitHub Bot (Jira)
• [PR] [FLINK-40281][connector-http] Improve HTTP sink failure observability [flink-connector-http] via GitHub
• [PR] [FLINK-41208][connector-jdbc] Only accept TYPE_SCROLL_INSENSITIVE for exactly-once JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-41208][connector-jdbc] Only accept TYPE_SCROLL_INSENSITIVE for exactly-once JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-41208][connector-jdbc] Only accept TYPE_SCROLL_INSENSITIVE for exactly-once JdbcSource [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-41155) Add stage_source_release_atr.sh for Apache Trusted Releases ASF GitHub Bot (Jira)
• [PR] [FLINK-37834][jdbc] Fixes [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834][jdbc] Fixes [flink-connector-jdbc] via GitHub
• [PR] [BP-2.4][FLINK-41087][table] Don't build the `PARSE_JSON` error for rows `TRY_PARSE_JSON` rejects [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-41087][table] Don't build the `PARSE_JSON` error for rows `TRY_PARSE_JSON` rejects [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-41087][table] Don't build the `PARSE_JSON` error for rows `TRY_PARSE_JSON` rejects [flink] via GitHub
• [jira] [Created] (FLINK-41207) Fluss pipeline source does not checkpoint consumed offsets across empty log intervals Xiaobing Fang (Jira)
• [jira] [Resolved] (FLINK-41114) Document the uid argument for FROM_CHANGELOG and TO_CHANGELOG Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41208) JdbcSourceBuilder accepts ResultSet.CONCUR_READ_ONLY as a result set type for exactly-once Purushottam Sinha (Jira)
• [jira] [Resolved] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-41207) Fluss pipeline source does not checkpoint consumed offsets across empty log intervals ASF GitHub Bot (Jira)
• [PR] [FLINK-41207][pipeline-connector/fluss] Preserve consumed offsets across empty log batches [flink-cdc] via GitHub
• [PR] [FLINK-41009][Stream] Ignore negative Pulsar message IDs in checkpoint metadata [flink-connector-pulsar] via GitHub
  • Re: [PR] [FLINK-41009][Stream] Ignore negative Pulsar message IDs in checkpoint metadata [flink-connector-pulsar] via GitHub
  • Re: [PR] [FLINK-41009][Stream] Ignore negative Pulsar message IDs in checkpoint metadata [flink-connector-pulsar] via GitHub
• [jira] [Resolved] (FLINK-40278) Document that HTTP sink retries resend the whole batch request Martijn Visser (Jira)
• [jira] [Closed] (FLINK-41164) Upgrade Testcontainers to 1.21.4 on the flink-connector-mongodb v2.0 branch Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-41204) VARIANT JSON parsing replaces unpaired surrogates with '?' instead of failing Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed Biao Geng (Jira)
• [jira] [Updated] (FLINK-40812) [Backport][1.20] Backport FLINK-38558 to release-1.20 ASF GitHub Bot (Jira)
• [PR] [BP-5.0][FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
  • Re: [PR] [BP-5.0][FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
  • Re: [PR] [BP-5.0][FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
  • Re: [PR] [BP-5.0][FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
• [PR] [FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
• [PR] [FLINK-40812][state] Backport FLINK-38558 to release-1.20 [flink] via GitHub
  • Re: [PR] [FLINK-40812][state] Backport FLINK-38558 to release-1.20 [flink] via GitHub
• [jira] [Updated] (FLINK-41203) Help users pick between the Kafka, Upsert Kafka and Dynamic Kafka SQL connectors ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41203) Help users pick between the Kafka, Upsert Kafka and Dynamic Kafka SQL connectors Martijn Visser (Jira)
• [jira] [Comment Edited] (FLINK-41197) Multi-table DROP may bypass tables.exclude when binlog newly-added table discovery is enabled Jira
• [jira] [Resolved] (FLINK-34625) TTL doesn't seem to work in pyflink Dian Fu (Jira)
• [PR] [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs [flink] via GitHub
  • Re: [PR] [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs [flink] via GitHub
  • Re: [PR] [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs [flink] via GitHub
  • Re: [PR] [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs [flink] via GitHub
  • Re: [PR] [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs [flink] via GitHub
  • Re: [PR] [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs [flink] via GitHub
  • Re: [PR] [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs [flink] via GitHub
• [jira] [Updated] (FLINK-41196) PyFlink pandas conversions and regular Python UDFs change TIMESTAMP_LTZ instants in non-UTC session time zones Biao Geng (Jira)
  • [jira] [Updated] (FLINK-41196) PyFlink pandas conversions and regular Python UDFs change TIMESTAMP_LTZ instants in non-UTC session time zones Biao Geng (Jira)
• [jira] [Created] (FLINK-41205) FLIP-616: Materialized Tables support for Table API Timo Theusner (Jira)
• [jira] [Updated] (FLINK-40936) Built-in functions compare VARIANT array elements and map keys by their binary encoding Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-41204) VARIANT JSON parsing replaces unpaired surrogates with '?' instead of failing Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41204) VARIANT JSON parsing replaces unpaired surrogates with '?' instead of failing Ramin Gharib (Jira)
• [jira] [Commented] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
• [PR] [FLINK-41201][pipeline-connector/fluss] Reuse sink writer metric group [flink-cdc] via GitHub
• [jira] [Created] (FLINK-41203) Help users pick between the Kafka, Upsert Kafka and Dynamic Kafka SQL connectors Martijn Visser (Jira)
• [PR] [BP-1.20][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
• [PR] [FLINK-38323][autoscaler] Add opt-in scaling using the highest scale … [flink-kubernetes-operator] via GitHub
• [PR] [BP-2.2][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
• [PR] [FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
  • Re: [PR] [FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
  • Re: [PR] [FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
  • Re: [PR] [FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
  • Re: [PR] [FLINK-40997][table-planner] Fix join upsert key order being non-deterministic [flink] via GitHub
• [jira] [Created] (FLINK-41202) Make connector integrations easier to find from the Flink docs Martijn Visser (Jira)
• [PR] [BP-2.4][FLINK-40936][table] Reject VARIANT elements and keys in functions and operators that compare them [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-40936][table] Reject VARIANT elements and keys in functions and operators that compare them [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-40936][table] Reject VARIANT elements and keys in functions and operators that compare them [flink] via GitHub
• [jira] [Updated] (FLINK-41202) Make connector integrations easier to find from the Flink docs ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41202) Make connector integrations easier to find from the Flink docs Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41202) Make connector integrations easier to find from the Flink docs Martijn Visser (Jira)
• [PR] [FLINK-41197][connect/mysql] Filter schema changes by captured table IDs [flink-cdc] via GitHub
• [PR] [FLINK-41197][connect/mysql] Filter schema changes by captured table IDs (release-3.6) [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-41180) VARIANT objects sort and search field names in UTF-16 order instead of UTF-8 byte order Ramin Gharib (Jira)
• [jira] [Comment Edited] (FLINK-24908) Improve SQL Error description for SQL Client Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41201) Fluss pipeline sink error counters remain zero after write failures ASF GitHub Bot (Jira)
• [PR] [FLINK-41107][pipeline-connector] Honor accepted schema evolution types in Hudi and MaxCompute sinks [flink-cdc] via GitHub
• [jira] [Created] (FLINK-41201) Fluss pipeline sink error counters remain zero after write failures Xiaobing Fang (Jira)
• [jira] [Commented] (FLINK-24908) Improve SQL Error description for SQL Client Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41180) VARIANT objects sort and search field names in UTF-16 order instead of UTF-8 byte order ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41180) VARIANT objects sort and search field names in UTF-16 order instead of UTF-8 byte order Ramin Gharib (Jira)
• [PR] [FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes [flink] via GitHub
  • Re: [PR] [FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes [flink] via GitHub
  • Re: [PR] [FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes [flink] via GitHub
• [PR] [BP-1.20][hotfix][docs] Fix link to DataStream operators overview [flink] via GitHub
  • Re: [PR] [BP-1.20][hotfix][docs] Fix link to DataStream operators overview [flink] via GitHub
• Re: [I] [Feature] OpenTelemetry GenAI exporter for Agent Traces (Phase 1: Java, spans-only) [flink-agents] via GitHub
• [jira] [Updated] (FLINK-24908) Improve SQL Error description for SQL Client Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink Yanquan Lv (Jira)
• Re: [PR] [hotfix] [docs] fix link URL to DataStream operators [flink] via GitHub
  • Re: [PR] [hotfix] [docs] fix link URL to DataStream operators [flink] via GitHub
• [jira] [Updated] (FLINK-31757) FLIP-370: Support Balanced Tasks Scheduling Yuepeng Pan (Jira)
• Re: [PR] [FLINK-40538][postgres] Skip WAL position search on idle publication … [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-40804) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fails with "Exceeded checkpoint tolerable failure threshold" Martijn Visser (Jira)
• [jira] [Closed] (FLINK-41065) Improve TypeInferenceUtil for built-in PTFs Timo Walther (Jira)
• [PR] Bump org.apache.logging.log4j:log4j-api from 2.24.3 to 2.25.5 [flink-connector-cassandra] via GitHub
• [PR] Bump org.apache.logging.log4j:log4j-core from 2.24.3 to 2.25.4 [flink-connector-cassandra] via GitHub
• [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-cassandra] via GitHub
• Re: [PR] [hotfix][ci] Skip CI on certain paths [flink-connector-cassandra] via GitHub
• [jira] [Assigned] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed Martijn Visser (Jira)
• Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents] via GitHub
• [jira] [Comment Edited] (FLINK-40928) DISTINCT over a cross join with an IS NULL filter returns rows with NULL that are not in the input Yusuf YILDIZ (Jira)
• [jira] [Created] (FLINK-41200) GROUP BY over an outer join with a non-equi join condition drops rows (batch mode) Yusuf YILDIZ (Jira)
• [jira] [Updated] (FLINK-41199) PyFlink result collection fails for NULL values inside nested rows and collections ASF GitHub Bot (Jira)
• [PR] [FLINK-41199][python] Decode NULL values in nested collected results [flink] via GitHub
  • Re: [PR] [FLINK-41199][python] Decode NULL values in nested collected results [flink] via GitHub
  • Re: [PR] [FLINK-41199][python] Decode NULL values in nested collected results [flink] via GitHub
• [jira] [Commented] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink YaLei Zhang (Jira)
  • [jira] [Commented] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-41200) GROUP BY over an outer join with a non-equi join condition drops rows (batch mode) Yusuf YILDIZ (Jira)

• Earlier messages
• Later messages