GitHub user xinyuiscool opened a pull request:
https://github.com/apache/samza/pull/307
SAMZA-1434: Fix issues found in Hadoop
Fix the following bugs found when running Samza on hadoop:
1. Hdfs allows output partitions to be 0 (empty folder)
2. Add null check for the changelog topic generation
3. Call getStreamSpec() instead of using streamSpec member in StreamEdge.
This is due to getStreamSpec will do more transformation.
4. Bound the auto-generated intermediate topic partition by a certain count
(256).
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xinyuiscool/samza SAMZA-1434
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/307.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #307
----
commit a81a059411be5fa68ded96681bf82c8042e0543f
Author: Xinyu Liu <xi...@xiliu-ld1.linkedin.biz>
Date: 2017-09-29T20:45:49Z
SAMZA-1434: Fix issues found in Hadoop
----
---
