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

Method die

storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:269–280  ·  view source on GitHub ↗
(Throwable exception)

Source from the content-addressed store, hash-verified

267 }
268
269 private void die(Throwable exception) {
270 String processInfo = process.getProcessInfoString() + process.getProcessTerminationInfoString();
271 this.exception = new RuntimeException(processInfo, exception);
272 String message = String.format("Halting process: ShellSpout died. Command: %s, ProcessInfo %s",
273 Arrays.toString(command),
274 processInfo);
275 LOG.error(message, exception);
276 collector.reportError(exception);
277 if (running || (exception instanceof Error)) { //don't exit if not running, unless it is an Error
278 System.exit(11);
279 }
280 }
281
282 private class SpoutHeartbeatTimerTask extends TimerTask {
283 private ShellSpout spout;

Callers 1

runMethod · 0.45

Calls 5

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

Tested by

no test coverage detected