xiangfu0 commented on PR #14270: URL: https://github.com/apache/pinot/pull/14270#issuecomment-2427943924
Saw errors like this: ``` Oct 21, 2024 11:43:47 PM io.grpc.internal.ServerCallImpl handleInternalError 23:43:47.045 ERROR [OpChainSchedulerService] [query-runner-on-45967-1-thread-12] (OpChain{2087751583000000061_1_3}): Completed erroneously null {200=QueryExecutionError: org.apache.pinot.spi.exception.BadQueryRequestException: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:157) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache$CachedValue.ensureDataType(ValueBasedSegmentPruner.java:226) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache.get(ValueBasedSegmentPruner.java:197) at org.apache.pinot.core.query.pruner.ColumnValueSegmentPruner.pruneInPredicate(ColumnValueSegmentPruner.java:146) ... Caused by: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.spi.data.FieldSpec$DataType.convertInternal(FieldSpec.java:724) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:155) ... 18 more} 23:43:47.046 ERROR [OpChainSchedulerService] [query-runner-on-36145-3-thread-17] (OpChain{2087751583000000061_0_2}): Completed erroneously null {200=QueryExecutionError: org.apache.pinot.spi.exception.BadQueryRequestException: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:157) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache$CachedValue.ensureDataType(ValueBasedSegmentPruner.java:226) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache.get(ValueBasedSegmentPruner.java:197) at org.apache.pinot.core.query.pruner.ColumnValueSegmentPruner.pruneInPredicate(ColumnValueSegmentPruner.java:146) ... Caused by: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.spi.data.FieldSpec$DataType.convertInternal(FieldSpec.java:724) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:155) ... 18 more} 23:43:47.046 ERROR [OpChainSchedulerService] [query-runner-on-45967-1-thread-10] (OpChain{2087751583000000061_1_2}): Completed erroneously null {200=QueryExecutionError: org.apache.pinot.spi.exception.BadQueryRequestException: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:157) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache$CachedValue.ensureDataType(ValueBasedSegmentPruner.java:226) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache.get(ValueBasedSegmentPruner.java:197) at org.apache.pinot.core.query.pruner.ColumnValueSegmentPruner.pruneInPredicate(ColumnValueSegmentPruner.java:146) ... WARNING: Cancelling the stream because of internal error io.grpc.StatusRuntimeException: INTERNAL: Completed without a response at io.grpc.Status.asRuntimeException(Status.java:524) at io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:223) at io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:213) at io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:395) at org.apache.pinot.query.service.server.QueryServer.cancel(QueryServer.java:229) at org.apache.pinot.common.proto.PinotQueryWorkerGrpc$MethodHandlers.invoke(PinotQueryWorkerGrpc.java:409) at io.grpc.stub.ServerCalls$UnaryServerCallHandler$UnaryServerCallListener.onHalfClose(ServerCalls.java:182) at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:356) at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:861) at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1583) Oct 21, 2024 11:43:47 PM io.grpc.internal.ServerCallImpl handleInternalError WARNING: Cancelling the stream because of internal error io.grpc.StatusRuntimeException: INTERNAL: Completed without a response at io.grpc.Status.asRuntimeException(Status.java:524) at io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:223) at io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:213) at io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:395) at org.apache.pinot.query.service.server.QueryServer.cancel(QueryServer.java:229) at org.apache.pinot.common.proto.PinotQueryWorkerGrpc$MethodHandlers.invoke(PinotQueryWorkerGrpc.java:409) at io.grpc.stub.ServerCalls$UnaryServerCallHandler$UnaryServerCallListener.onHalfClose(ServerCalls.java:182) at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:356) at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:861) at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1583) Caused by: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.spi.data.FieldSpec$DataType.convertInternal(FieldSpec.java:724) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:155) ... 18 more} 23:43:47.046 ERROR [OpChainSchedulerService] [query-runner-on-36145-3-thread-8] (OpChain{2087751583000000061_0_1}): Completed erroneously null {200=QueryExecutionError: org.apache.pinot.spi.exception.BadQueryRequestException: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:157) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache$CachedValue.ensureDataType(ValueBasedSegmentPruner.java:226) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache.get(ValueBasedSegmentPruner.java:197) at org.apache.pinot.core.query.pruner.ColumnValueSegmentPruner.pruneInPredicate(ColumnValueSegmentPruner.java:146) ... Caused by: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.spi.data.FieldSpec$DataType.convertInternal(FieldSpec.java:724) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:155) ... 18 more} 23:43:47.047 ERROR [OpChainSchedulerService] [query-runner-on-45967-1-thread-11] (OpChain{2087751583000000061_1_1}): Completed erroneously null {200=QueryExecutionError: org.apache.pinot.spi.exception.BadQueryRequestException: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:157) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache$CachedValue.ensureDataType(ValueBasedSegmentPruner.java:226) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache.get(ValueBasedSegmentPruner.java:197) at org.apache.pinot.core.query.pruner.ColumnValueSegmentPruner.pruneInPredicate(ColumnValueSegmentPruner.java:146) ... Caused by: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.spi.data.FieldSpec$DataType.convertInternal(FieldSpec.java:724) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:155) ... 18 more} 23:43:47.048 ERROR [OpChainSchedulerService] [query-runner-on-36145-3-thread-7] (OpChain{2087751583000000061_0_3}): Completed erroneously null {200=QueryExecutionError: org.apache.pinot.spi.exception.BadQueryRequestException: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:157) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache$CachedValue.ensureDataType(ValueBasedSegmentPruner.java:226) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache.get(ValueBasedSegmentPruner.java:197) at org.apache.pinot.core.query.pruner.ColumnValueSegmentPruner.pruneInPredicate(ColumnValueSegmentPruner.java:146) ... Caused by: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.spi.data.FieldSpec$DataType.convertInternal(FieldSpec.java:724) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:155) ... 18 more} 23:43:47.055 ERROR [MultiStageBrokerRequestHandler] [jersey-server-managed-async-executor-3] Caught exception executing request 2087751583000000061: SELECT MAX(CRSArrTime), AVG(CAST("ArrDel15" AS DOUBLE)) FROM mytable WHERE WeatherDelay BETWEEN 59 AND 228 GROUP BY LongestAddGTime, CRSArrTime HAVING MAX(CRSArrTime) IN (4309.587, 4319.672) AND MAX(CRSArrTime) BETWEEN 918.5392 AND 7404.9795 LIMIT 15, Received error query execution result block: {200=QueryExecutionError: org.apache.pinot.spi.exception.BadQueryRequestException: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:157) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache$CachedValue.ensureDataType(ValueBasedSegmentPruner.java:226) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner$ValueCache.get(ValueBasedSegmentPruner.java:197) at org.apache.pinot.core.query.pruner.ColumnValueSegmentPruner.pruneInPredicate(ColumnValueSegmentPruner.java:146) ... Caused by: java.lang.IllegalArgumentException: Cannot convert value: '4309.0' to type: INT at org.apache.pinot.spi.data.FieldSpec$DataType.convertInternal(FieldSpec.java:724) at org.apache.pinot.core.query.pruner.ValueBasedSegmentPruner.convertValue(ValueBasedSegmentPruner.java:155) ... 18 more} org.apache.pinot.query.service.dispatch.QueryDispatcher.runReducer(QueryDispatcher.java:482) org.apache.pinot.query.service.dispatch.QueryDispatcher.submitAndReduce(QueryDispatcher.java:117) org.apache.pinot.broker.requesthandler.MultiStageBrokerRequestHandler.handleRequest(MultiStageBrokerRequestHandler.java:227) org.apache.pinot.broker.requesthandler.BaseBrokerRequestHandler.handleRequest(BaseBrokerRequestHandler.java:155) 23:43:58.961 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__0__20241021T2342Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.961 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__0__20241021T2342Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.961 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__7__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.961 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__4__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.961 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__4__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.961 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__7__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.961 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__10__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.961 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__1__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.961 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__6__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__3__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__3__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__10__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__2__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__9__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__9__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__6__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__1__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__11__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__8__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__11__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__8__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__2__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.962 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__5__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.963 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__5__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.978 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16282_16312_7 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:58.978 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16190_16220_4 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:58.978 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16251_16281_6 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:58.978 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16071_16101_0 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:58.978 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16130_16159_2 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:58.978 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16221_16250_5 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:58.978 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16102_16129_1 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:58.978 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16160_16189_3 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:58.978 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__0__20241021T2342Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__0__20241021T2342Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__7__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__4__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__4__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__7__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__10__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__1__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__6__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__3__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__3__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__10__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__2__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__9__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.979 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__9__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.980 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__6__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.980 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__1__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.980 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__11__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.980 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__8__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.980 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__11__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.980 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__8__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.980 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__2__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.980 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__5__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:58.980 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__5__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.081 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16282_16312_7 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.082 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16190_16220_4 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.082 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16251_16281_6 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.082 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16071_16101_0 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.082 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16130_16159_2 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.082 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16221_16250_5 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.082 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16102_16129_1 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.082 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16160_16189_3 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.204 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__0__20241021T2342Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.204 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__0__20241021T2342Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.204 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__7__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.204 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__4__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__4__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__7__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__10__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__1__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__6__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__3__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__3__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__10__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__2__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__9__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__9__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__6__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__1__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.205 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__11__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.206 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__8__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.206 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__11__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.206 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__8__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.206 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__2__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.206 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__1__5__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.206 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable__0__5__20241021T2343Z for table: mytable_REALTIME (all candidate instances: [Server_localhost_22004] are disabled, counting segment as unavailable) 23:43:59.319 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16282_16312_7 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.319 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16190_16220_4 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.319 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16251_16281_6 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.320 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16071_16101_0 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.320 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16130_16159_2 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.320 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16221_16250_5 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.320 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16102_16129_1 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:43:59.320 WARN [BaseInstanceSelector] [ClusterChangeHandlingThread] Failed to find servers hosting old segment: mytable_16160_16189_3 % for table: mytable_OFFLINE (all candidate instances: [Server_localhost_22001] are disabled, counting segment as unavailable) 23:44:21.070 WARN [MultiStageBrokerRequestHandler] [jersey-server-managed-async-executor-3] Caught exception planning request 208[7751](https://github.com/apache/pinot/actions/runs/11450116144/job/31856988151?pr=14270#step:6:7752)583000000158: SELECT COUNT(*) FROM potato, Error composing query plan for: SELECT COUNT(*) FROM potato org.apache.pinot.query.QueryEnvironment.planQuery(QueryEnvironment.java:198) org.apache.pinot.broker.requesthandler.MultiStageBrokerRequestHandler.handleRequest(MultiStageBrokerRequestHandler.java:165) Oct 21, 2024 11:44:21 PM io.grpc.internal.ServerCallImpl handleInternalError org.apache.pinot.broker.requesthandler.BaseBrokerRequestHandler.handleRequest(BaseBrokerRequestHandler.java:155) org.apache.pinot.broker.requesthandler.BrokerRequestHandlerDelegate.handleRequest(BrokerRequestHandlerDelegate.java:104) Table does not exist: 'potato' com.google.common.base.Preconditions.checkArgument(Preconditions.java:143) org.apache.pinot.query.catalog.PinotCatalog.getTable(PinotCatalog.java:71) org.apache.calcite.jdbc.SimpleCalciteSchema.getImplicitTable(SimpleCalciteSchema.java:128) org.apache.calcite.jdbc.CalciteSchema.getTable(CalciteSchema.java:283) 23:44:21.074 WARN [MultiStageBrokerRequestHandler] [jersey-server-managed-async-executor-3] Caught exception planning request 2087751583000000159: SELECT POTATO(ArrTime) FROM mytable, Error composing query plan for 'SELECT POTATO(ArrTime) FROM mytable': From line 1, column 8 to line 1, column 22: No match found for function signature POTATO(<NUMERIC>)' org.apache.pinot.query.QueryEnvironment.planQuery(QueryEnvironment.java:196) org.apache.pinot.broker.requesthandler.MultiStageBrokerRequestHandler.handleRequest(MultiStageBrokerRequestHandler.java:165) org.apache.pinot.broker.requesthandler.BaseBrokerRequestHandler.handleRequest(BaseBrokerRequestHandler.java:155) org.apache.pinot.broker.requesthandler.BrokerRequestHandlerDelegate.handleRequest(BrokerRequestHandlerDelegate.java:104) From line 1, column 8 to line 1, column 22: No match found for function signature POTATO(<NUMERIC>) java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:62) java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:502) java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:486) org.apache.calcite.runtime.Resources$ExInstWithCause.ex(Resources.java:507) No match found for function signature POTATO(<NUMERIC>) java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:62) java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:502) java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:486) org.apache.calcite.runtime.Resources$ExInstWithCause.ex(Resources.java:507) 23:44:21.100 ERROR [BaseCombineOperator] [query-runner-on-36145-3-thread-8] Caught exception while processing query: QueryContext{_tableName='mytable_REALTIME', _subquery=null, _selectExpressions=[count(*)], _distinct=false, _aliasList=[null], _filter=(minus(ArrTime,cast('potato','INT')) = '0' AND DaysSinceEpoch > '16311'), _groupByExpressions=null, _havingFilter=null, _orderByExpressions=null, _limit=2147483647, _offset=0, _queryOptions={useMultistageEngine=true, timeBoundaryInfo.timeValue=16311, requestId=2087751583000000160, timeoutMs=59996, tableName=mytable, timeBoundaryInfo.timeColumn=DaysSinceEpoch}, _expressionOverrideHints={}, _explain=NONE} java.lang.IllegalArgumentException: Invalid int value: potato at org.apache.pinot.common.request.context.LiteralContext.getIntValue(LiteralContext.java:215) ~[pinot-common-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.LiteralTransformFunction.getIntLiteral(LiteralTransformFunction.java:64) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.LiteralTransformFunction.transformToIntValuesSV(LiteralTransformFunction.java:129) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.CastTransformFunction.transformToIntValuesSV(CastTransformFunction.java:128) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.BaseTransformFunction.transformToDoubleValuesSV(BaseTransformFunction.java:315) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.CastTransformFunction.transformToDoubleValuesSV(CastTransformFunction.java:210) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.SubtractionTransformFunction.transformToDoubleValuesSV(SubtractionTransformFunction.java:117) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.dociditerators.ExpressionScanDocIdIterator.processProjectionBlock(ExpressionScanDocIdIterator.java:244) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.dociditerators.ExpressionScanDocIdIterator.next(ExpressionScanDocIdIterator.java:94) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.dociditerators.ExpressionScanDocIdIterator.advance(ExpressionScanDocIdIterator.java:119) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.dociditerators.AndDocIdIterator.next(AndDocIdIterator.java:51) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.DocIdSetOperator.getNextBlock(DocIdSetOperator.java:75) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.DocIdSetOperator.getNextBlock(DocIdSetOperator.java:39) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:48) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.ProjectionOperator.getNextBlock(ProjectionOperator.java:71) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.ProjectionOperator.getNextBlock(ProjectionOperator.java:38) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:48) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.query.AggregationOperator.getNextBlock(AggregationOperator.java:73) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] 23:44:21.105 ERROR [BaseCombineOperator] [query-runner-on-45967-1-thread-9] Caught exception while processing query: QueryContext{_tableName='mytable_OFFLINE', _subquery=null, _selectExpressions=[count(*)], _distinct=false, _aliasList=[null], _filter=(minus(ArrTime,cast('potato','INT')) = '0' AND DaysSinceEpoch <= '16311'), _groupByExpressions=null, _havingFilter=null, _orderByExpressions=null, _limit=2147483647, _offset=0, _queryOptions={useMultistageEngine=true, timeBoundaryInfo.timeValue=16311, requestId=2087751583000000160, timeoutMs=59991, tableName=mytable, timeBoundaryInfo.timeColumn=DaysSinceEpoch}, _expressionOverrideHints={}, _explain=NONE} java.lang.IllegalArgumentException: Invalid int value: potato at org.apache.pinot.common.request.context.LiteralContext.getIntValue(LiteralContext.java:215) ~[pinot-common-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.LiteralTransformFunction.getIntLiteral(LiteralTransformFunction.java:64) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.LiteralTransformFunction.transformToIntValuesSV(LiteralTransformFunction.java:129) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.CastTransformFunction.transformToIntValuesSV(CastTransformFunction.java:128) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.BaseTransformFunction.transformToDoubleValuesSV(BaseTransformFunction.java:315) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.CastTransformFunction.transformToDoubleValuesSV(CastTransformFunction.java:210) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.SubtractionTransformFunction.transformToDoubleValuesSV(SubtractionTransformFunction.java:117) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.dociditerators.ExpressionScanDocIdIterator.processProjectionBlock(ExpressionScanDocIdIterator.java:244) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.dociditerators.ExpressionScanDocIdIterator.next(ExpressionScanDocIdIterator.java:94) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.DocIdSetOperator.getNextBlock(DocIdSetOperator.java:75) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.DocIdSetOperator.getNextBlock(DocIdSetOperator.java:39) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:48) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.ProjectionOperator.getNextBlock(ProjectionOperator.java:71) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.ProjectionOperator.getNextBlock(ProjectionOperator.java:38) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:48) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.query.AggregationOperator.getNextBlock(AggregationOperator.java:73) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.query.AggregationOperator.getNextBlock(AggregationOperator.java:43) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:48) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.combine.BaseSingleBlockCombineOperator.processSegments(BaseSingleBlockCombineOperator.java:94) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.combine.BaseCombineOperator$1.runJob(BaseCombineOperator.java:117) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.util.trace.TraceRunnable.run(TraceRunnable.java:40) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?] at java.base/java.lang.Thread.run(Thread.java:1583) [?:?] 23:44:21.105 ERROR [BaseCombineOperator] [query-runner-on-45967-1-thread-4] Caught exception while processing query: QueryContext{_tableName='mytable_OFFLINE', _subquery=null, _selectExpressions=[count(*)], _distinct=false, _aliasList=[null], _filter=(minus(ArrTime,cast('potato','INT')) = '0' AND DaysSinceEpoch <= '16311'), _groupByExpressions=null, _havingFilter=null, _orderByExpressions=null, _limit=2147483647, _offset=0, _queryOptions={useMultistageEngine=true, timeBoundaryInfo.timeValue=16311, requestId=2087751583000000160, timeoutMs=59991, tableName=mytable, timeBoundaryInfo.timeColumn=DaysSinceEpoch}, _expressionOverrideHints={}, _explain=NONE} java.lang.IllegalArgumentException: Invalid int value: potato at org.apache.pinot.common.request.context.LiteralContext.getIntValue(LiteralContext.java:215) ~[pinot-common-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.LiteralTransformFunction.getIntLiteral(LiteralTransformFunction.java:64) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.LiteralTransformFunction.transformToIntValuesSV(LiteralTransformFunction.java:129) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.CastTransformFunction.transformToIntValuesSV(CastTransformFunction.java:128) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.BaseTransformFunction.transformToDoubleValuesSV(BaseTransformFunction.java:315) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.CastTransformFunction.transformToDoubleValuesSV(CastTransformFunction.java:210) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.transform.function.SubtractionTransformFunction.transformToDoubleValuesSV(SubtractionTransformFunction.java:117) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.dociditerators.ExpressionScanDocIdIterator.processProjectionBlock(ExpressionScanDocIdIterator.java:244) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.dociditerators.ExpressionScanDocIdIterator.applyAnd(ExpressionScanDocIdIterator.java:142) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.docidsets.AndDocIdSet.iterator(AndDocIdSet.java:168) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.DocIdSetOperator.getNextBlock(DocIdSetOperator.java:67) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.DocIdSetOperator.getNextBlock(DocIdSetOperator.java:39) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:48) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.ProjectionOperator.getNextBlock(ProjectionOperator.java:71) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.ProjectionOperator.getNextBlock(ProjectionOperator.java:38) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:48) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.query.AggregationOperator.getNextBlock(AggregationOperator.java:73) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.query.AggregationOperator.getNextBlock(AggregationOperator.java:43) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.BaseOperator.nextBlock(BaseOperator.java:48) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.combine.BaseSingleBlockCombineOperator.processSegments(BaseSingleBlockCombineOperator.java:94) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.operator.combine.BaseCombineOperator$1.runJob(BaseCombineOperator.java:117) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at org.apache.pinot.core.util.trace.TraceRunnable.run(TraceRunnable.java:40) ~[pinot-core-1.3.0-SNAPSHOT.jar:1.3.0-SNAPSHOT-ab7ea4983b0a61f58cf658a03783d97b5e041c78] at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?] at java.base/java.lang.Thread.run(Thread.java:1583) [?:?] 23:44:21.105 ERROR [MultiStageBrokerRequestHandler] [jersey-server-managed-async-executor-3] Caught exception executing request 2087751583000000160: SELECT COUNT(*) FROM mytable where ArrTime = 'potato', Received error query execution result block: {200=QueryExecutionError: java.lang.IllegalArgumentException: Invalid int value: potato at org.apache.pinot.common.request.context.LiteralContext.getIntValue(LiteralContext.java:215) at org.apache.pinot.core.operator.transform.function.LiteralTransformFunction.getIntLiteral(LiteralTransformFunction.java:64) at org.apache.pinot.core.operator.transform.function.LiteralTransformFunction.transformToIntValuesSV(LiteralTransformFunction.java:129) at org.apache.pinot.core.operator.transform.function.CastTransformFunction.transformToIntValuesSV(CastTransformFunction.java:128)} org.apache.pinot.query.service.dispatch.QueryDispatcher.runReducer(QueryDispatcher.java:482) org.apache.pinot.query.service.dispatch.QueryDispatcher.submitAndReduce(QueryDispatcher.java:117) org.apache.pinot.broker.requesthandler.MultiStageBrokerRequestHandler.handleRequest(MultiStageBrokerRequestHandler.java:227) org.apache.pinot.broker.requesthandler.BaseBrokerRequestHandler.handleRequest(BaseBrokerRequestHandler.java:155) ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org