pinot

pinot copied to clipboard

Handle exception in realtime decoder gracefully

1

This PR continues the effort from #9163 We already added `continueOnError` flag in previous PRs to handle errors gracefully. This PR extends the same configs to handle decoder exceptions as...

KKcorps

[multistage] [debugability] Support explain distributed stage plan and add a test for explicit distinct

1

Extend the current explain query visitor to explain distributed stage plan. Add a test for explicit distinct query.

61yao

[multi-stage] Query timeout overwrite

2

Currently, the query option time doesn't overwrite correctly. We should have: user-config override should always be considered as the total time (maybe minus planning time, i will explain later) with...

61yao

consolidate FunctionRegistry for v1/v2 engines

1

This is the first PR in a set of queries to allow for polymorphism (see https://github.com/apache/pinot/pull/9600) in UDFs. This one simply does some clean up in preparation to standardize on...

agavra

Support non-blocking MailboxReceivedOperator

5

Currently MailboxReceivedOperator - does a busy wait on all mailbox - always pick the next mailbox to check in exact order instead of round-robin pick or random propose to create...

walterddr

Add read APIs for `BOOLEAN` and `TIMESTAMP`

2

Currently `BOOLEAN` is supported using the `INT` data type, and `TIMESTAMP` is supported using the `LONG` data type. Even though the storage format are the same, the behavior should be...

Jackie-Jiang

Allow submiting ingestionJobSpec yaml to launch minion task for ingestion job

1

Currently, users run this command to ingest data: `pinot-admin.sh LaunchIngestionJob -jobSpec my-ingestion-job-spec.yaml`. The goal is to make users can re-use the same yaml for segment ingestion in minion. Steps: 1....

xiangfu0

Instructions: 1. The PR has to be tagged with at least one of the following labels (*): 1. `feature` 2. `bugfix` 3. `performance` 4. `ui` 5. `backward-incompat` 6. `release-notes` (**)...

navina

Timeout expired while fetching topic metadata

7

My table config 《 { "tableName": "t3_rt", "tableType": "REALTIME", "segmentsConfig": { "timeColumnName": "update_time", "timeType": "MILLISECONDS", "schemaName": "t3", "replicasPerPartition": "1" }, "tenants": {}, "tableIndexConfig": { "loadMode": "MMAP", "streamConfigs": { "dataFormat": "avro",...

tianqin69

- mailbox reference will be kept in concurrent hashmap forever - if query fails, it doesn't cancel all the mailboxes, but the mailbox receive operator already returned. this means any...

walterddr