pinot

pinot copied to clipboard

**Problem** When shards are merged or reduced in Kinesis, Servers send segment consumed message to Controller with reason: endOfPartition reached. Controller during commit process can incorrectly determine partition has not...

noob-se7en

🐛 Problem Currently, when configuring a Pinot table to ingest from a Pulsar stream using OAuth2, it is not possible to specify the scope parameter. The PulsarPartitionLevelConnectionHandler class initializes the...

hefesto684

end to end tracking lag feature removed unintentionally

3

https://github.com/apache/pinot/pull/16783 removed this feature thinking it is not used, but it was a functional feature which we use in stripe https://github.com/apache/pinot/pull/16783#issuecomment-3498367846

priyen-stripe

Pinot Server fails to start in offline/air-gapped environments due to eager evaluation of NetUtils.getHostAddress()

2

### Current Behavior When attempting to start the Pinot Server (_version 1.4.0_) in an environment with no outbound internet access (e.g., a firewalled Docker Swarm overlay network), the server fails...

gyorfimi

Spark Ingestion Job Fails with NullPointerException: "Cannot invoke getTableSpec() because spec is null"

1

### __What Happens__: - Error occurs on __Spark Executor nodes__ during segment push phase - The `SegmentGenerationJobSpec` object is __null__ when executors try to push segments - Fails at `SegmentPushUtils.pushSegments()`...

Akanksha-kedia

[Query Resource Isolation] Various Improvements and fixes

1

## Summary 1. Add support for **custom class implementation** using reflections to avoid creating a custom implementation of the entire starter class. This follows the convention we generally use for...

praveenc7

## Problem Statement ### Current Limitation The existing segment reload status API (`GET /segments/segmentReloadStatus/{jobId}`) uses timestamp-based heuristics to determine reload success by comparing `segmentLoadTimeMs >= jobSubmissionTime`. This approach has several...

suvodeep-pyne

Add JDK 25 to GitHub Actions PR test matrix for unit, integration, and quickstart jobs.

xiangfu0

[Query] Server level runtime query throttling (pause/limit)

2

**Why** - Keep servers stable under load (reduce OOM and spike-driven failures) - Improve user experience by preventing single-query hogging and lowering error rates **What** - Global concurrency gate for...

xiangfu0

Add timeout overflow break handling at leaf stage

1

## Summary - introduce timeoutOverflowMode plumbing in server/broker metadata - make LeafOperator break early only if mode=BREAK and expose a TIMEOUT_OVERFLOW_REACHED stat so intermediates keep running - add SlowMockInstanceDataManagerFactory plus...

xiangfu0