dev  

Messages by Thread

• [jira] [Created] (FLINK-40794) CAST in Table API ignores input nullability when the target type is NOT NULL Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods sepuri sai krishna (Jira)
• [DISCUSS][FLINK-40574] Upgrade SLF4J from 1.7 to 2.x Piotr Przybylski
  • Re: [DISCUSS][FLINK-40574] Upgrade SLF4J from 1.7 to 2.x P Sinha
• [jira] [Created] (FLINK-40792) Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40790) DefaultDeclarativeSlotPoolTest.testIncreasingResourceRequirementsWillSendResourceRequirementNotification receives the first increment alone Martijn Visser (Jira)
• [jira] [Created] (FLINK-40791) OpenTelemetryMetricReporterITCase.testCounterDelta fails with expected 1234 but was 25 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• [jira] [Created] (FLINK-40787) 'Flink CLI end-to-end test' fails with "Unexpected task manager slot count" Martijn Visser (Jira)
• [jira] [Created] (FLINK-40786) compile_cron_azure fails with OutOfMemoryError in japicmp on flink-s3-fs-presto Martijn Visser (Jira)
• [jira] [Created] (FLINK-40785) Nightly snapshot deployment fails in spotless because google-java-format 1.28.0 does not run on JDK 11 Martijn Visser (Jira)
• [DISCUSS] Clarifying the checkpoint upload path and performance attribution in the Native S3 benchmark Xia Rui
• [DISCUSS] FLINK-32806 - EmbeddedJobResultStore retains clean job result entries forever L L
  • Re: [DISCUSS] FLINK-32806 - EmbeddedJobResultStore retains clean job result entries forever Matthias Pohl
• [jira] [Created] (FLINK-40784) Upgrade ArchUnit to 1.5.0 in flink-connector-kafka Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40783) Upgrade HikariCP from 4.0.3 to 7.1.0 peiyu (Jira)
• [jira] [Created] (FLINK-40782) Fail connector CI when ArchUnit would update a frozen violation store Martijn Visser (Jira)
• [jira] [Created] (FLINK-40781) ArchUnit tests in flink-connector-jdbc don't analyse any production classes Martijn Visser (Jira)
• [jira] [Created] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams Rui Fan (Jira)
• [jira] [Created] (FLINK-40779) JdbcSourceEnumerator snapshots splitter state ahead of the splits it has handled Martijn Visser (Jira)
• [jira] [Created] (FLINK-40778) JdbcTablePlanTest.testFilterPushdown fails against Flink 2.4 because of the upper-case AND in the filter digest Martijn Visser (Jira)
• [jira] [Created] (FLINK-40777) Run the XA connection tests against PostgreSQL Martijn Visser (Jira)
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.16.1 released Gyula Fóra
• [jira] [Created] (FLINK-40776) PARSE_URL compiles the query-parameter pattern on every row Utkarsh Vashishtha (Jira)
• [PR] [FLINK-40775][ci] Add a PR template with AI disclosure [flink-ci-docker] via GitHub
• [jira] [Created] (FLINK-40774) Add a PR template with AI disclosure for flink-jira-bot Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40773) Add a PR template with AI disclosure for flink-playgrounds Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40775) Add a PR template with AI disclosure for flink-ci-docker Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40772) Add a PR template with AI disclosure for flink-training Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40771) Add a PR template with AI disclosure for flink-connector-redis-streams Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40770) Add a PR template with AI disclosure for flink-connector-rabbitmq Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40769) Add a PR template with AI disclosure for flink-connector-gcp-pubsub Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40768) Add a PR template with AI disclosure for flink-connector-cassandra Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40767) Add a PR template with AI disclosure for flink-connector-hbase Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40766) Add AI disclosure to the flink-ml PR template Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40765) Add a PR template with AI disclosure for flink-agents-demos Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40764) Add a PR template with AI disclosure for flink-benchmarks Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40763) Add a PR template with AI disclosure for flink-connector-kudu Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40762) Add a PR template with AI disclosure for flink-connector-hive Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40761) Add AI disclosure to the flink-connector-prometheus PR template Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40760) Add AI disclosure to the flink-connector-pulsar PR template Aleksandr Savonin (Jira)
• [DISCUSS] Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Ramin Gharib
  • Re: [DISCUSS] Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Timo Walther
  • Re: [DISCUSS] Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Krishna Sai
  • Re: [DISCUSS] Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Ramin Gharib
• [jira] [Created] (FLINK-40759) Add a PR template with AI disclosure for flink-connector-shared-utils Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40758) Add a PR template with AI disclosure for flink-connector-http Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40756) Add a PR template with AI disclosure for flink-shaded Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40757) Add a PR template with AI disclosure for flink-connector-elasticsearch Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40755) Add a PR template with AI disclosure for flink-web Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40754) Add a PR template with AI disclosure for flink-docker Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40753) Correlated subqueries over SQL VALUES fail during decorrelation FangHao (Jira)
• [jira] [Created] (FLINK-40748) PreparedSplitterNumericParameters.withBatchSize reads past maxVal Martijn Visser (Jira)
• [jira] [Created] (FLINK-40752) Add a PR template with AI disclosure for flink-connector-opensearch Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40751) State Processor environment and operators should use task memory/io manager Gyula Fora (Jira)
• [jira] [Created] (FLINK-40750) Add AI disclosure to the Flink AWS connectors PR template Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40749) Add or update PR templates with AI disclosure across Flink repositories Aleksandr Savonin (Jira)
• [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
• [jira] [Created] (FLINK-40745) PyFlink JDBC sink binds to classes that no longer exist in flink-connector-jdbc 4.x Martijn Visser (Jira)
• [jira] [Created] (FLINK-40740) Fluss source can assign the same splits more than once during periodic discovery Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40742) Pin the JDBC Table sink's changelog behaviour with tests before the Sink V2 migration Martijn Visser (Jira)
• [jira] [Created] (FLINK-40744) Remove the dead InputFormat and OutputFormat classes from flink-connector-jdbc Martijn Visser (Jira)
• [jira] [Created] (FLINK-40747) PreparedSplitterEnumerator.of(sqlTemplate) produces no split, the source reads nothing Martijn Visser (Jira)
• [jira] [Created] (FLINK-40746) Deprecate the JdbcSourceBuilder setters that only the deprecated setSql path reads Martijn Visser (Jira)
• [jira] [Created] (FLINK-40743) JDBC Table sink reports an empty lineage dataset name Martijn Visser (Jira)
• [jira] [Created] (FLINK-40741) [Flink cdc]After the full snapshot read of the newly added table completes, the newly added table is no longer synchronized, while the existing (old) tables continue reading Ruan Hang (Jira)
• [jira] [Created] (FLINK-40739) [Bug][pipeline-connector][maxcompute] Partition values extracted from wrong column index when partition columns are not contiguous at the end of schema Yanquan Lv (Jira)
• [jira] [Created] (FLINK-40734) [Umbrella] Remove Deprecated Configuration Options/Keys in Flink Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40738) LAG/LEAD with a non-null default value returns the default instead of NULL sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40736) Non-time ROWS OVER window emits a malformed row for FIRST_VALUE, LAST_VALUE, LISTAGG, COUNT(DISTINCT), ARRAY_AGG, COLLECT and PERCENTILE sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40733) Trino tests are disabled, so the Trino dialect has no test coverage Martijn Visser (Jira)
• [jira] [Created] (FLINK-40727) Support comma-separated security.ssl.protocol and fix internal SSL hostname verification regression Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40732) Release finished snapshot split metadata in the MongoDB CDC connector Spoorthi Basu (Jira)
• [jira] [Created] (FLINK-40728) [FLIP-607] Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser (Jira)
• [jira] [Created] (FLINK-40731) CONVERT_TZ silently returns a wrong timestamp for a time zone it does not recognize sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40729) Refresh the JDBC driver and test dependency versions raised by Dependabot Martijn Visser (Jira)
• [jira] [Created] (FLINK-40730) Remove the Derby dialect now that Derby is retired and replace it with H2 Martijn Visser (Jira)
• Review request: FLINK-40574 (Update SLF4J from 1.7.36 to 2.x) - PR #29120 Piotr Przybylski
• [RESULT][VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
• [jira] [Created] (FLINK-40726) Reading a key from a map returned by MAP_FROM_ARRAYS / MAP_FROM_ENTRIES / MAP_UNION fails with ClassCastException sepuri sai krishna (Jira)
• Swag request from a high school student who loves Apache Flink Anshumaan Vyas
• [jira] [Created] (FLINK-40725) JDBC table sink incompatible with Flink 2.3.0 ON CONFLICT / upsert-key validation Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40724) Add maven wrapper to connectors Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40723) Test JDK 21 and current Flink minor lines in CI Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40722) Create AGENTS.md for Flink JDBC connector and update the PR description to track AI usage Purushottam Sinha (Jira)
• [SUMMARY] Flink 2.4 Release Sync - 18.09.26 Sumin Joo
• [PR] [FLINK-40721][ci] Add maven 3.9.16 to ci docker [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-40721][ci] Add maven 3.9.16 to ci docker [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-40721][ci] Add maven 3.9.16 to ci docker [flink-ci-docker] via GitHub
• [jira] [Created] (FLINK-40721) Add maven 3.9.16 to ci docker Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40720) Do not checkout all branches in ci Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40719) Free disk space silently fails with E: Unable to locate package hhvm Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40717) Create AGENTS.md for Flink MongoDB connector and update the PR description to track AI usage Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40718) Do not run weekly if there is no new commits since the last green run Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40716) [FileSystem] common filesystems interfaces for hadoop-less implementations Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-40715) FLIP-597 [FileSystems] Support common implementation for SDK native hadoop-less file systems Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-40713) Bump mongo-driver version from 5.1.1 to 5.11.1 to fix CVE-2026-88033 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40712) Update dependencies in the Flink Connector MongoDB Project Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40714) Add MongoDB 8.0 to the multi-version integration test matrix Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40711) Don not run weekly if there is no new commits since the last green runs Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Bowen Li (Jira)
• [jira] [Created] (FLINK-40709) Kubernetes Operator: allowlist to exempt trusted hosts from jarURI restricted-host check Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40707) Backports of FLINK-39572 breaks previous releases because of different Beam version Martijn Visser (Jira)
• [jira] [Created] (FLINK-40708) Support ValueView in PTFs Timo Walther (Jira)
• [jira] [Created] (FLINK-40706) Harden address validation in kubernetes operator artifact fetcher Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Liu Liu (Jira)
• [DISCUSS] FLIP-608: Flink on Ray, Ray Resource Backend For Flink Zhanghao Chen
• [jira] [Created] (FLINK-40704) Enable spotless for java25 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40703) Improve correctness coverage: Add ITCase for recovery from a checkpoint whose pooled transactional id was reused by a later checkpoint Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40694) INSERT INTO with a column list fails over a process table function with a set-semantic table argument Martijn Visser (Jira)
• [jira] [Created] (FLINK-40702) Unify shared HTTP sink and lookup configuration options Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40701) Upgrade ArchUnit to 1.5.0 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40700) Add typed DataStream configuration for HTTP sink options Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40699) Add HTTP sink continue-on-error and optional error/DLQ handling Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40698) Bump japicmp-maven-plugin to 0.26.2 Martijn Visser (Jira)
• [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature Gyula Fóra
  • Re: [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature Dennis-Mircea Ciupitu
  • Re: [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature Robert Metzger
  • Re: [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature P Sinha
• [jira] [Created] (FLINK-40697) Release finished snapshot split metadata in the incremental source framework (flink-cdc-base) Spoorthi Basu (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 P Sinha
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Dennis-Mircea Ciupitu
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Rui Fan
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Robert Metzger
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
• [jira] [Created] (FLINK-40696) Revert observed runtime config logic Gyula Fora (Jira)
• [jira] [Created] (FLINK-40695) Transient issues during ExecutionGraph creation lead to terminal job Failure Ahmed Hamdy (Jira)
• [REMINDER] Flink 2.4 Release Sync - 18.09.26 Chanhae Oh
• [jira] [Created] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Paryshev (Jira)
• [jira] [Created] (FLINK-40692) [Model] Use default model version from server when no version is defined in model config Danish (Jira)
• [jira] [Created] (FLINK-40691) Fix comparison logic for binlog filename with more than 6 digits Yanquan Lv (Jira)
• [jira] [Created] (FLINK-40690) Fluss sink applies top-level column mapping to nested ROW fields Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40689) Kafka sink checkpoint recovery fails after producer epoch rollover with transaction V2 Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40687) flink-model shade relocations do not match, okhttp and kotlin ship unrelocated Martijn Visser (Jira)
• [jira] [Created] (FLINK-40688) flink-model-openai NOTICE lists httpcomponents artifacts it no longer bundles Martijn Visser (Jira)
• [jira] [Created] (FLINK-40686) Shaded jars declare a bundled dependency's JPMS module name Martijn Visser (Jira)
• [jira] [Created] (FLINK-40685) ForSt skips local cache cleanup for checkpoint-owned files Aaron He (Jira)
• [jira] [Created] (FLINK-40684) Tensor names are unconditionally uppercased Danish (Jira)
• [jira] [Created] (FLINK-40683) JoinSemanticTests[anti-join-on-nested] asserts the raw changelog on release-2.3 and release-2.2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40682) ArchivedExecutionGraphTest fails in setup with "BUG: trying to schedule a region which is not in CREATED state" sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40681) Streaming outer join drops the null-padded row after an inner-side update followed by delete when UPDATE_BEFORE is not required Martijn Visser (Jira)
• [jira] [Created] (FLINK-40680) Bump openai-java dependency Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40679) Support Iceberg table maintenance Mingliang Zhu (Jira)
• [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator P Sinha
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dennis-Mircea Ciupitu
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Zhanghao Chen
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Robert Metzger
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane via dev
• [jira] [Created] (FLINK-40678) Lookup join digest ignores table OPTIONS hints Martijn Visser (Jira)
• [jira] [Created] (FLINK-40677) Native application submission without jarURI fails in bundled Flink client David Peacock (Jira)
• [jira] [Created] (FLINK-40672) Incorrect nullability for CAST from VARIANT dylanhz (Jira)
• [jira] [Created] (FLINK-40676) Support Flink 2.0.x and Pulsar Client 4.0.9 Ferenc Csaky (Jira)
• Hackathon at Community over Code Glasgow — schedule slot needed Rich Bowen
  • Re: Hackathon at Community over Code Glasgow — schedule slot needed Andrea Cosentino
• [jira] [Created] (FLINK-40675) SqlGatewayServiceITCase.testReleaseLockWhenFailedToSubmitOperation is unstable sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40674) Stop deserializing SerializedThrowable via ObjectInputStream on parse Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40673) INTERSECT ALL and EXCEPT ALL fail with mixed INT/BIGINT inputs Bettle (Jira)
• [jira] [Created] (FLINK-40671) Document why UnknownInputChannel graduation hardcodes needsRecovery=false Rui Fan (Jira)
• [jira] [Created] (FLINK-40669) Java 11 E2E group 2 on release-2.3 is killed at the 234 minute budget while the other profiles finish in half the time Martijn Visser (Jira)
• [jira] [Created] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40668) Document why the recovery drain cannot stall on zero-credit needsRecovery channels Rui Fan (Jira)
• [jira] [Created] (FLINK-40667) Buffer ref-count leaks in CDR recovery filtering end in free() on a live segment Rui Fan (Jira)
• [jira] [Created] (FLINK-40666) Simplify SNAPSHOT function by removing 'load_completed_condition' parameter Fabian Hueske (Jira)
• FLIP-608: Flink on Ray — Ray Resource Backend For Flink Zhanghao Chen
  • Re: FLIP-608: Flink on Ray — Ray Resource Backend For Flink Zhanghao Chen
• [jira] [Created] (FLINK-40665) cron_snapshot_deployment_maven fails the Maven version enforcer because deploy_staging_jars.sh uses the Maven on PATH Martijn Visser (Jira)
• [jira] [Created] (FLINK-40662) 'Run kubernetes Materialized Table test' fails on release-2.3 because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• [jira] [Created] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• [jira] [Created] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• [jira] [Created] (FLINK-40661) Kerberized and PyFlink YARN Docker e2e tests fail on release-1.20 because the KDC image is built from debian:bullseye Martijn Visser (Jira)
• [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #3 Gyula Fóra
• [jira] [Created] (FLINK-40660) SplitFetcher hangs on shutdown when its element queue wakeUp flag is still set Martijn Visser (Jira)
• [jira] [Created] (FLINK-40659) SingleThreadFetcherManager reaps and recreates its fetcher on every idle gap Martijn Visser (Jira)
• [jira] [Created] (FLINK-40658) UNNEST silently drops null ROW elements from ARRAY Bettle (Jira)
• [jira] [Created] (FLINK-40651) Support configurable Iceberg file rolling within a checkpoint Yanquan Lv (Jira)
• [jira] [Created] (FLINK-40656) Distributed schema coordinator can remain EVOLVING after checkpoint restore Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Alexandru (Jira)
• [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath P Sinha
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Gustavo de Morais
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Efrat Levitan
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Zhe Wang
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Samrat Deb
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Ferenc Csaky
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Sergey Nuyanzin
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
• [jira] [Created] (FLINK-40654) cron_snapshot_deployment jobs fail because build-nightly-dist.yml still points at tools/azure-pipelines/free_disk_space.sh Martijn Visser (Jira)
• [jira] [Created] (FLINK-40653) Testcontainers tests fail with "Could not find a valid Docker environment" on the cron_azure profile Martijn Visser (Jira)
• [jira] [Created] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Martijn Visser (Jira)
• [jira] [Created] (FLINK-40652) MinioTestContainerTest and the S3 e2e tests fail on all release branches because minio/minio was removed from Docker Hub Martijn Visser (Jira)
• [jira] [Created] (FLINK-40650) Improve SqlServerDialect.discoverDataCollectionSchemas to reduce snapshot start time with many tables Stefano Franco (Jira)
• [jira] [Created] (FLINK-40649) [sqlserver-cdc] Agent status validation fails on localized SQL Server instances where service name is not in English dulele (Jira)
• [jira] [Created] (FLINK-40648) PrometheusReporter drops all metrics of a process when two metric group variables sanitise to the same label name Martijn Visser (Jira)
• [jira] [Created] (FLINK-40647) Support best-effort schema expansion for existing sink tables during table creation Mao Jiayi (Jira)

• Earlier messages