Start Kafka after zookeeper in integration tests

Start Kafka after zookeeper in integration tests

Codecov Report
All modified and coverable lines are covered by tests :white_check_mark:

Project coverage is 0.00%. Comparing base (59551e4) to head (cf8dfde).
Report is 1213 commits behind head on master.

:exclamation:  There is a different number of reports uploaded between BASE (59551e4) and HEAD (cf8dfde). Click for more details.
HEAD has 53 uploads less than BASE

Flag
BASE (59551e4)
HEAD (cf8dfde)

integration
7
1

integration2
3
1

temurin
12
1

java-21
7
1

skip-bytebuffers-true
3
1

skip-bytebuffers-false
7
0

unittests
5
0

unittests1
2
0

java-11
5
0

unittests2
3
0

integration1
2
0

custom-integration1
2
0

Additional details and impacted files
@@              Coverage Diff              @@
##             master   #14270       +/-   ##
=============================================
- Coverage     61.75%    0.00%   -61.76%
=============================================
  Files          2436        3     -2433
  Lines        133233        6   -133227
  Branches      20636        0    -20636
=============================================
- Hits          82274        0    -82274
+ Misses        44911        6    -44905
+ Partials       6048        0     -6048

Flag
Coverage Δ

custom-integration1
?

integration
0.00% <ø> (-0.01%)
:arrow_down:

integration1
?

integration2
0.00% <ø> (ø)

java-11
?

java-21
0.00% <ø> (-61.63%)
:arrow_down:

skip-bytebuffers-false
?

skip-bytebuffers-true
0.00% <ø> (-27.73%)
:arrow_down:

temurin
0.00% <ø> (-61.76%)
:arrow_down:

unittests
?

unittests1
?

unittests2
?

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<PHONE_NUMBER>000000061: 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<PHONE_NUMBER>000000159: 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<PHONE_NUMBER>000000160: 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)


Obsolete Auth 1.0

Will go in when Security switches over to Auth 2.0 (this will require all Auth usages to switch over to 2.0 as well)

Replaced by https://github.com/aspnet/HttpAbstractions/pull/866


HSEARCH-3383 Upgrade to a version of jqassistant that works correctly when we skip modules

https://hibernate.atlassian.net//browse/HSEARCH-3383

Pull Request Test Coverage Report for Build 1

0 of 0   changed or added relevant lines in 0 files are covered.
No unchanged relevant lines lost coverage.
Overall coverage remained the same at 86.609%

Totals

Change from base Build 52:
0.0%

Covered Lines:
11357

Relevant Lines:
13113

💛  - Coveralls

Merged, thanks!


Supervised Anomaly Accelerator Labs

We are in the process of releasing an accelerator and are interested in contributing to it also as a lab and are interested in contributing to a new Maximo lab.

Hi, please follow the instructions for contributing: http://maximo-lab.monitordemo4.ibmmam.com/contribute/


arduino project background has trouble loading and incorrectly spaced buttons

this issue does not appear on jumper labs x3 laptop with ubuntu and on brave browser btw but let be real who actually has one of those other than me

appears normal on macOS and Ubuntu, looking into other OS


After closing project in dashboard, we're getting repeatative connection error logs.

Looks like some connecting process is leaking.

We also get multiple "you may be a victim of scam" messages BTW.

A comment from the old parent issue:

re: multiple "you may be a victim of scam" messages
this is intentional, otherwise it's possible that it's scrolled out of view by the time the user opens the console. it's true that usually this shouldn't happen because currently no real logging happens, but i think it's better to be on the safe side


Make colored Write-Host calls (-ForegroundColor / -BackgroundColor) emit ANSI/VT sequences when stringified, notably in CLI output

Summary of the new feature / enhancement
Especially in CLI use, though also with Out-String, it is reasonable to expect Write-Host -ForegroundColor / -BackgroundColor to result in ANSI/VT sequences  (where supported) in the - invariably stringified - output.
Currently (PowerShell 7.4.0-preview.5), as the following example shows, colored Write-Host output is invariably stripped of its colors when stdout isn't a terminal, which is what necessitates stringification:
pwsh -NoProfile -c '
  $PSStyle.OutputRendering = "Ansi";
  Write-Host -ForegroundColor Green green!; $PSVersionTable
' |
 & { if ($IsWindows) { $input | findstr . } else { $input | cat } }

Sample output:

Note how green! is not colored, unlike the column headers in the $PSVersionTable output, due to having sent the CLI output to the pipeline for further processing.
As an aside: If you run the above on Windows in a regular console window (conhost.exe), you'll currently see the - conceptually unrelated - effects of this bug:

#19425

Why this is important:
Capturing a CLI call's output for logging / diagnostic purposes, such as in CI/CD environments, with the originally intended coloring consistently  captured, is an important visual aid (if viewed in a context where ANSI/VT sequences are rendered appropriately).
Proposed technical implementation details (optional)
No response

I got the error:

$PSStyle.OutputRendering = ""Ansi""; works as expected
To colorize Write-Host output I use escape sequences without Fore/Background (because no effect of them)
No effect:

The error implies that  $PSNativeCommandArgumentPassing is not at its default; the command works when it is at its default ('Standard on Unix, 'Windows' on Windows).
That you can use ANSI/VT escape sequences explicitly is beside the point.


4.6.3 Currently Showing Up Twice In UI

Micronaut version 4.6.3 is currently showing up twice in the UI.

This appears to not be an issue at the moment.


alias python to python3 for compatibility with astrobee scripts

Our baseline approach for Astrobee Python scripts is that they should be compatible with both Python 2 (for Ubuntu 16.04) and Python 3 (for 20.04) and start with the line #!/usr/bin/env python.
However, Ubuntu's consistent default across distros is that python runs Python 2 (if installed) or otherwise gives an error. In the latter case we need to alias python to run Python 3.
This is already handled in install_desktop_packages.sh, but since that script isn't currently invoked during setup on the ros2 branch, we can do it in the Dockerfile instead.
(Eventually, the Python scripts can be changed to run #!/usr/bin/env python3 and drop Python 2 compatibility, at which point the alias would no longer be needed, but it seems simpler to wait on that until after completing the ROS2 migration.)

One alternative to this is to install the package python-is-python3 on  >=Ubuntu 20.04 in case the update-alternatives is more difficult to get consistent.

One alternative to this is to install the package python-is-python3 on >=Ubuntu 20.04 in case the update-alternatives is more difficult to get consistent.

Good to know that exists! It does seem a bit simpler. But I think I'll go ahead this way since it's already a one-liner and it's been tested a lot.


Slow response times

I'm able to access D1 located in (Eastern NA) from Hetzner (ash-dc1 in Ashburn, VA), however any simple query is taking 3-4 seconds. Tested connecting to Western NA D1 instance from my local machine in California, it's also similary slow. Is this a known limitation?

Hey @erinc yes, the D1 API is a bit slow for now.
You should try the workers-dbms engine, you just need to deploy a worker in your cloudflare account and that's it, your requests will then be much faster because they are sent via websockets
https://github.com/G4brym/django-cf?tab=readme-ov-file#using-with-durable-objects


run llama 3.1 405B has error[Usage]:

Your current environment
The output of `python collect_env.py`

environment
two node,node1 and node2,every node eth set is
eth0 is the controller network
eth1 to eth8 is the GPU RoCe network
vllm version：vLLM API server version 0.5.3.post1
the start command is：
GLOO_SOCKET_IFNAME=eth0  NCCL_SOCKET_IFNAME=eth0 TP_SOCKET_IFNAME="eth0"  vllm serve /models  --tensor-parallel-size 16
the error is：
DEBUG 08-02 08:50:03 parallel_state.py:803] world_size=16 rank=0 local_rank=0 distributed_init_method=tcp://<IP_ADDRESS>:34773 backend=nccl
(RayWorkerWrapper pid=1978, ip=<IP_ADDRESS>) [rank9]:[W ProcessGroupGloo.cpp:721] Warning: Unable to resolve hostname to a (local) address. Using the loopback address as fallback. Manually set the network interface to bind to with GLOO_SOCKET_IFNAME. (function operator())
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) [rank8]:[E ProcessGroupGloo.cpp:144] Gloo connectFullMesh failed with [../third_party/gloo/gloo/transport/tcp/pair.cc:144] no error
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382] Error executing method init_device. This might cause deadlock in distributed execution.
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382] Traceback (most recent call last):
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/vllm/worker/worker_base.py", line 374, in execute_method
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     return executor(*args, **kwargs)
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/vllm/worker/worker.py", line 132, in init_device
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     init_worker_distributed_environment(self.parallel_config, self.rank,
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/vllm/worker/worker.py", line 343, in init_worker_distributed_environment
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     init_distributed_environment(parallel_config.world_size, rank,
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/vllm/distributed/parallel_state.py", line 830, in init_distributed_environment
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     _WORLD = init_world_group(ranks, local_rank, backend)
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/vllm/distributed/parallel_state.py", line 714, in init_world_group
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     return GroupCoordinator(
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/vllm/distributed/parallel_state.py", line 149, in init
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     cpu_group = torch.distributed.new_group(ranks, backend="gloo")
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/torch/distributed/c10d_logger.py", line 89, in wrapper
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     func_return = func(*args, **kwargs)
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/torch/distributed/distributed_c10d.py", line 3868, in new_group
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     return _new_group_with_tag(ranks, timeout, backend, pg_options, None, use_local_synchronization=use_local_synchronization)
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/torch/distributed/distributed_c10d.py", line 3939, in _new_group_with_tag
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     pg, pg_store = _new_process_group_helper(
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]   File "/usr/local/lib/python3.10/dist-packages/torch/distributed/distributed_c10d.py", line 1509, in _new_process_group_helper
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382]     backend_class = ProcessGroupGloo(backend_prefix_store, group_rank, group_size, timeout=timeout)
(RayWorkerWrapper pid=1890, ip=<IP_ADDRESS>) ERROR 08-02 08:50:03 worker_base.py:382] RuntimeError: Gloo connectFullMesh failed with [../third_party/gloo/gloo/transport/tcp/pair.cc:144] no error
How would you like to use vllm
I want to run inference of a [specific model](put link here). I don't know how to integrate it with vllm.

solve it by set:  -e GLOO_SOCKET_IFNAME="eth0" -e NCCL_SOCKET_IFNAME=eth0 -e TP_SOCKET_IFNAME=eth0  when docker run,if the container is running,you enter containers to set it,it not work.

this is stated in https://docs.vllm.ai/en/latest/serving/distributed_serving.html :

Note that setting environment variables in the shell (e.g. NCCL_SOCKET_IFNAME=eth0 vllm serve ...) only works for the processes in the same node, not for the processes in the other nodes. Setting environment variables when you create the cluster is the recommended way. See the discussion for more information.


Startup time improvements

@fuss86 could you please add some description for this task?

sorry, it was my misunderstanding of the problem. Internal SB-1404 has been created properly


YARN-2232

https://issues.apache.org/jira/browse/YARN-2232

Can one of the admins verify this patch?


Remove use of units in poliastro.core

Fix #1256, and enforce it forever using import-linter.
I had to make several other changes along the way:

Refactor atmospheric_drag to take the density as a float rather than a callable. This introduces a minor redundancy because the user needs to compute the height outside, but the advantage is that the perturbation can be jitted, and no units are needed.
Disable the atmosphere perturbation in EarthSatellite. The design of the class is not very flexible and does not support the new atmospheric_drag function easily. Rather than trying to find a way out, since these classes are experimental, I temporarily introduced a NotImplementedError until we find a better solution.
Add a lint-imports command to our test environment in tox, since import-linter requires the package to be installed.

Also, notice I ended up preventing the whole astropy in poliastro.core, see https://github.com/seddonym/import-linter/issues/111

Found a workaround for import-linter, merging!


Add hardware and Windows scripting languages

Add some extra languages:

Hardware focused: Verilog, VHDL
Windows scripting: PowerShell, Batchfile

Thank you but we don't accept PRs adding languages :)


Help with search domains (OR in config)

Hi,
Looking for php implementation help of OR in configuration using search_read.
Apparently the ORM API supports this configuration, so I'm wondering how to use it here:
$transaction_config = array( 			array('|'), 			array('online_account_id.name', '=', $odoo_bank_account['online_account_name']), 			array('journal_id.name', '=', 'something'), 		);
The following works fine, but I want to be able to OR it with another value:
$transaction_config = array( 			array('online_account_id.name', '=', $odoo_bank_account['online_account_name']),);
Any help would be appreciated.

Ah, silly me, appears I just had the formatting wrong, and it should have been.
$transaction_config = array( 			'|', 			array('online_account_id.name', '=', $odoo_bank_account['online_account_name']), 			array('journal_id.name', '=', 'something'), 		);


[ERROR] turicreate.toolkits._main: Toolkit error: Column type of target 'rating' must be int or str.

Hi, I am getting this error.
[ERROR] turicreate.toolkits._main: Toolkit error: Column type of target 'rating' must be int or str.
Traceback (most recent call last):
  File "imdb_sent_turi.py", line 45, in <module>
    model = tc.sentence_classifier.create(dataset, 'rating', features=['text'])
  File "/Users/airphoenix/Desktop/aclImdb/sent_turi/lib/python3.6/site-packages/turicreate/toolkits/sentence_classifier/_sentence_classifier.py", line 110, in create
    validation_set=validation_set)
  File "/Users/airphoenix/Desktop/aclImdb/sent_turi/lib/python3.6/site-packages/turicreate/toolkits/classifier/logistic_classifier.py", line 312, in create
    seed=seed)
  File "/Users/airphoenix/Desktop/aclImdb/sent_turi/lib/python3.6/site-packages/turicreate/toolkits/_supervised_learning.py", line 398, in create
    options, verbose)
  File "/Users/airphoenix/Desktop/aclImdb/sent_turi/lib/python3.6/site-packages/turicreate/toolkits/_main.py", line 84, in run
    raise ToolkitError(str(message))
turicreate.toolkits._main.ToolkitError: Column type of target 'rating' must be int or str.

My ratings vector is derived from
    with open(pf, "r") as f:
        indexCounter = 0
        review = f.read()
        split_title = pf.split('_')
        split_title2 = split_title[1].split('.')
        rating = int(split_title2[0])

        ratings_vector.append(rating)
        reviews_vector.append(review)`

and is, when printed, an array of ints.
My code for the model is:
dataset = {'rating': ratings_vector, 'text': reviews_vector}
model = tc.sentence_classifier.create(dataset, 'rating', features=['text'])

@jchuter - Sorry for the unhelpful error message. You need to create a SFrame and then pass that to tc.sentence_classifier.create(...).
So instead of
dataset = {'rating': ratings_vector, 'text': reviews_vector}
do
dataset = tc.SFrame({'rating': ratings_vector, 'text': reviews_vector})

My mistake, and thanks for the response!