Xinyu Liu created SAMZA-1477:
--------------------------------
Summary: Fix issues found by BEAM tests
Key: SAMZA-1477
URL: https://issues.apache.org/jira/browse/SAMZA-1477
Project: Samza
Issue Type: Bug
Affects Versions: 0.14.0
Reporter: Xinyu Liu
Assignee: Xinyu Liu
A bunch of issues were found by BEAM tests, which includes:
1) WatermarkFunction needs to be able to return output after processWatermark()
2) control message doesn't implement the equals() and hashcode()
3) Some kafka system related code is not scala 2.10 compatible for tests.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
