Return-Path: 
 <commits-return-2659-apmail-hive-commits-archive=hive.apache.org@hive.apache.org>
X-Original-To: apmail-hive-commits-archive@www.apache.org
Delivered-To: apmail-hive-commits-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 9B1897C90
	for <apmail-hive-commits-archive@www.apache.org>;
 Sat, 16 Jul 2011 15:28:53 +0000 (UTC)
Received: (qmail 35197 invoked by uid 500); 16 Jul 2011 15:28:53 -0000
Delivered-To: apmail-hive-commits-archive@hive.apache.org
Received: (qmail 35183 invoked by uid 500); 16 Jul 2011 15:28:52 -0000
Mailing-List: contact commits-help@hive.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:commits-help@hive.apache.org>
List-Unsubscribe: <mailto:commits-unsubscribe@hive.apache.org>
List-Post: <mailto:commits@hive.apache.org>
List-Id: <commits.hive.apache.org>
Reply-To: hive-dev@hive.apache.org
Delivered-To: mailing list commits@hive.apache.org
Received: (qmail 35175 invoked by uid 99); 16 Jul 2011 15:28:51 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 16 Jul 2011 15:28:51 +0000
X-ASF-Spam-Status: No, hits=-2000.0 required=5.0
	tests=ALL_TRUSTED
X-Spam-Check-By: apache.org
Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4)
    by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 16 Jul 2011 15:28:50 +0000
Received: from eris.apache.org (localhost [127.0.0.1])
	by eris.apache.org (Postfix) with ESMTP id 9F23B23888CE
	for <commits@hive.apache.org>; Sat, 16 Jul 2011 15:28:30 +0000 (UTC)
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Subject: svn commit: r1147436 -
 /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java
Date: Sat, 16 Jul 2011 15:28:30 -0000
To: commits@hive.apache.org
From: nzhang@apache.org
X-Mailer: svnmailer-1.0.8
Message-Id: <20110716152830.9F23B23888CE@eris.apache.org>

Author: nzhang
Date: Sat Jul 16 15:28:30 2011
New Revision: 1147436

URL: http://svn.apache.org/viewvc?rev=1147436&view=rev
Log:
HIVE-2260. ExecDriver::addInputPaths should pass the table properties to the record writer (Jakob Homan via Ning Zhang)

Modified:
    hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java

Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java?rev=1147436&r1=1147435&r2=1147436&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java Sat Jul 16 15:28:30 2011
@@ -743,12 +743,15 @@ public class ExecDriver extends Task<Map
     // The input file does not exist, replace it by a empty file
     Class<? extends HiveOutputFormat> outFileFormat = null;
     boolean nonNative = true;
+    Properties props;
     if (isEmptyPath) {
       PartitionDesc partDesc = work.getPathToPartitionInfo().get(path);
+      props = partDesc.getProperties();
       outFileFormat = partDesc.getOutputFileFormatClass();
       nonNative = partDesc.getTableDesc().isNonNative();
     } else {
       TableDesc tableDesc = work.getAliasToPartnInfo().get(alias).getTableDesc();
+      props = tableDesc.getProperties();
       outFileFormat = tableDesc.getOutputFileFormatClass();
       nonNative = tableDesc.isNonNative();
     }
@@ -802,7 +805,7 @@ public class ExecDriver extends Task<Map
 
     String onefile = newPath.toString();
     RecordWriter recWriter = outFileFormat.newInstance().getHiveRecordWriter(job, newFilePath,
-        Text.class, false, new Properties(), null);
+        Text.class, false, props, null);
     recWriter.close(false);
     FileInputFormat.addInputPaths(job, onefile);
     return numEmptyPaths;