pinot

pinot copied to clipboard

added a default groupid in kafka consumer

14

Description: This PR adds a default groupid in kafka consumer This PR will solve the following issue -- #9183 Testing: Added KafkaStreamLevelStreamConfigTest.java to ensure that default value is added to...

tanmesh

Following the guide from [kubernetes-quickstart](https://docs.pinot.apache.org/basics/getting-started/kubernetes-quickstart#3.4-load-data-into-kafka-and-create-pinot-schema-tables) When I run the jobs in section "Load data into Kafka and create Pinot schema/tables" `kubectl apply -f pinot/pinot-realtime-quickstart.yml ` The job container 'pinot-add-example-realtime-table-avro' fails...

amitoj

[colocated-join] Add Support for Deterministic Segment Assignment Strategy

6

Will use this PR to discuss some questions offline and update details here afterwards.

ankitsultana

[BUG] Can not override existing schemas even with override=true (POST /schemas API)

5

Hi, we just noticed there is one change introduced by [#7374](https://github.com/apache/pinot/pull/7374). A new checking schema.isBackwardCompatibleWith(oldSchema) is added for POST /schemas API. With the checking, we can not modify any existing...

MeihanLi

optimize `order by sorted ASC, unsorted` and `order by DESC` cases

9

Below the line is the original PR comment. After the PR was open, some things have changed. Specially: - The DESC case is also optimized - The `partial-order-by` option, which...

gortiz

[multistage] support additional SQL feature tracker

1

Many SQL features are not yet supported in multistage engine, because one of the two followings: - stage plan node in pinot-query-planner hasn't been implemented yet. - operator in pinot-query-runtime...

walterddr

[Feature] Support for Correlation Function

4

Add support for calculating Pearson's coefficient `corr(x,y)` as part of the effort in #8493. Can leverage implementation for COVAR_SAMP and COVAR_POP as mentioned in #9236.

SabrinaZhaozyf

[Question] whether refreshing/ingesting segments will cause it to rebalance?

4

Hello! We are doing some work to make changes for our tables to utilize "pool based" assignment strategy. A question that I encountered is do we need to rebalance the...

xuhui-stripe

At the moment only Dropwizard/Yammer metrics are provided. A new plugin for Micrometer metrics would be a nice to have. However, I think this should reside in a separate project....

ddcprg

[multistage] Support limit properly

1

Currently `select * from tbl limit 10` returns a unimplemented exception because limit is considered as an `Order By` with `fetch top 10`. since we do not order with limit...

walterddr