@ Override @ Nullable public Object startJob ( ) { final Object metadata = appenderator . startJob ( ) ; if ( metadata != null ) { throw new ISE ( "Metadata should be null because BatchAppenderatorDriver never persists it" ) ; } return null ; }
This method always returns null because batch ingestion doesn t support restoring tasks on failures .