AJ-854: throw exception when PTA append error;

Author: chengyitian

src/com/xxdb/route/PartitionedTableAppender.java

@@ -145,15 +145,26 @@ public int append(Table table) throws IOException {
     	int affected = 0;
     	for(int i=0; i<tasks.size(); ++i){
     		DBTask task = tasks.get(i);
-    		if(task.isSuccessful()){
+			while (!task.isFinished()) {
+				try {
+					Thread.sleep(100);
+				} catch (InterruptedException e) {
+					throw new RuntimeException(e);
+				}
+			}
+
+    		if (task.isSuccessful()) {
     			Entity re = task.getResult();
-    			if(re.getDataType() == Entity.DATA_TYPE.DT_VOID){
+    			if (re.getDataType() == Entity.DATA_TYPE.DT_VOID) {
 					affected = 0;
-				}else{
+				} else {
 					affected += ((BasicInt)task.getResult()).getInt();
 				}
+			} else {
+				throw new RuntimeException("Task [" + i + "] come across execption: " + task.getErrorMsg());
 			}
     	}
+
     	return affected;
     }