SAMZA-1189: Fix file system closed issue on hdfs system producer
authorJacob Maes <jmaes@linkedin.com>
Wed, 5 Apr 2017 03:37:32 +0000 (20:37 -0700)
committerJacob Maes <jmaes@linkedin.com>
Wed, 5 Apr 2017 03:37:32 +0000 (20:37 -0700)
commit65af13df1f8aa29e1bcf9a83232b4c58fde28b09
treefa92d5536eca4e37836866d761bdcb92e79d8008
parentb70ee983b7af4f5d47e1f7368d5f42e08937d16f
SAMZA-1189: Fix file system closed issue on hdfs system producer

Author: Jacob Maes <jmaes@linkedin.com>

Reviewers: Jagadish <jvenkatr@linkedin.com>

Closes #111 from jmakes/samza-1189
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemProducer.scala