This is an automated email from the ASF dual-hosted git repository. qiaojialin pushed a commit to branch continue_write in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit f30dfd3472c21ece75ff3b9524c849e9601a5bdc Author: qiaojialin <[email protected]> AuthorDate: Mon Jun 1 20:28:53 2020 +0800 continue write --- server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java b/server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java index 241d0b1..106333f 100644 --- a/server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java +++ b/server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java @@ -94,11 +94,13 @@ public class PublishHandler extends AbstractInterceptHandler { plan.setTypes(new TSDataType[event.getValues().size()]); plan.setInferType(true); - boolean status; + boolean status = false; try { status = executeNonQuery(plan); } catch (QueryProcessException | StorageGroupNotSetException | StorageEngineException e ) { - throw new RuntimeException(e); + LOG.warn( + "meet error when inserting device {}, measurements {}, at time {}, because ", + event.getDevice(), event.getMeasurements(), event.getTimestamp(), e); } LOG.debug("event process result: {}", status);
