@Override
	protected void doStop() {
		try {
			if (storePartitionWriter != null) {
				storePartitionWriter.close();
				storePartitionWriter = null;
			}
		}
		catch (Exception e) {
			logger.error("Error closing writer", e);
		}
	}
Instantiates a new hdfs partition data store message handler.

@param storePartitionWriter the store partition writer
spring-xd-hadoop/src/main/java/org/springframework/xd/integration/hadoop/outbound/HdfsPartitionDataStoreMessageHandler.java