You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2014/11/14 02:17:11 UTC
[08/12] accumulo git commit: ACCUMULO-3334 Fix arguments passed to
TeraSortIngest by CloudStone4
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 <el...@apache.org>
Authored: Thu Nov 13 17:11:36 2014 -0800
Committer: Josh Elser <el...@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("")