Shutdown sequence

samza-beam

PipelineResult pres =  pipeline.run();
Thread waitThread = Thread.currentThread();


Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    try {
	pres.cancel();
	waitThread.join();
    } catch (UnsupportedOperationException | IOException | InterruptedException e){
	logger.error("Graceful cleanup in response to shutdown request failed:",e);
    }
}));	
PipelineResult.State state = pres.waitUntilFinish();

new Thread(() -> {
	try {
	    LOGGER.info("Application Killer sleeping for {} ms", 30_000);
	    Thread.sleep(30_000);
	} catch (Exception e) { /* ignore exception */
	} finally {
	    LOGGER.warn("Application Killer acting ...");
	    Runtime.getRuntime().halt(HALTING_STATUS_CODE);
	}
    }, "Application Killer Thread")
.start();

System.exit(appState);