GitHub user Zedmor opened a pull request:
https://github.com/apache/samza/pull/431
Staging directory name has to be formatted in config
When we instantiate a HDFS config staging directory we missing a formatter
for getStagingDirectory so systems.hdfs-system-name.stagingDirectory
Github user Zedmor closed the pull request at:
https://github.com/apache/samza/pull/428
---
GitHub user Zedmor opened a pull request:
https://github.com/apache/samza/pull/428
Json file reader
1. Gradle.build changes
2. Staging directory fix for properties
3. Initial offset fix to set it to 0:0 if missing
4. Text file reader
You can merge this pull request into
