@ Override public void dispose ( ) { IOUtils . closeQuietly ( cancelStreamRegistry ) ; if ( kvStateRegistry != null ) { kvStateRegistry . unregisterAll ( ) ; } lastName = null ; lastState = null ; keyValueStatesByName . clear ( ) ; }
Closes the state backend releasing all internal resources but does not delete any persistent checkpoint data .