pinot
pinot copied to clipboard
apache
Apache Pinot - A realtime distributed OLAP datastore
Hi Pinot team, recently my company came across an issue where we realized that expired segments were not being deleted from the deep store. The reason for this we realized...
It'd be great if Pinot Controller had an API which returned whether a set of tables have Colocated Realtime Partitions or not. Partitions here refers to the stream partition ID....
I am unable to start my pinot controller pod in AWS EKS environment. **For that I have added configurations in values.template.yaml for pinot to connect it from aws s3** As...
This is also a long time ask, similar to presto type: [TIMESTAMP WITH TIME ZONE](https://prestodb.io/docs/current/language/types.html#timestamp-with-time-zone) ``` Instant in time that includes the date and time of day with a time...
This is a continuation of this issue: https://github.com/apache/pinot/issues/11894 ## Background When rebalancing upsert tables, we are noticing that nearly all segments are moving to a new host with `minimizeDataMovement` on....
`feature` `ingestion` To ingest json-like data through SchemaConformingTransformer, previously, we could only dump data to either dedicated column or a single json_data field. We may build json index on json_data...
Our `OnHeapStringDictionary` implementation can result in a lot of wasted heap usage if there are enough duplicates in a column. Below is JXray analysis of the heapdump for one usecase...
add listKeys() scalar transformation function and unit tests under new mapfunctions class. takes in JSON map input and outputs string array of all keys in map.
We are testing some multistage queries with joins and adaptive routing turned on on a table using 3 replicas, 30 servers each. We joined against another much smaller table 90...
Saw these failures as part of #14064. TPCH ``` Error: TPCHQueryIntegrationTest.testTPCHQueries:111->testQueriesSucceed:115 » PinotClient java.util.concurrent.TimeoutException ``` pinot-kafka-3.0 ``` 21:49:15.240 ERROR [KafkaServer] [main] Fatal error during KafkaServer startup. Prepare to shutdown kafka.zookeeper.ZooKeeperClientTimeoutException:...