You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mrql.apache.org by fe...@apache.org on 2014/02/04 19:11:41 UTC
git commit: MRQL-28: Fixed dumping of HDFS sequence file in Spark mode
Updated Branches:
refs/heads/master 9b76440e0 -> 3bb04d69e
MRQL-28: Fixed dumping of HDFS sequence file in Spark mode
Project: http://git-wip-us.apache.org/repos/asf/incubator-mrql/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-mrql/commit/3bb04d69
Tree: http://git-wip-us.apache.org/repos/asf/incubator-mrql/tree/3bb04d69
Diff: http://git-wip-us.apache.org/repos/asf/incubator-mrql/diff/3bb04d69
Branch: refs/heads/master
Commit: 3bb04d69e2c82cedf876a1783e32f0df919e6e02
Parents: 9b76440
Author: fegaras <fe...@cse.uta.edu>
Authored: Tue Feb 4 12:11:21 2014 -0600
Committer: fegaras <fe...@cse.uta.edu>
Committed: Tue Feb 4 12:11:21 2014 -0600
----------------------------------------------------------------------
src/main/java/spark/SparkEvaluator.gen | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-mrql/blob/3bb04d69/src/main/java/spark/SparkEvaluator.gen
----------------------------------------------------------------------
diff --git a/src/main/java/spark/SparkEvaluator.gen b/src/main/java/spark/SparkEvaluator.gen
index 867b926..beb1e2a 100644
--- a/src/main/java/spark/SparkEvaluator.gen
+++ b/src/main/java/spark/SparkEvaluator.gen
@@ -150,6 +150,7 @@ final public class SparkEvaluator extends Evaluator implements Serializable {
Path path = new Path(file);
FileSystem fs = path.getFileSystem(Plan.conf);
PrintStream ftp = new PrintStream(fs.create(path.suffix(".type")));
+ fs.delete(path,true);
ftp.print("2@"+type.toString()+"\n");
ftp.close();
// in Spark mode, a dataset has always one RDD datasource