Index: core/src/main/java/org/apache/hama/bsp/BSPJobClient.java =================================================================== --- core/src/main/java/org/apache/hama/bsp/BSPJobClient.java (revision 1188976) +++ core/src/main/java/org/apache/hama/bsp/BSPJobClient.java (working copy) @@ -300,7 +300,7 @@ int maxTasks = clusterStatus.getMaxTasks(); if (tasks <= 0 || tasks > maxTasks) { - LOG.warn("The number of tasks you've entered was invalid. Using default value of " + LOG.info("The number of tasks you've entered was invalid. Using default value of " + maxTasks + "!"); job.setNumBspTask(maxTasks); } Index: core/src/main/java/org/apache/hama/bsp/GroomServer.java =================================================================== --- core/src/main/java/org/apache/hama/bsp/GroomServer.java (revision 1188976) +++ core/src/main/java/org/apache/hama/bsp/GroomServer.java (working copy) @@ -39,7 +39,6 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.filecache.DistributedCache; import org.apache.hadoop.fs.FSError; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; @@ -147,6 +146,8 @@ } if (actions != null) { + LOG.info("Launch " + actions.length + " tasks."); + assignedPeerNames = new HashMap(); int i = 0; @@ -312,8 +313,6 @@ this.groomServerName = "groomd_" + this.rpcServer.replace(':', '_'); LOG.info("Starting groom: " + this.rpcServer); - DistributedCache.purgeCache(this.conf); - // establish the communication link to bsp master this.masterClient = (MasterProtocol) RPC.waitForProxy(MasterProtocol.class, MasterProtocol.versionID, bspMasterAddr, conf); @@ -426,6 +425,7 @@ if (!tip.runner.isAlive()) { if (taskStatus.getRunState() != TaskStatus.State.FAILED) { taskStatus.setRunState(TaskStatus.State.SUCCEEDED); + LOG.info("Task '" + taskStatus.getTaskId().toString() + "' has completed."); } taskStatus.setPhase(TaskStatus.Phase.CLEANUP); } @@ -476,7 +476,7 @@ } catch (IOException e1) { LOG.error(e1); } - + TaskInProgress tip = new TaskInProgress(t, jobConf, this.groomServerName); synchronized (this) { @@ -786,6 +786,7 @@ taskStatus.setRunState(TaskStatus.State.RUNNING); this.runner = task.createRunner(GroomServer.this); this.runner.start(); + LOG.info("Task '" + task.getTaskID().toString() + "' has started."); } /** Index: core/src/main/java/org/apache/hama/bsp/JobInProgress.java =================================================================== --- core/src/main/java/org/apache/hama/bsp/JobInProgress.java (revision 1188976) +++ core/src/main/java/org/apache/hama/bsp/JobInProgress.java (working copy) @@ -201,7 +201,7 @@ master.createJobRoot(this.getJobID().toString()); tasksInited = true; - LOG.debug("Job is initialized."); + LOG.info("Job is initialized."); } public synchronized Task obtainNewTask(GroomServerStatus status, @@ -231,7 +231,7 @@ public synchronized void completedTask(TaskInProgress tip, TaskStatus status) { TaskAttemptID taskid = status.getTaskId(); updateTaskStatus(tip, status); - LOG.info("Taskid '" + taskid + "' has finished successfully."); + LOG.debug("Taskid '" + taskid + "' has finished successfully."); tip.completed(taskid); // @@ -253,7 +253,7 @@ this.finishTime = System.currentTimeMillis(); this.status.setFinishTime(this.finishTime); - LOG.debug("Job successfully done."); + LOG.info("Job successfully done."); // delete job root master.deleteJobRoot(this.getJobID().toString()); @@ -287,7 +287,7 @@ this.finishTime = System.currentTimeMillis(); this.status.setFinishTime(this.finishTime); - LOG.debug("Job failed."); + LOG.info("Job failed."); garbageCollect(); } Index: core/src/main/java/org/apache/hama/bsp/TaskInProgress.java =================================================================== --- core/src/main/java/org/apache/hama/bsp/TaskInProgress.java (revision 1188976) +++ core/src/main/java/org/apache/hama/bsp/TaskInProgress.java (working copy) @@ -212,7 +212,7 @@ } public void completed(TaskAttemptID taskid) { - LOG.info("Task '" + taskid.getTaskID().toString() + "' has completed."); + LOG.debug("Task '" + taskid.getTaskID().toString() + "' has completed."); TaskStatus status = (TaskStatus) taskStatuses.get(taskid); status.setRunState(TaskStatus.State.SUCCEEDED); Index: core/src/main/java/org/apache/hama/bsp/TaskRunner.java =================================================================== --- core/src/main/java/org/apache/hama/bsp/TaskRunner.java (revision 1188976) +++ core/src/main/java/org/apache/hama/bsp/TaskRunner.java (working copy) @@ -78,7 +78,7 @@ void start() { this.future.set(this.sched.schedule(this, 0, SECONDS)); - LOG.info("Start building BSPPeer process."); + LOG.debug("Start building BSPPeer process."); } void stop() { @@ -246,7 +246,7 @@ } catch (ExecutionException ee) { LOG.error("Failure occurs when retrieving tasks result.", ee); } - LOG.info("Finishes executing BSPPeer child process."); + LOG.debug("Finishes executing BSPPeer child process."); } /**