Repository: flume Updated Branches: refs/heads/flume-1.7 a7ffb2701 -> 56bc98d9e
FLUME-2835. Hive Sink tests need to create table with transactional property set (Sriharsha Chintalapani via Roshan Naik) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/56bc98d9 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/56bc98d9 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/56bc98d9 Branch: refs/heads/flume-1.7 Commit: 56bc98d9e63718b9696f5f8a91460d04ee9bad73 Parents: a7ffb27 Author: Roshan Naik <[email protected]> Authored: Tue Nov 3 13:00:12 2015 -0800 Committer: Roshan Naik <[email protected]> Committed: Tue Nov 3 13:00:12 2015 -0800 ---------------------------------------------------------------------- .../src/test/java/org/apache/flume/sink/hive/TestUtil.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/56bc98d9/flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java b/flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java index 1fd60bc..107789f 100644 --- a/flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java +++ b/flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java @@ -76,7 +76,9 @@ public class TestUtil { " clustered by ( " + colNames[0] + " )" + " into 10 buckets " + " stored as orc " + - " location '" + tableLoc + "'"; + " location '" + tableLoc + "'" + + " TBLPROPERTIES ('transactional'='true')"; + runDDL(driver, crtTbl); System.out.println("crtTbl = " + crtTbl); if (partNames!=null && partNames.length!=0) {
