### Question:
StatementExecutor { void handleRestoration(final RestoreCommands restoreCommands) throws Exception { restoreCommands.forEach( (commandId, command, terminatedQueries, wasDropped) -> { log.info("Executing prior statement: '{}'", command); try { handleStatementWithTerminatedQueries( command, commandId, terminatedQueries, wasDropped ); } catch (Exception exception) { log.warn( "Failed to execute statement due to exception", exception ); } } ); } StatementExecutor(
      KsqlEngine ksqlEngine,
      StatementParser statementParser
  ); Map<CommandId, CommandStatus> getStatuses(); Optional<CommandStatus> getStatus(CommandId statementId); Future<CommandStatus> registerQueuedStatement(CommandId commandId);  }### Answer:
@Test public void shouldNotRunNullStatementList() { try{ statementExecutor.handleRestoration(null); } catch (Exception nex) { assertThat("Statement list should not be null.", nex instanceof NullPointerException); } }