You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2016/02/05 19:05:53 UTC
hbase git commit: HBASE-11262 Addendum fixes new unit test
Repository: hbase
Updated Branches:
refs/heads/branch-1 8473fae1d -> 9bd679de4
HBASE-11262 Addendum fixes new unit test
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9bd679de
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9bd679de
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9bd679de
Branch: refs/heads/branch-1
Commit: 9bd679de4299c86394be09ac8150e128e4e3171b
Parents: 8473fae
Author: tedyu <yu...@gmail.com>
Authored: Fri Feb 5 10:05:46 2016 -0800
Committer: tedyu <yu...@gmail.com>
Committed: Fri Feb 5 10:05:46 2016 -0800
----------------------------------------------------------------------
.../java/org/apache/hadoop/hbase/mapreduce/TestImportTsv.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/9bd679de/hbase-server/src/test/java/org/apache/hadoop/hbase/mapreduce/TestImportTsv.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/mapreduce/TestImportTsv.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/mapreduce/TestImportTsv.java
index 8920da4..83de8f9 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/mapreduce/TestImportTsv.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/mapreduce/TestImportTsv.java
@@ -368,15 +368,15 @@ public class TestImportTsv implements Configurable {
@Test
public void testSkipEmptyColumns() throws Exception {
- Path bulkOutputPath = new Path(util.getDataTestDirOnTestFS(tn.getNameAsString()), "hfiles");
+ Path bulkOutputPath = new Path(util.getDataTestDirOnTestFS(table), "hfiles");
args.put(ImportTsv.BULK_OUTPUT_CONF_KEY, bulkOutputPath.toString());
args.put(ImportTsv.COLUMNS_CONF_KEY, "HBASE_ROW_KEY,HBASE_TS_KEY,FAM:A,FAM:B");
args.put(ImportTsv.SEPARATOR_CONF_KEY, ",");
args.put(ImportTsv.SKIP_EMPTY_COLUMNS, "true");
// 2 Rows of data as input. Both rows are valid and only 3 columns are no-empty among 4
String data = "KEY,1234,VALUE1,VALUE2\nKEY,1235,,VALUE2\n";
- doMROnTableTest(util, tn, FAMILY, data, args, 1, 3);
- util.deleteTable(tn);
+ doMROnTableTest(util, table, FAMILY, data, args, 1, 3);
+ util.deleteTable(table);
}
private Tool doMROnTableTest(String data, int valueMultiplier,int expectedKVCount)