Broker log
SQL query for request 1020573879000000408: select * from anti_virus_44 limit 10
Caught exception while deserializing data table of size: 1209 from server: pinot-server-0_R
java.lang.NumberFormatException: Cannot parse null string
at java.base/java.lang.Long.parseLong(Long.java:674)
at java.base/java.lang.Long.parseLong(Long.java:836)
at org.apache.pinot.core.transport.QueryRouter.receiveDataTable(QueryRouter.java:192)
at org.apache.pinot.core.transport.DataTableHandler.channelRead0(DataTableHandler.java:73)
at org.apache.pinot.core.transport.DataTableHandler.channelRead0(DataTableHandler.java:39)
at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1357)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:868)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:796)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:732)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:658)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:998)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:840)
requestId=1020573879000000408,table=anti_virus_44,timeMs=10002,docs=0/0,entries=0/0,segments(queried/processed/matched/consumingQueried/consumingProcessed/consumingMatched/unavailable):0/0/0/0/0/0/0,consumingFreshnessTimeMs=0,servers=0/1,groupsTrimmed=false,groupLimitReached=false,groupWarningLimitReached=false,brokerReduceTimeMs=0,exceptions=1,serverStats=(Server=SubmitDelayMs,ResponseDelayMs,ResponseSize,DeserializationTimeMs,RequestSentDelayMs);pinot-server-0_R=0,-1,0,0,1,offlineThreadCpuTimeNs(total/thread/sysActivity/resSer):0/0/0/0,realtimeThreadCpuTimeNs(total/thread/sysActivity/resSer):0/0/0/0,clientIp=unknown,queryEngine=singleStage,offlineMemAllocatedBytes(total/thread/resSer):0/0/0,realtimeMemAllocatedBytes(total/thread/resSer):0/0/0,pools=[-1],rlsFiltersApplied=false,query=select * from anti_virus_44 limit 10
Query processing exceptions: {427=1 servers [pinot-server-0_R] not responded}
Pinot server-0 log
[Consumer clientId=t1_d45_dart_dtag_emea_config_v1_REALTIME-dtag_emea_config-0, groupId=null] Resetting offset for partition dtag_emea_config-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.0.43.64:9092 (id: 0 rack: null)], epoch=0}}.
Processed requestId=1020573879000000408,table=anti_virus_44_REALTIME,segments(queried/processed/matched/consumingQueried/consumingProcessed/consumingMatched/invalid/limit/value)=105/105/1/1/1/0/0/0/0,schedulerWaitMs=0,reqDeserMs=1,totalExecMs=7,resSerMs=1,totalTimeMs=9,minConsumingFreshnessMs=1762342193209,broker=Broker_pinot-broker-0.pinot-broker-headless.dp-1-346.svc.cluster.local_8099,numDocsScanned=10,scanInFilter=0,scanPostFilter=60,sched=FCFS,threadCpuTimeNs(total/thread/sysActivity/resSer)=0/0/0/0, threadMemAllocatedBytes(total/thread/resSer)=0/0/0
[Consumer clientId=t1_d44_services_REALTIME-service_name-0, groupId=null] Seeking to offset 0 for partition service_name-0
[Consumer clientId=t1_d44_url_REALTIME-URL_44-0, groupId=null] Seeking to offset 0 for partition URL_44-0
[Consumer clientId=t1_d44_asset_REALTIME-asset_44-0, groupId=null] Seeking to offset 0 for partition asset_44-0
[Consumer clientId=windows_defender_44_REALTIME-windows_defender_44-0, groupId=null] Seeking to offset 94708 for partition windows_defender_44-0
[Consumer clientId=t1_d359_automation_test_REALTIME-1_359_automation_test-0, groupId=null] Seeking to offset 3570 for partition 1_359_automation_test-0
Consumed 0 events from (rate:0.0/s), currentOffset=86419, numRowsConsumedSoFar=3509, numRowsIndexedSoFar=3489
[Consumer clientId=windows_defender_44_REALTIME-windows_defender_44-0, groupId=null] Fetch position FetchPosition{offset=94708, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.0.43.64:9092 (id: 0 rack: null)], epoch=0}} is out of range for partition windows_defender_44-0, resetting offset
[Consumer clientId=t1_d359_automation_test_REALTIME-1_359_automation_test-0, groupId=null] Fetch position FetchPosition{offset=3570, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.0.43.64:9092 (id: 0 rack: null)], epoch=0}} is out of range for partition 1_359_automation_test-0, resetting offset
[Consumer clientId=windows_defender_44_REALTIME-windows_defender_44-0, groupId=null] Resetting offset for partition windows_defender_44-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.0.43.64:9092 (id: 0 rack: null)], epoch=0}}.
[Consumer clientId=t1_d359_automation_test_REALTIME-1_359_automation_test-0, groupId=null] Resetting offset for partition 1_359_automation_test-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.0.43.64:9092 (id: 0 rack: null)], epoch=0}}.
[Consumer clientId=t1_d45_scccm_REALTIME-sccm_status_45-0, groupId=null] Seeking to offset 2 for partition sccm_status_45-0
[Consumer clientId=t1_d45_dartautomation_v1_REALTIME-1_45_pinot_automation-0, groupId=null] Seeking to offset 7 for partition 1_45_pinot_automation-0
[Consumer clientId=t1_d44_batteryDetails_REALTIME-battery_details_44-0, groupId=null] Seeking to offset 0 for partition battery_details_44-0
[Consumer clientId=t1_d45_scccm_REALTIME-sccm_status_45-0, groupId=null] Fetch position FetchPosition{offset=2, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.0.43.64:9092 (id: 0 rack: null)], epoch=0}} is out of range for partition sccm_status_45-0, resetting offset
[Consumer clientId=t1_d45_scccm_REALTIME-sccm_status_45-0, groupId=null] Resetting offset for partition sccm_status_45-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.0.43.64:9092 (id: 0 rack: null)], epoch=0}}.
[Consumer clientId=t1_d45_dartautomation_v1_REALTIME-1_45_pinot_automation-0, groupId=null] Fetch position FetchPosition{offset=7, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.0.43.64:9092 (id: 0 rack: null)], epoch=0}} is out of range for partition 1_45_pinot_automation-0, resetting offset