@Before
	public void initialize() {
		jdbcSink = sinks.jdbc();
		tableName = HdfsJdbcJob.DEFAULT_TABLE_NAME;
		jdbcSink.tableName(tableName);
		cleanup();
		jdbcSink.getJdbcTemplate().getDataSource();
	}
Removes the table created from a previous test.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/HdfsJdbcTest.java