Hi guys I am trying to use `LastWithTime` function to get th Apache Pinot #troubleshooting

Hi guys, I am trying to use `LastWithTime` functio...

George He

05/11/2022, 6:29 AM

Hi guys, I am trying to use

LastWithTime

function to get the latest data of each group. But unfortunately I got NPE exception. Original intention is to get the top N of a group after group by ad hoc column. Wondering if I have a grammar issue of my PQL:

Copy code

select hostname, lastWithTime('alertId', 'issued', 'STRING')   from uas_nomalized_alert 
where JSON_EXTRACT_SCALAR(attributes, '$.graphQL-businessService', 'STRING', '') = 'Meeting Centers'
group by hostname

alertId

is a 'STRING' column,

issued

is a 'TIMESTAMP' column

George He

05/12/2022, 2:14 AM

Hi, any update?

George He

05/12/2022, 3:21 AM

{ "message": "QueryExecutionError:\nProcessingException(errorCode:450, messageInternalError\njava.lang.NullPointerException\n\tat org.apache.pinot.core.operator.combine.GroupByOrderByCombineOperator.mergeResults(GroupByOrderByCombineOperator.java:236)\n\tat org.apache.pinot.core.operator.combine.BaseCombineOperator.getNextBlock(BaseCombineOperator.java:119)\n\tat org.apache.pinot.core.operator.combine.BaseCombineOperator.getNextBlock(BaseCombineOperator.java:50)", "errorCode": 200 }

Neha Pawar

05/12/2022, 9:59 PM

it’s probably the single quotes around the column names. This works for me

Copy code

select lastwithtime(repo, createdTimeMillis, 'STRING'), createdTimeMillis from pullRequestMergedEvents group by createdTimeMillis limit 10

Open in Slack

Previous Next