<CONTEXT>sparkRuntimeService.start();return controller;</BUG>} catch (Throwable t) {closeAll(closeables);<extra_id_0>} catch (Throwable t) {closeAll(closeables);<BUG>throw t;}</BUG>}private Service.Listener createRuntimeServiceListener(final Id.Program programId, final RunId runId,final Arguments arguments, final Arguments userArgs,final List<Closeable> closeables) {</CONTEXT>
} else {ProgramRunners.startAsUser(cConf.get(Constants.CFG_HDFS_USER), sparkRuntimeService);return controller;throw Throwables.propagate(t);