pinot
pinot copied to clipboard
Published
20 hours ago •
apache
apache
Start Kafka after zookeeper in integration tests
Codecov Report
All modified and coverable lines are covered by tests :white_check_mark:
Project coverage is 63.72%. Comparing base (
59551e4) to head (bd7511a). Report is 1222 commits behind head on master.
Additional details and impacted files
@@ Coverage Diff @@
## master #14270 +/- ##
============================================
+ Coverage 61.75% 63.72% +1.97%
- Complexity 207 1528 +1321
============================================
Files 2436 2628 +192
Lines 133233 144989 +11756
Branches 20636 22184 +1548
============================================
+ Hits 82274 92396 +10122
- Misses 44911 45763 +852
- Partials 6048 6830 +782
| Flag | Coverage Δ | |
|---|---|---|
| custom-integration1 | ? |
|
| integration | ? |
|
| integration1 | ? |
|
| integration2 | ? |
|
| java-11 | 63.69% <ø> (+1.98%) |
:arrow_up: |
| java-21 | 63.61% <ø> (+1.99%) |
:arrow_up: |
| skip-bytebuffers-false | 63.72% <ø> (+1.97%) |
:arrow_up: |
| skip-bytebuffers-true | 63.57% <ø> (+35.84%) |
:arrow_up: |
| temurin | 63.72% <ø> (+1.97%) |
:arrow_up: |
| unittests | 63.72% <ø> (+1.97%) |
:arrow_up: |
| unittests1 | 55.40% <ø> (+8.51%) |
:arrow_up: |
| unittests2 | 34.31% <ø> (+6.58%) |
:arrow_up: |
Flags with carried forward coverage won't be shown. Click here to find out more.
:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.
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)
@xiangfu0 the PR title says
Start Kafka after zookeeper in integration testsbut from what I can tell, that was already the case in all the integration tests? The thing being changed here is starting Kafka before starting the Pinot cluster right?
Yes, I was playing around the startup sequence to see if that would improve the integration test pass rate.