diff --git a/src/main/java/org/bdware/consistency/plugin/sharding/SelfAdaptiveShardingExecutor.java b/src/main/java/org/bdware/consistency/plugin/sharding/SelfAdaptiveShardingExecutor.java index fe8e2d5..a6d7ee2 100644 --- a/src/main/java/org/bdware/consistency/plugin/sharding/SelfAdaptiveShardingExecutor.java +++ b/src/main/java/org/bdware/consistency/plugin/sharding/SelfAdaptiveShardingExecutor.java @@ -124,7 +124,7 @@ public class SelfAdaptiveShardingExecutor extends AbstractContextContractExecuto LOGGER.debug("receive contract request " + requestID); executedTxs.put(requestID, false); reqQueue.add(req); - rcb.onResult(JsonUtil.toJson(new ContractResult(ContractResult.Status.Executing, + rcb.onResult(JsonUtil.toJson(new ContractResult(ContractResult.Status.Success, new JsonPrimitive("this request is added into blocks")))); // if cache is full, submit if (reqQueue.size() >= SUBMIT_LIMIT) {