shuwenwei opened a new pull request, #15722:
URL: https://github.com/apache/iotdb/pull/15722
## Description
Using join to query views of non-aligned series may throw
NullPointerException
```
2025-06-04 17:35:38,451
[pool-33-IoTDB-DataNodeInternalRPC-Processor-128$20250604_093526_10262_6.6.0]
WARN o.a.i.d.q.e.f.FragmentInstanceManager:202 - error when create
FragmentInstanceExecution.
java.lang.NullPointerException: Cannot invoke "java.util.List.get(int)"
because the return value of "java.util.Map.get(Object)" is null
at
org.apache.iotdb.db.queryengine.execution.relational.ColumnTransformerBuilder.lambda$visitSymbolReference$17(ColumnTransformerBuilder.java:1280)
at java.base/java.util.HashMap.computeIfAbsent(HashMap.java:1220)
at
org.apache.iotdb.db.queryengine.execution.relational.ColumnTransformerBuilder.visitSymbolReference(ColumnTransformerBuilder.java:1276)
at
org.apache.iotdb.db.queryengine.execution.relational.ColumnTransformerBuilder.visitSymbolReference(ColumnTransformerBuilder.java:204)
at
org.apache.iotdb.db.queryengine.plan.relational.sql.ast.SymbolReference.accept(SymbolReference.java:46)
at
org.apache.iotdb.db.queryengine.plan.relational.sql.ast.AstVisitor.process(AstVisitor.java:33)
at
org.apache.iotdb.db.queryengine.plan.planner.TableOperatorGenerator.constructFilterAndProjectOperator(TableOperatorGenerator.java:1296)
at
org.apache.iotdb.db.queryengine.plan.planner.TableOperatorGenerator.access$100(TableOperatorGenerator.java:331)
at
org.apache.iotdb.db.queryengine.plan.planner.TableOperatorGenerator$1.getFilterAndProjectOperator(TableOperatorGenerator.java:825)
at
org.apache.iotdb.db.queryengine.plan.planner.TableOperatorGenerator$1.generateCurrentDeviceOperatorTree(TableOperatorGenerator.java:552)
at
org.apache.iotdb.db.queryengine.execution.operator.source.relational.DeviceIteratorScanOperator.constructCurrentDeviceOperatorTree(DeviceIteratorScanOperator.java:117)
at
org.apache.iotdb.db.queryengine.execution.operator.source.relational.DeviceIteratorScanOperator.<init>(DeviceIteratorScanOperator.java:68)
at
org.apache.iotdb.db.queryengine.plan.planner.TableOperatorGenerator.visitTreeNonAlignedDeviceViewScan(TableOperatorGenerator.java:470)
at
org.apache.iotdb.db.queryengine.plan.planner.TableOperatorGenerator.visitTreeNonAlignedDeviceViewScan(TableOperatorGenerator.java:331)
at
org.apache.iotdb.db.queryengine.plan.relational.planner.node.TreeNonAlignedDeviceViewScanNode.accept(TreeNonAlignedDeviceViewScanNode.java:78)
at
org.apache.iotdb.db.queryengine.plan.planner.TableOperatorGenerator.visitIdentitySink(TableOperatorGenerator.java:374)
at
org.apache.iotdb.db.queryengine.plan.planner.TableOperatorGenerator.visitIdentitySink(TableOperatorGenerator.java:331)
at
org.apache.iotdb.db.queryengine.plan.planner.plan.node.sink.IdentitySinkNode.accept(IdentitySinkNode.java:75)
at
org.apache.iotdb.db.queryengine.plan.planner.LocalExecutionPlanner.generateOperator(LocalExecutionPlanner.java:185)
at
org.apache.iotdb.db.queryengine.plan.planner.LocalExecutionPlanner.plan(LocalExecutionPlanner.java:112)
at
org.apache.iotdb.db.queryengine.execution.fragment.FragmentInstanceManager.lambda$execDataQueryFragmentInstance$3(FragmentInstanceManager.java:162)
at
java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1708)
at
org.apache.iotdb.db.queryengine.execution.fragment.FragmentInstanceManager.execDataQueryFragmentInstance(FragmentInstanceManager.java:138)
at
org.apache.iotdb.db.consensus.statemachine.dataregion.DataRegionStateMachine.read(DataRegionStateMachine.java:251)
at
org.apache.iotdb.consensus.iot.IoTConsensusServerImpl.read(IoTConsensusServerImpl.java:258)
at
org.apache.iotdb.consensus.iot.IoTConsensus.read(IoTConsensus.java:253)
at
org.apache.iotdb.db.queryengine.execution.executor.RegionReadExecutor.execute(RegionReadExecutor.java:84)
at
org.apache.iotdb.db.protocol.thrift.impl.DataNodeInternalRPCServiceImpl.sendFragmentInstance(DataNodeInternalRPCServiceImpl.java:422)
at
org.apache.iotdb.mpp.rpc.thrift.IDataNodeRPCService$Processor$sendFragmentInstance.getResult(IDataNodeRPCService.java:6364)
at
org.apache.iotdb.mpp.rpc.thrift.IDataNodeRPCService$Processor$sendFragmentInstance.getResult(IDataNodeRPCService.java:6344)
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38)
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:38)
at
org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:248)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
