flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From roshann...@apache.org
Subject flume git commit: FLUME-2835. Hive Sink tests need to create table with transactional property set (Sriharsha Chintalapani via Roshan Naik)
Date Tue, 03 Nov 2015 21:06:40 GMT
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 <roshan@hortonworks.com>
Authored: Tue Nov 3 13:00:12 2015 -0800
Committer: Roshan Naik <roshan@hortonworks.com>
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) {


Mime
View raw message