IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

BasicError handling, print don't throw

Browse Source
This commit is contained in:
phact 2020-05-07 15:51:39 -04:00
parent e2e75f4dc0
commit 66a7190e54
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
engine-core/src/main/java/io/nosqlbench/engine/core/ActivityExecutor.java
View File

@ -20,6 +20,7 @@ import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import io.nosqlbench.engine.api.activityimpl.ParameterMap; import io.nosqlbench.engine.api.activityimpl.ParameterMap;
import io.nosqlbench.engine.api.activityimpl.SlotStateTracker; import io.nosqlbench.engine.api.activityimpl.SlotStateTracker;
import io.nosqlbench.engine.api.activityimpl.input.ProgressCapable; import io.nosqlbench.engine.api.activityimpl.input.ProgressCapable;
import io.nosqlbench.nb.api.errors.BasicError;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -97,12 +98,15 @@ public class ActivityExecutor implements ActivityController, ParameterMap.Listen
activity.setRunState(RunState.Starting); activity.setRunState(RunState.Starting);
activity.initActivity(); activity.initActivity();
//activity.onActivityDefUpdate(activityDef); //activity.onActivityDefUpdate(activityDef);
} catch (BasicError ue) {
logger.error(ue.getMessage());
} catch (Exception e) { } catch (Exception e) {
this.stoppingException = new RuntimeException("Error initializing activity '" + this.stoppingException = new RuntimeException("Error initializing activity '" +
activity.getAlias() +"': " + e.getMessage(),e); activity.getAlias() +"': " + e.getMessage(),e);
activitylogger.error("error initializing activity '" + activity.getAlias() + "': " + stoppingException); activitylogger.error("error initializing activity '" + activity.getAlias() + "': " + stoppingException);
throw stoppingException; throw stoppingException;
} }
adjustToActivityDef(activity.getActivityDef()); adjustToActivityDef(activity.getActivityDef());
activity.setRunState(RunState.Running); activity.setRunState(RunState.Running);
activitylogger.debug("START/after alias=(" + activity.getAlias() + ")"); activitylogger.debug("START/after alias=(" + activity.getAlias() + ")");