else
System.err.println("Run with --debug to get full stack trace or --help to get help.");
System.exit(1);
}
handler.output(String.format("Streaming session ID: %s", future.planId));
try
{
future.get();
System.exit(0); // We need that to stop non daemonized threads