From 5ce026d9c8a68fdb0b5dc60b73953abf5f16505d Mon Sep 17 00:00:00 2001 From: Jonathan Shook Date: Fri, 8 May 2020 14:05:49 -0500 Subject: [PATCH] Revert "BasicError handling, print don't throw" This reverts commit 66a7190e --- .../main/java/io/nosqlbench/engine/core/ActivityExecutor.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/engine-core/src/main/java/io/nosqlbench/engine/core/ActivityExecutor.java b/engine-core/src/main/java/io/nosqlbench/engine/core/ActivityExecutor.java index c172dffc5..637923482 100644 --- a/engine-core/src/main/java/io/nosqlbench/engine/core/ActivityExecutor.java +++ b/engine-core/src/main/java/io/nosqlbench/engine/core/ActivityExecutor.java @@ -20,7 +20,6 @@ import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ParameterMap; import io.nosqlbench.engine.api.activityimpl.SlotStateTracker; import io.nosqlbench.engine.api.activityimpl.input.ProgressCapable; -import io.nosqlbench.nb.api.errors.BasicError; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -98,15 +97,12 @@ public class ActivityExecutor implements ActivityController, ParameterMap.Listen activity.setRunState(RunState.Starting); activity.initActivity(); //activity.onActivityDefUpdate(activityDef); - } catch (BasicError ue) { - logger.error(ue.getMessage()); } catch (Exception e) { this.stoppingException = new RuntimeException("Error initializing activity '" + activity.getAlias() +"': " + e.getMessage(),e); activitylogger.error("error initializing activity '" + activity.getAlias() + "': " + stoppingException); throw stoppingException; } - adjustToActivityDef(activity.getActivityDef()); activity.setRunState(RunState.Running); activitylogger.debug("START/after alias=(" + activity.getAlias() + ")");