svn commit: r1294041 - in /incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor: Configurator.java Monitor.java

[ch...@apache.org]

Author: chl501
Date: Mon Feb 27 06:15:36 2012
New Revision: 1294041

URL: http://svn.apache.org/viewvc?rev=1294041&view=rev
Log:
change log level to remove unnecessary messages.

Modified:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Configurator.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Monitor.java

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Configurator.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Configurator.java?rev=1294041&r1=1294040&r2=1294041&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Configurator.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Configurator.java Mon Feb 27 06:15:36 2012
@@ -58,7 +58,7 @@ public final class Configurator {
     File pluginDir = new File(pluginPath);
     ClassLoader loader = Thread.currentThread().getContextClassLoader();
     Map<String, Task> taskList = new HashMap<String, Task>();
-    LOG.info("Scanning jar files within "+pluginDir+".");
+    LOG.debug("Scanning jar files within "+pluginDir+".");
     for(File jar: pluginDir.listFiles()) {
       String jarPath = jar.getPath();
       Long timestamp = repos.get(jarPath);
@@ -68,7 +68,7 @@ public final class Configurator {
           t.setListener(listener);
           taskList.put(jarPath, t);
           repos.put(jarPath, new Long(jar.lastModified()));
-          LOG.info(jar.getName()+" is loaded.");
+          LOG.debug(jar.getName()+" is loaded.");
         }
       }
     }
@@ -91,7 +91,7 @@ public final class Configurator {
       "in menifest file.");
     String namespace = pkg + File.separator + main;
     namespace = namespace.replaceAll(File.separator, ".");
-    LOG.info("Task class to be loaded: "+namespace);
+    LOG.debug("Task class to be loaded: "+namespace);
     URLClassLoader child = 
       new URLClassLoader(new URL[]{path.toURI().toURL()}, loader); 
     Thread.currentThread().setContextClassLoader(child);

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Monitor.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Monitor.java?rev=1294041&r1=1294040&r2=1294041&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Monitor.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/monitor/Monitor.java Mon Feb 27 06:15:36 2012
@@ -206,11 +206,11 @@ public final class Monitor extends Threa
               if(null == zk.exists(znode+File.separator+name, false)) {
                 String p = this.zk.create(znode+File.separator+name, toBytes(value), 
                 Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
-                LOG.info("Successfully publish data to zk with path to `"+p+"'");
+                LOG.debug("Successfully publish data to zk with path to `"+p+"'");
               } else {
                 // can we just update by increasing 1 version?
                 this.zk.setData(znode+File.separator+name, toBytes(value), -1); 
-                LOG.info("Successfully update data in znode: "+znode);
+                LOG.debug("Successfully update data in znode: "+znode);
               }
             }
           } catch (KeeperException ke) {
@@ -313,7 +313,7 @@ public final class Monitor extends Threa
     public void run() {
       try { 
         while(!Thread.currentThread().interrupted()) {
-          LOG.info("How many workers will be executed by collector? "+workers.size());
+          LOG.debug("How many workers will be executed by collector? "+workers.size());
           for(TaskWorker worker: workers.values()) {
             pool.submit(worker);
           }
@@ -410,7 +410,7 @@ public final class Monitor extends Threa
   public void notify(Result result) {
     try {
       results.put(result); 
-      LOG.info(result.name()+" is put to queue (size is "+results.size()+")");
+      LOG.debug(result.name()+" is put to queue (size is "+results.size()+")");
     } catch(InterruptedException ie) {
       LOG.warn(this.getClass().getSimpleName()+" is interrupted.", ie);
       Thread.currentThread().interrupt();