[ https://issues.apache.org/jira/browse/IOTDB-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yukun Zhou reassigned IOTDB-4972: --------------------------------- Assignee: Yukun Zhou (was: Jinrui Zhang) > [DispatchFailed] NPE at > org.apache.iotdb.db.mpp.plan.planner.plan.node.write.InsertNode.selfCheckDataTypes(InsertNode.java:251) > ------------------------------------------------------------------------------------------------------------------------------- > > Key: IOTDB-4972 > URL: https://issues.apache.org/jira/browse/IOTDB-4972 > Project: Apache IoTDB > Issue Type: Bug > Components: mpp-cluster > Affects Versions: 0.14.0-SNAPSHOT > Reporter: 刘珍 > Assignee: Yukun Zhou > Priority: Major > Attachments: image-2022-11-23-11-37-14-211.png, more_ts.conf > > > master_1117_92c6a57 > 1. 启动3副本3C3D集群 > 2. benchmark创建元数据,写入数据 > 3.(ip62) datanode ERROR ,所有的数据写入失败(预期每个序列写入10个点,共5000万序列): > {color:red}*2022-11-17 16:32:59,456 > [pool-26-IoTDB-ClientRPC-Processor-35$20221117_083256_00512_3] ERROR > o.a.i.d.m.p.s.FragmentInstanceDispatcherImpl:123 - [DispatchFailed] > java.lang.NullPointerException: null > at > org.apache.iotdb.db.mpp.plan.planner.plan.node.write.InsertNode.selfCheckDataTypes(InsertNode.java:251)*{color} > at > org.apache.iotdb.db.mpp.plan.planner.plan.node.write.InsertTabletNode.validateAndSetSchema(InsertTabletNode.java:201) > at > org.apache.iotdb.db.mpp.plan.analyze.SchemaValidator.validate(SchemaValidator.java:64) > at > org.apache.iotdb.db.mpp.execution.executor.RegionWriteExecutor$WritePlanNodeExecutionVisitor.executeDataInsert(RegionWriteExecutor.java:191) > at > org.apache.iotdb.db.mpp.execution.executor.RegionWriteExecutor$WritePlanNodeExecutionVisitor.visitInsertTablet(RegionWriteExecutor.java:163) > at > org.apache.iotdb.db.mpp.execution.executor.RegionWriteExecutor$WritePlanNodeExecutionVisitor.visitInsertTablet(RegionWriteExecutor.java:117) > at > org.apache.iotdb.db.mpp.plan.planner.plan.node.write.InsertTabletNode.accept(InsertTabletNode.java:1086) > at > org.apache.iotdb.db.mpp.execution.executor.RegionWriteExecutor.execute(RegionWriteExecutor.java:83) > at > org.apache.iotdb.db.mpp.plan.scheduler.FragmentInstanceDispatcherImpl.dispatchLocally(FragmentInstanceDispatcherImpl.java:232) > at > org.apache.iotdb.db.mpp.plan.scheduler.FragmentInstanceDispatcherImpl.dispatchOneInstance(FragmentInstanceDispatcherImpl.java:137) > at > org.apache.iotdb.db.mpp.plan.scheduler.FragmentInstanceDispatcherImpl.dispatchWriteSync(FragmentInstanceDispatcherImpl.java:119) > at > org.apache.iotdb.db.mpp.plan.scheduler.FragmentInstanceDispatcherImpl.dispatch(FragmentInstanceDispatcherImpl.java:90) > at > org.apache.iotdb.db.mpp.plan.scheduler.ClusterScheduler.start(ClusterScheduler.java:106) > at > org.apache.iotdb.db.mpp.plan.execution.QueryExecution.schedule(QueryExecution.java:287) > at > org.apache.iotdb.db.mpp.plan.execution.QueryExecution.start(QueryExecution.java:205) > at > org.apache.iotdb.db.mpp.plan.Coordinator.execute(Coordinator.java:150) > at > org.apache.iotdb.db.mpp.plan.Coordinator.execute(Coordinator.java:164) > at > org.apache.iotdb.db.service.thrift.impl.ClientRPCServiceImpl.insertTablet(ClientRPCServiceImpl.java:1234) > at > org.apache.iotdb.service.rpc.thrift.IClientRPCService$Processor$insertTablet.getResult(IClientRPCService.java:4078) > at > org.apache.iotdb.service.rpc.thrift.IClientRPCService$Processor$insertTablet.getResult(IClientRPCService.java:4058) > at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:38) > at > org.apache.iotdb.db.service.thrift.ProcessorWithMetrics.process(ProcessorWithMetrics.java:64) > at > org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:248) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:748) > 复现流程 > 1. 192.168.10.62/66/68 72C256GB 3C3D > ConfigNode配置文件: > MAX_HEAP_SIZE="8G" > cn_connection_timeout_ms=3600000 > DataNode配置文件: > MAX_HEAP_SIZE="192G" > MAX_DIRECT_MEMORY_SIZE="32G" > Common配置文件: > schema_region_consensus_protocol_class=org.apache.iotdb.consensus.ratis.RatisConsensus > data_region_consensus_protocol_class=org.apache.iotdb.consensus.multileader.MultiLeaderConsensus > schema_replication_factor=3 > data_replication_factor=3 > connection_timeout_ms=3600000 > max_connection_for_internal_service=1100 > enable_timed_flush_seq_memtable=true > seq_memtable_flush_interval_in_ms=3600000 > seq_memtable_flush_check_interval_in_ms=600000 > enable_timed_flush_unseq_memtable=true > unseq_memtable_flush_interval_in_ms=3600000 > unseq_memtable_flush_check_interval_in_ms=600000 > max_waiting_time_when_insert_blocked=3600000 > query_timeout_threshold=36000000 > enable_auto_create_schema=false > schema_region_ratis_request_timeout_ms=3600000 > 2. benchmark配置见附件 > 运行,查看ip62 datanode 日志。 -- This message was sent by Atlassian Jira (v8.20.10#820010)