You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by lt...@apache.org on 2019/04/15 10:07:42 UTC
[incubator-iotdb] branch cluster_concurrent updated: fix test bug
This is an automated email from the ASF dual-hosted git repository.
lta pushed a commit to branch cluster_concurrent
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/cluster_concurrent by this push:
new dd42d07 fix test bug
dd42d07 is described below
commit dd42d077d3e0daa2c093e1af7f6b65900c07f468
Author: lta <li...@163.com>
AuthorDate: Mon Apr 15 18:07:20 2019 +0800
fix test bug
---
.../java/org/apache/iotdb/cluster/qp/executor/NonQueryExecutor.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/qp/executor/NonQueryExecutor.java b/cluster/src/main/java/org/apache/iotdb/cluster/qp/executor/NonQueryExecutor.java
index d2c986c..c8c2a9b 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/qp/executor/NonQueryExecutor.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/qp/executor/NonQueryExecutor.java
@@ -101,7 +101,6 @@ public class NonQueryExecutor extends ClusterQPExecutor {
*/
public void processBatch(PhysicalPlan[] physicalPlans, BatchResult batchResult)
throws InterruptedException {
- int[] result = batchResult.getResult();
Status nullReadTaskStatus = Status.OK();
RaftUtils.handleNullReadToMetaGroup(nullReadTaskStatus);
@@ -152,7 +151,7 @@ public class NonQueryExecutor extends ClusterQPExecutor {
physicalPlansMap.get(groupId).add(plan);
planIndexMap.get(groupId).add(i);
}
- } catch (PathErrorException | ProcessorException | IOException | RaftConnectionException e) {
+ } catch (PathErrorException | ProcessorException | IOException | RaftConnectionException | InterruptedException e) {
result[i] = Statement.EXECUTE_FAILED;
batchResult.setAllSuccessful(false);
batchResult.setBatchErrorMessage(e.getMessage());