Fixing the log related bugs

hershs · Sep 19, 2013 · 3939409 · 3939409
1 parent c667418
commit 3939409
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/common/EtlCounts.java b/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/common/EtlCounts.java
@@ -397,7 +397,7 @@ private void produceCount(List<URI> brokerURI, ArrayList<Message> monitorSet) {
                 break;
             } catch (Exception e) {
                 e.printStackTrace();
-                log.err(topic + " issue sending tracking to " + uri);
+                log.error(topic + " issue sending tracking to " + uri);
                 continue;
             } finally {
                 if (basicProducer != null) {

diff --git a/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/mapred/EtlRecordReader.java b/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/mapred/EtlRecordReader.java
@@ -114,7 +114,7 @@ public void initialize(InputSplit split, TaskAttemptContext context) throws IOEx
 
         this.totalBytes = this.split.getLength();
 
-        System.out.log.info("Finished executing the initialize part");
+        log.info("Finished executing the initialize part");
     }
 
     @Override