Skip to content

Commit

Permalink
AbstractRankerBolt: use log level DEBUG instead INFO so that the bolt…
Browse files Browse the repository at this point in the history
… is more silent on the logging side
  • Loading branch information
Michael G. Noll committed Aug 29, 2013
1 parent b9c57eb commit 2ace708
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/jvm/storm/starter/bolt/AbstractRankerBolt.java
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ protected Rankings getRankings() {
@Override
public final void execute(Tuple tuple, BasicOutputCollector collector) {
if (TupleHelpers.isTickTuple(tuple)) {
getLogger().info("Received tick tuple, triggering emit of current rankings");
getLogger().debug("Received tick tuple, triggering emit of current rankings");
emitRankings(collector);
}
else {
Expand All @@ -76,7 +76,7 @@ public final void execute(Tuple tuple, BasicOutputCollector collector) {

private void emitRankings(BasicOutputCollector collector) {
collector.emit(new Values(rankings));
getLogger().info("Rankings: " + rankings);
getLogger().debug("Rankings: " + rankings);
}

@Override
Expand Down

0 comments on commit 2ace708

Please sign in to comment.