All pull requests

Pull requests

• Emit a minion subtask queue-stall gauge that a long but draining job does not trip

  metricsminionobservability
  #20039·raghavyadav01 opened Oct 25, 2026Contributor·

  ·
  5

• [minion] Allow generators to validate effective minion tags

  featureminionrelease-notes
  #20036·xiangfu0 opened Oct 25, 2026Contributor·

  ·
  8

• Fix compiled aggregation inputs after timestamp index rewrites

  performance
  #20035·xiangfu0 opened Oct 25, 2026Contributor·

  ·
  12

• [VARIANT 8/8] VARIANT compatibility suites, integration test and quickstart

  featuretesting
  #20034·xiangfu0 opened Oct 25, 2026Contributor·

  ·

• [VARIANT 7/8] VARIANT response encoding and Java/JDBC clients

  feature
  #20033·xiangfu0 opened Oct 25, 2026Contributor·

  ·

• [VARIANT 6/8] VARIANT multi-stage query support and opacity guards

  featuremulti-stagequeryupgrade-incompat
  #20032·xiangfu0 opened Oct 25, 2026Contributor·

  ·

• [VARIANT 5/8] VARIANT single-stage query functions and opacity guards

  featurequery
  #20031·xiangfu0 opened Oct 25, 2026Contributor·

  ·

• [VARIANT 4/8] Read Parquet VARIANT columns during ingestion

  featureingestion
  #20030·xiangfu0 opened Oct 25, 2026Contributor·

  ·

• [VARIANT 3/8] VARIANT segment storage and schema/table-config validation

  feature
  #20029·xiangfu0 opened Oct 25, 2026Contributor·

  ·

• [VARIANT 2/8] Add Variant codec, scalar functions and VARIANT column type (pinot-common)

  featureupgrade-incompat
  #20028·xiangfu0 opened Oct 25, 2026Contributor·

  ·

• [VARIANT 1/8] Add VARIANT logical type foundation (pinot-spi)

  featurerelease-notes
  #20027·xiangfu0 opened Oct 25, 2026Contributor·

  ·
  5

• Adopt the stream position of an empty batch in RealtimeSegmentDataManager

  kafkaobservability
  #20024·xiangfu0 opened Oct 24, 2026Contributor·

  ·
  7

• Do not execute requests that reach the server after the broker deadline

  bugconfigurationobservabilityquery
  #20023·xiangfu0 opened Oct 24, 2026Contributor·

  ·
  22

• Make the failure detector probe the channels that carry queries

  bugconfigurationobservability
  #20022·xiangfu0 opened Oct 23, 2026Contributor·

  ·
  33

• Detect and close half-open broker-to-server channels

  bugconfigurationGRPCobservability
  #20021·xiangfu0 opened Oct 23, 2026Contributor·

  ·
  34

• Rate-limit StreamDataLoss reports and harden Kafka transactional offset-gap handling

  bugkafkaobservability
  #20020·xiangfu0 opened Oct 23, 2026Contributor·

  ·
  11

• Query optional segments in multi-stage leaf stages

  bugmulti-stage
  #20017·xiangfu0 opened Oct 23, 2026Contributor·

  ·
  7

• Wait for no optional segments before custom cluster integration tests run

  flaky-testmulti-stagetesting
  #20015·xiangfu0 opened Oct 23, 2026Contributor·

  ·
  12

• Share the per-table ZK metadata read and deep-store listing in RetentionManager

  refactor
  #20010·9aman opened Oct 23, 2026Contributor·

  ·
  3

• Retry task deletion when Helix fails to remove the job context

  bugflaky-testminion
  #20009·xiangfu0 opened Oct 23, 2026Contributor·

  ·
  11

• Add a controller gauge that marks ended stream partitions

  kinesismetricsobservabilityreal-time
  #20008·KKcorps opened Oct 23, 2026Contributor·

  ·
  1

• [DATA-3302] Fail segment build when indexes disagree with segment metadata

  bugindexjavatesting
  #20007·KKcorps opened Oct 23, 2026Contributor·

  ·
  6

• Recover unhealthy MSE workers that are not servers in the routing manager

  bugmulti-stageobservability
  #20005·yashmayya opened Oct 22, 2026Contributor·

  ·
  4

• Fix NPE when sorting a no-dictionary sorted column that is an aggregation key

  aggregationbugingestionreal-time
  #20002·gortiz opened Oct 22, 2026Contributor·

  ·
  9

• Support = and IN on multi-value columns in the multi-stage engine

  bugmulti-stage
  #20001·raghavyadav01 opened Oct 22, 2026Contributor·

  ·
  13