MCPcopy Create free account
hub / github.com/apache/storm / die

Method die

storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:295–306  ·  view source on GitHub ↗
(Throwable exception)

Source from the content-addressed store, hash-verified

293 }
294
295 private void die(Throwable exception) {
296 String processInfo = process.getProcessInfoString() + process.getProcessTerminationInfoString();
297 this.exception = new RuntimeException(processInfo, exception);
298 String message = String.format("Halting process: ShellBolt died. Command: %s, ProcessInfo %s",
299 Arrays.toString(command),
300 processInfo);
301 LOG.error(message, exception);
302 collector.reportError(exception);
303 if (!isLocalMode && (running || (exception instanceof Error))) { //don't exit if not running, unless it is an Error
304 System.exit(11);
305 }
306 }
307
308 private class BoltHeartbeatTimerTask extends TimerTask {
309 private ShellBolt bolt;

Callers 3

runMethod · 0.45
runMethod · 0.45
runMethod · 0.45

Calls 5

getProcessInfoStringMethod · 0.80
formatMethod · 0.65
reportErrorMethod · 0.65
toStringMethod · 0.45

Tested by

no test coverage detected