test to ensure the underlying delegate is being passed the aborttask call . concode_field_sep Path outputSampleFilePath concode_elem_sep OutputCommitter mockCommitter concode_elem_sep TableSchema TEST_TABLE_SCHEMA concode_elem_sep String TEST_OUTPUT_FILE_STRING concode_elem_sep String TEST_OUTPUT_PATH_STRING concode_elem_sep Configuration conf concode_elem_sep String TEST_PROJECT_ID concode_elem_sep TaskAttemptContext mockTaskAttemptContext concode_elem_sep TaskAttemptID TEST_TASK_ATTEMPT_ID concode_elem_sep ForwardingBigQueryFileOutputCommitter committer concode_elem_sep Path outputPath concode_elem_sep BigQueryFileFormat TEST_FILE_FORMAT concode_elem_sep ExpectedException expectedException concode_elem_sep Class<? extends FileOutputFormat> TEST_OUTPUT_CLASS concode_elem_sep Job job concode_elem_sep String TEST_DATASET_ID concode_elem_sep String TEST_TABLE_ID concode_elem_sep InMemoryGoogleHadoopFileSystem ghfs concode_field_sep void testGetOutputFileURIs concode_elem_sep void testAbortJob concode_elem_sep void testNeedsTaskCommit concode_elem_sep void testSetupJob concode_elem_sep void generateSampleFiles concode_elem_sep void testCleanup concode_elem_sep void setUp concode_elem_sep void testSetupTask concode_elem_sep void testCommitTask concode_elem_sep void testCommitJob concode_elem_sep void tearDown
void function ( ) { committer . abortTask ( mockTaskAttemptContext ) ; verify ( mockCommitter ) . abortTask ( eq ( mockTaskAttemptContext ) ) ; }