All pull requests

Pull requests

• Core, Flink: Convert Avro time-millis and time-micros to int and long on request

  coreflink
  #18859·kumarpritam863 opened Nov 10, 2026Contributor·

  ·

• Flink: Dynamic Sink: Retry table updates on concurrent commits and reload concurrently created tables

  flink
  #18858·kumarpritam863 opened Nov 10, 2026Contributor·

  ·

• Flink: Dynamic Sink: Do not validate the first commit to a new branch against the ancestry of main

  flink
  #18857·kumarpritam863 opened Nov 10, 2026Contributor·

  ·

• REST: Remove total byte statistics from content-file JSON

  coreOPENAPI
  #18856·anoopj opened Nov 10, 2026Member·

  ·

• Flink: Backport: Fix range distribution with truncate on binary columns (#18696)

  flink
  #18855·chenjian2664 opened Nov 10, 2026Contributor·

  ·
  1

• Flink: Backport: Distribute rows by custom fields to DynamicWriter in DynamicSink (#18668)

  flink
  #18854·swapna267 opened Nov 10, 2026Contributor·

  ·
  1

• Core: Add v4 TrackedFile write wrappers for leaf and root manifests

  core
  #18853·stevenzwu opened Nov 9, 2026Contributor·

  ·
  29

• Core: Add V4 changelog planning

  #18852·anoopj opened Nov 9, 2026Member·

  ·

• Arrow: Read projected shredded variants in vectorized Parquet reads

  #18851·nssalian opened Nov 9, 2026Collaborator·

  ·
  1

• Flink: Make DataFileRewriteCommitter close idempotent fix ci timeout

  flink
  #18850·Guosmilesmile opened Nov 9, 2026Contributor·

  ·
  3

• Flink: Always reset commit service after watermark in DataFileRewriteCommitter

  flink
  #18849·ebyhr opened Nov 9, 2026Member·5 tasks done·

  ·

• AWS, GCP: Preserve prefixes during vended credential refresh

  AWSGCP
  #18848·VenkataKarthikP opened Nov 9, 2026·

  ·
  1

• Core: Add GroupAggregateEvaluator for group by aggregate pushdown

  core
  #18847·drexler-sky opened Nov 9, 2026Contributor·

  ·

• Core: Fix deleted rows reappearing when copy-on-write races an equality delete

  core
  #18846·jiwen624 opened Nov 9, 2026Contributor·

  ·
  2

• Build: Dump threads when Flink CI hangs

  INFRA
  #18845·ebyhr opened Nov 9, 2026Member·

  ·

• Flink: Reject delete files in DynamicIcebergSink overwrite commits

  flink
  #18844·zhengxiang378928908-code opened Nov 9, 2026Contributor·

  ·
  1

• Build: Bump com.google.cloud:libraries-bom from 26.90.0 to 26.91.0

  GCPKAFKACONNECT
  #18838·ebyhr opened Nov 8, 2026Member·

  ·
  1

• Kafka Connect: Skip control events a channel ignores without decoding them

  KAFKACONNECT
  #18837·Mohith26 opened Nov 8, 2026·

  ·

• Arrow: Document NullabilityHolder.reset() null-marker contract

  arrow
  #18836·Shahzeb-DataEngineer opened Nov 8, 2026·

  ·
  1

  1

• Build: Bump joda-time:joda-time from 2.15.0 to 2.15.1

  dependenciesjava
  #18835·dependabot[bot] opened Nov 8, 2026Bot·

  ·
  1

• Build: Bump com.google.cloud:libraries-bom from 26.90.0 to 26.91.0

  dependenciesjava
  #18833·dependabot[bot] opened Nov 8, 2026Bot·

  ·
  1

• Spark: Honor spark.wap.id in metadata deletes

  spark
  #18824·Marouane-elfadli opened Nov 7, 2026·

  ·
  3

• Flink: Handle concurrent JDBC lock table initialization

  flink
  #18823·adiranjan25 opened Nov 7, 2026·

  ·
  1

  1

• [1.10.x] Core: Backport thread-safe duplicate delete handling (#16686)

  core
  #18821·conor-mcavoy opened Nov 7, 2026·

  ·
  2

• [1.11.x] Core: Backport thread-safe duplicate delete handling (#16686)

  core
  #18820·conor-mcavoy opened Nov 7, 2026·

  ·