[incubator-iotdb] branch continue_write created (now f30dfd3)

[qi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a change to branch continue_write
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.


      at f30dfd3  continue write

This branch includes the following new commits:

     new f30dfd3  continue write

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[incubator-iotdb] 01/01: continue write

[qi...@apache.org]

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 <64...@qq.com>
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);