http://git-wip-us.apache.org/repos/asf/flume/blob/cf474b4d/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestAsyncHBaseSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestAsyncHBaseSink.java b/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestAsyncHBaseSink.java index 641952a..c835172 100644 --- a/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestAsyncHBaseSink.java +++ b/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestAsyncHBaseSink.java @@ -55,6 +55,7 @@ import org.junit.BeforeClass; import org.junit.Ignore; import org.junit.Test; +import com.google.common.io.Files; import com.google.common.primitives.Longs; import java.lang.reflect.Method; @@ -62,7 +63,7 @@ public class TestAsyncHBaseSink { private static HBaseTestingUtility testUtility; private static MiniZooKeeperCluster zookeeperCluster; private static MiniHBaseCluster hbaseCluster; - private static String workDir = "./testFlumeHbaseSink"; + private static String workDir = Files.createTempDir().getAbsolutePath(); private static String tableName = "TestHbaseSink"; private static String columnFamily = "TestColumnFamily"; @@ -261,7 +262,6 @@ public class TestAsyncHBaseSink { testUtility.deleteTable(tableName.getBytes()); } - @Test(expected = FlumeException.class) public void testMissingTable() throws Exception { ctx.put("batchSize", "2");
