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

Reply via email to