ly923976094 commented on issue #3626: timezone problem URL: https://github.com/apache/incubator-pinot/issues/3626#issuecomment-450548401 > The second statement has EPOCH (which is UTC). Statement 1 is the only way to specify time zone. Seems like you don't have a filter in your query, which means you are essentially applying the transform on all the records. How many records do are there in this table? What is the query latency you are seeing? Also, is this a test query or a real query that you plan to run in production (ie without any filters)? yes，For a real query running in a production environment, such as this table video_market-video_download_performance_full_day, about 1.5g of data per day, querying 30 days of data, a total of 1237838944 rows of data, executing pq1 (server query timeout) and pql2 takes the following results pq1: select sum(total_count) from video_market-video_download_performance_full_day where fdate >= 1543593600000 and fdate < 1546271999000 group by dateTimeConvert(fdate, '1:MILLISECONDS:EPOCH','1:MILLISECONDS:SIMPLE_DATE_FORMAT:yyyy-MM-dd HH:mm:ss tz(Asia/Shanghai)', '1:DAYS') { "exceptions":[ { "errorCode":200, "message":"QueryExecutionError: java.util.concurrent.TimeoutException: Timed out while combining group-by results after 14999ms at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:168) at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:50) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:34) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:23) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.plan.GlobalPlanImplV0.execute(GlobalPlanImplV0.java:45) at com.linkedin.pinot.core.query.executor.ServerQueryExecutorV1Impl.processQuery(ServerQueryExecutorV1Impl.java:159) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.processQueryAndSerialize(QueryScheduler.java:127) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.lambda$createQueryFutureTask$0(QueryScheduler.java:112) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108) at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41)" }, { "errorCode":200, "message":"QueryExecutionError: java.util.concurrent.TimeoutException: Timed out while combining group-by results after 15000ms at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:168) at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:50) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:34) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:23) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.plan.GlobalPlanImplV0.execute(GlobalPlanImplV0.java:45) at com.linkedin.pinot.core.query.executor.ServerQueryExecutorV1Impl.processQuery(ServerQueryExecutorV1Impl.java:159) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.processQueryAndSerialize(QueryScheduler.java:127) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.lambda$createQueryFutureTask$0(QueryScheduler.java:112) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108) at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41)" }, { "errorCode":200, "message":"QueryExecutionError: java.util.concurrent.TimeoutException: Timed out while combining group-by results after 14999ms at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:168) at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:50) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:34) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:23) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.plan.GlobalPlanImplV0.execute(GlobalPlanImplV0.java:45) at com.linkedin.pinot.core.query.executor.ServerQueryExecutorV1Impl.processQuery(ServerQueryExecutorV1Impl.java:159) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.processQueryAndSerialize(QueryScheduler.java:127) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.lambda$createQueryFutureTask$0(QueryScheduler.java:112) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108) at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41)" }, { "errorCode":200, "message":"QueryExecutionError: java.util.concurrent.TimeoutException: Timed out while combining group-by results after 15000ms at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:168) at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:50) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:34) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:23) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.plan.GlobalPlanImplV0.execute(GlobalPlanImplV0.java:45) at com.linkedin.pinot.core.query.executor.ServerQueryExecutorV1Impl.processQuery(ServerQueryExecutorV1Impl.java:159) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.processQueryAndSerialize(QueryScheduler.java:127) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.lambda$createQueryFutureTask$0(QueryScheduler.java:112) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108) at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41)" }, { "errorCode":200, "message":"QueryExecutionError: java.util.concurrent.TimeoutException: Timed out while combining group-by results after 15000ms at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:168) at com.linkedin.pinot.core.operator.CombineGroupByOperator.getNextBlock(CombineGroupByOperator.java:50) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:34) at com.linkedin.pinot.core.operator.InstanceResponseOperator.getNextBlock(InstanceResponseOperator.java:23) at com.linkedin.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:42) at com.linkedin.pinot.core.plan.GlobalPlanImplV0.execute(GlobalPlanImplV0.java:45) at com.linkedin.pinot.core.query.executor.ServerQueryExecutorV1Impl.processQuery(ServerQueryExecutorV1Impl.java:159) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.processQueryAndSerialize(QueryScheduler.java:127) at com.linkedin.pinot.core.query.scheduler.QueryScheduler.lambda$createQueryFutureTask$0(QueryScheduler.java:112) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108) at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41)" } ], "numServersQueried":6, "numServersResponded":6, "numDocsScanned":170287136, "numEntriesScannedInFilter":340574272, "numEntriesScannedPostFilter":340574272, "totalDocs":1237838944, "numGroupsLimitReached":false, "timeUsedMs":35737, "segmentStatistics":[ ], "traceInfo":{ } } pq2: select sum(total_count) from video_market-video_download_performance_full_day where fdate >= 1543593600000 and fdate < 1546271999000 group by dateTimeConvert(fdate, '1:MILLISECONDS:EPOCH','1:MILLISECONDS:EPOCH', '1:DAYS') { "aggregationResults": [ { "groupByResult": [ { "value": "5214728856.00000", "group": ["1543622400000"] }, { "value": "5146017730.00000", "group": ["1544227200000"] }, { "value": "4950169463.00000", "group": ["1545868800000"] }, { "value": "4912167135.00000", "group": ["1545696000000"] }, { "value": "4894003737.00000", "group": ["1545436800000"] }, { "value": "4882993768.00000", "group": ["1545782400000"] }, { "value": "4612845413.00000", "group": ["1544140800000"] }, { "value": "4612000264.00000", "group": ["1543536000000"] }, { "value": "4581314177.00000", "group": ["1544832000000"] }, { "value": "4510667574.00000", "group": ["1545609600000"] }], "function": "sum_total_count", "groupByColumns": ["datetimeconvert(fdate,'1:MILLISECONDS:EPOCH','1:MILLISECONDS:EPOCH','1:DAYS')"] }], "exceptions": [], "numServersQueried": 6, "numServersResponded": 6, "numDocsScanned": 1074252463, "numEntriesScannedInFilter": 2148504926, "numEntriesScannedPostFilter": 2148504926, "totalDocs": 1237838944, "numGroupsLimitReached": false, "timeUsedMs": 5750, "segmentStatistics": [], "traceInfo": {} }
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
