This is an automated email from the ASF dual-hosted git repository. qiaojialin pushed a commit to branch fix_message_null in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit f632f5588fd38c955e86304273843a89d3a79e67 Author: qiaojialin <[email protected]> AuthorDate: Fri May 15 14:57:20 2020 +0800 fix null message --- .../iotdb/db/engine/memtable/AbstractMemTable.java | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java b/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java index 54b329d..f5b173c 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java @@ -83,18 +83,14 @@ public abstract class AbstractMemTable implements IMemTable { @Override public void insert(InsertPlan insertPlan) throws QueryProcessException { - try { - for (int i = 0; i < insertPlan.getValues().length; i++) { + for (int i = 0; i < insertPlan.getValues().length; i++) { - Object value = parseValue(insertPlan.getDataTypes()[i], insertPlan.getValues()[i]); - write(insertPlan.getDeviceId(), insertPlan.getMeasurements()[i], - insertPlan.getDataTypes()[i], insertPlan.getTime(), value); - } - long recordSizeInByte = MemUtils.getRecordSize(insertPlan); - memSize += recordSizeInByte; - } catch (RuntimeException e) { - throw new QueryProcessException(e.getMessage()); + Object value = parseValue(insertPlan.getDataTypes()[i], insertPlan.getValues()[i]); + write(insertPlan.getDeviceId(), insertPlan.getMeasurements()[i], + insertPlan.getDataTypes()[i], insertPlan.getTime(), value); } + long recordSizeInByte = MemUtils.getRecordSize(insertPlan); + memSize += recordSizeInByte; } private static Object parseValue(TSDataType dataType, String value) throws QueryProcessException {
