FLUME-2835. Hive Sink tests need to create table with transactional p…

…roperty set (Sriharsha Chintalapani via Roshan Naik)
apache · Nov 3, 2015 · f38a521 · f38a521
1 parent 8bb5566
commit f38a521
Showing 1 changed file with 3 additions and 1 deletion.
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
@@ -76,7 +76,9 @@ public static void createDbAndTable(Driver driver, String databaseName,
             " 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) {