Repository: flume Updated Branches: refs/heads/trunk 8bb556604 -> f38a52102
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/f38a5210 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/f38a5210 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/f38a5210 Branch: refs/heads/trunk Commit: f38a52102cf7a09e9727aa7a1321a86dcbe84c0d Parents: 8bb5566 Author: Roshan Naik <[email protected]> Authored: Tue Nov 3 13:00:12 2015 -0800 Committer: Roshan Naik <[email protected]> Committed: Tue Nov 3 13:01:36 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/f38a5210/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) {
