Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2245 from guobingkun/debug_to_info 

change log level to info for ITKafkaTest
This commit is contained in:
Fangjin Yang 2016-01-11 22:30:24 -08:00
parent dfe6abb721 36ca5b1703
commit 9073e79a23
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java
View File

@ -181,7 +181,6 @@ public class ITKafkaTest extends AbstractIndexerTest
// send data to kafka // send data to kafka
while (dt.compareTo(dtStop) < 0) { // as long as we're within the time span while (dt.compareTo(dtStop) < 0) { // as long as we're within the time span
LOG.info("sending event at [%s]", event_fmt.print(dt));
num_events++; num_events++;
added += num_events; added += num_events;
// construct the event to send // construct the event to send
@ -189,7 +188,7 @@ public class ITKafkaTest extends AbstractIndexerTest
event_template, event_template,
event_fmt.print(dt), num_events, 0, num_events event_fmt.print(dt), num_events, 0, num_events
); );
LOG.debug("event: [%s]", event); LOG.info("sending event: [%s]", event);
try { try {
// Send event to kafka // Send event to kafka
KeyedMessage<String, String> message = new KeyedMessage<String, String>(TOPIC_NAME, event); KeyedMessage<String, String> message = new KeyedMessage<String, String>(TOPIC_NAME, event);