accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [08/12] accumulo git commit: ACCUMULO-3334 Fix arguments passed to TeraSortIngest by CloudStone4
Date Fri, 14 Nov 2014 01:17:11 GMT
ACCUMULO-3334 Fix arguments passed to TeraSortIngest by CloudStone4


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/a8a6b15a
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/a8a6b15a
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/a8a6b15a

Branch: refs/heads/master
Commit: a8a6b15ada23af15839820e7677432036aee2d40
Parents: e74986a
Author: Josh Elser <elserj@apache.org>
Authored: Thu Nov 13 17:11:36 2014 -0800
Committer: Josh Elser <elserj@apache.org>
Committed: Thu Nov 13 17:11:36 2014 -0800

----------------------------------------------------------------------
 test/system/bench/lib/TeraSortBenchmark.py | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/a8a6b15a/test/system/bench/lib/TeraSortBenchmark.py
----------------------------------------------------------------------
diff --git a/test/system/bench/lib/TeraSortBenchmark.py b/test/system/bench/lib/TeraSortBenchmark.py
index 5f3e1b7..0b1d9f4 100755
--- a/test/system/bench/lib/TeraSortBenchmark.py
+++ b/test/system/bench/lib/TeraSortBenchmark.py
@@ -73,17 +73,17 @@ class TeraSortBenchmark(Benchmark):
         file = os.path.join( dir, 'splits' )
         code, out, err = cloudshell.run(self.username, self.password, "createtable %s -sf
%s\n" % (self.tablename, file))
         command = self.buildcommand('org.apache.accumulo.examples.simple.mapreduce.TeraSortIngest',
-                                    self.numrows(),
-                                    self.keysizemin(),
-                                    self.keysizemax(),
-                                    self.minvaluesize(),
-                                    self.maxvaluesize(),
-                                    self.tablename,
-                                    self.instance,
-                                    self.zookeepers,
-                                    self.username,
-                                    self.password, 
-                                    self.numsplits)
+                                    '--count', self.numrows(),
+                                    '-nk', self.keysizemin(),
+                                    '-xk', self.keysizemax(),
+                                    '-nv', self.minvaluesize(),
+                                    '-xv', self.maxvaluesize(),
+                                    '-t', self.tablename,
+                                    '-i', self.instance,
+                                    '-z', self.zookeepers,
+                                    '-u', self.username,
+                                    '-p', self.password,
+                                    '--splits', self.numsplits)
         handle = runner.start(command, stdin=subprocess.PIPE)
         log.debug("Running: %r", command)
         out, err = handle.communicate("")


Mime
View raw message