Merge pull request #217 from DSL-UMD/distributed

[FIX] remove itself
umd-dslam · Oct 1, 2019 · a3f128e · a3f128e
2 parents c03a4f2 + a0dbf1a
commit a3f128e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/voltdb/BatchRemoveINodes.java b/voltdb/BatchRemoveINodes.java
@@ -39,6 +39,7 @@ public class BatchRemoveINodes extends VoltProcedure {
   public long run(long[] ids) throws VoltAbortException {
     List<Long> set = new ArrayList<>();
     for (int i = 0; i < ids.length; ++i) {
+      voltQueueSQL(sql2, id);
       set.add(ids[i]);
     }
 

diff --git a/voltdb/RemoveChild.java b/voltdb/RemoveChild.java
@@ -38,6 +38,7 @@ public class RemoveChild extends VoltProcedure {
   public long run(long id) throws VoltAbortException {
     List<Long> set = new ArrayList<>();
     set.add(id);
+    voltQueueSQL(sql2, id);
 
     int i = 0;
     while (i < set.size()) {