@After
	public void cleanup() {
		if (job != null) {
			job.dropCollection(HdfsMongoDbJob.DEFAULT_COLLECTION_NAME);
		}
		if (hadoopUtil.fileExists(HdfsMongoDbJob.DEFAULT_DIRECTORY)) {
			hadoopUtil.fileRemove(HdfsMongoDbJob.DEFAULT_DIRECTORY);
		}
	}
Being a good steward, remove the result collection from mongo and source file from hdfs.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/HdfsMongoDbTest.java