commit | 0a0a0b0f657a012ce2715b8d3216bd2893f85cc8 | [log] [tgz] |
---|---|---|
author | buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> | Thu Mar 21 23:48:09 2013 +0000 |
committer | buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> | Thu Mar 21 23:48:09 2013 +0000 |
tree | 80f2364303dbf0d1e48a22e473443ee2524e07c1 | |
parent | bdeff22a08f96665a985f5ee72f7448b971dc7d7 [diff] |
minor fix for the log git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_asterix_stabilization@3160 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-hdfs/hyracks-hdfs-core/src/main/java/edu/uci/ics/hyracks/hdfs/scheduler/Scheduler.java b/hyracks/hyracks-hdfs/hyracks-hdfs-core/src/main/java/edu/uci/ics/hyracks/hdfs/scheduler/Scheduler.java index 6688eae..3f7997b 100644 --- a/hyracks/hyracks-hdfs/hyracks-hdfs-core/src/main/java/edu/uci/ics/hyracks/hdfs/scheduler/Scheduler.java +++ b/hyracks/hyracks-hdfs/hyracks-hdfs-core/src/main/java/edu/uci/ics/hyracks/hdfs/scheduler/Scheduler.java
@@ -152,7 +152,7 @@ */ public String[] getLocationConstraints(InputSplit[] splits) throws HyracksException { if (splits == null) { - /**deal the case when the splits array is null*/ + /** deal the case when the splits array is null */ return new String[] {}; } int[] workloads = new int[NCs.length]; @@ -193,7 +193,8 @@ dataLocalCount++; } } - LOGGER.info("Data local rate: " + ((float) dataLocalCount / (float) (scheduled.length))); + LOGGER.info("Data local rate: " + + (scheduled.length == 0 ? 0.0 : ((float) dataLocalCount / (float) (scheduled.length)))); /** * push non-data-local lower-bounds slots to each machine */