-
Notifications
You must be signed in to change notification settings - Fork 4.1k
STORM-2748: Fix TickTupleTest to actually test something #2334
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
4701ee3 to
a7304c3
Compare
srdo
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1 pending tests passing, thanks for fixing this.
| public void prepare(Map<String, Object> conf, TopologyContext topologyContext, OutputCollector outputCollector) {} | ||
| @Override | ||
| public void execute(Tuple tuple) {} | ||
| private static class NoopBlot extends BaseRichBolt { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nit: Blot -> Bolt
| public void cleanup() { } | ||
| @Override | ||
| public void execute(Tuple tuple) { | ||
| LOG.error("GOT {}", tuple); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nit: Info or debug might be nicer so a grep for errors in the logs doesn't produce this line.
|
@srdo thanks for the review. Trying to get the test to work on the slower VMs is still a work in progress. I'll let you know why I actually have it passing consistently. |
|
@srdo I finally have the test passing predictably on travis. I also fixed the issues that you saw. Feel free to take another look. |
srdo
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1 again
| } | ||
| tickTupleTimes.clear(); | ||
| cluster.advanceClusterTime(1); | ||
| time += 1000; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think this can be put in a loop now, the following lines don't differ anymore.
|
@srdo I turned it into a loop like you requested |
|
Thanks |
|
+1 |
… into STORM-2748 STORM-2748: Fix TickTupleTest to actually test something This closes #2334
No description provided.