https://pinot.apache.org/ logo
Join Slack
Powered by
Facing the issue with when I am running below quer...
# general
a
Facing the issue with when I am running below query - 
WITH ACTE AS (Select distinct tt.col1, tt.col2 FROM (Select *, row_number() over(partition by col3 order by col4 DESC) as rnk From  A
WHERE A.col4 between '2024-05-01' and '2024-05-02') tt
WHERE tt.rnk=1),
BCTE AS (
Select * From (Select *, row_number() over(partition by col1 order by col2 DESC) as rnk
FROM B
WHERE col3 in (SELECT CONCAT('', col1) FROM ACTE) or
lp_uuid in (SELECT CONCAT('', col2) FROM ACTE)) pu
WHERE pu.rnk=1)
Select * FROM BCTE
Error Code: 200 QueryExecutionError: Received error query execution result block: {1000=Cancelled by sender java.lang.RuntimeException: Cancelled by sender at org.apache.pinot.query.mailbox.channel.MailboxContentObserver.onError(MailboxContentObserver.java:124) at io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:288) at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:378) at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:365) ... Caused by: io.grpc.StatusRuntimeException: CANCELLED: client cancelled at io.grpc.Status.asRuntimeException(Status.java:530) at io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:291) ... 8 more}
@Xiang Fu
Can anyone please help @Xiang Fu
x
can you describe the query? also are you able to select values from 
ACTE
? Can you also try to extend the query latency for this query? there seems to be a lot of inefficient operations in the query
a
Yes able to select the values from 
ACTE
Tried extending the query latency but still it is giving same error as above also due to lots of memory consumption happening on the pinot server some of them are getting dead. cc: @Ashwin Agalcha @Shubham Setia @Ritesh Kumar
image.png
x
then this is likely due to timeout, can you try to increase the time out value ?
Open in Slack
PreviousNext
Powered by