@After
	public void cleanup() {
		if (jdbcSink != null) {
			jdbcSink.dropTable(tableName);
		}
		if (hadoopUtil.fileExists(HdfsJdbcJob.DEFAULT_DIRECTORY)) {
			hadoopUtil.fileRemove(HdfsJdbcJob.DEFAULT_DIRECTORY);
		}
	}
Being a good steward, remove the result table from the DB and source file from hdfs.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/HdfsJdbcTest.java