public static void close ( final Collection < MasterTriggerRestoreHook < ? > > hooks , final Logger log ) throws FlinkException { for ( MasterTriggerRestoreHook < ? > hook : hooks ) { try { hook . close ( ) ; } catch ( Throwable t ) { log . warn ( "Failed to cleanly close a checkpoint master hook (" + hook . getIdentifier ( ) + ")" , t ) ; } } }
Closes the master hooks .