Return-Path: X-Original-To: apmail-drill-commits-archive@www.apache.org Delivered-To: apmail-drill-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 81AD3180E1 for ; Mon, 11 Jan 2016 07:53:50 +0000 (UTC) Received: (qmail 88984 invoked by uid 500); 11 Jan 2016 07:53:50 -0000 Delivered-To: apmail-drill-commits-archive@drill.apache.org Received: (qmail 88875 invoked by uid 500); 11 Jan 2016 07:53:50 -0000 Mailing-List: contact commits-help@drill.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: commits@drill.apache.org Delivered-To: mailing list commits@drill.apache.org Received: (qmail 88722 invoked by uid 99); 11 Jan 2016 07:53:50 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Jan 2016 07:53:50 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 13DBDE050B; Mon, 11 Jan 2016 07:53:50 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: jacques@apache.org To: commits@drill.apache.org Date: Mon, 11 Jan 2016 07:53:59 -0000 Message-Id: <863872fa9a1a43f595678dbf8c857e93@git.apache.org> In-Reply-To: <90208e6d24734ec8a04a65532abf2713@git.apache.org> References: <90208e6d24734ec8a04a65532abf2713@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [11/12] drill git commit: DRILL-4241: Timestamps should divide by 1000 in reader DRILL-4241: Timestamps should divide by 1000 in reader Project: http://git-wip-us.apache.org/repos/asf/drill/repo Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/36949096 Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/36949096 Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/36949096 Branch: refs/heads/master Commit: 3694909662d62772ea146c073bdb2d6f10e4150e Parents: 54cf727 Author: Todd Lipcon Authored: Thu Nov 19 16:19:45 2015 -0800 Committer: Jacques Nadeau Committed: Sun Jan 10 22:54:21 2016 -0800 ---------------------------------------------------------------------- .../java/org/apache/drill/exec/store/kudu/KuduRecordReader.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/drill/blob/36949096/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java ---------------------------------------------------------------------- diff --git a/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java b/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java index 7f7fc35..a97df77 100644 --- a/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java +++ b/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java @@ -315,10 +315,10 @@ public class KuduRecordReader extends AbstractRecordReader { case TIMESTAMP: if (pci.kuduColumn.isNullable()) { ((NullableTimeStampVector.Mutator)pci.vv.getMutator()) - .setSafe(rowIndex, result.getLong(pci.index)); + .setSafe(rowIndex, result.getLong(pci.index) / 1000); } else { ((TimeStampVector.Mutator)pci.vv.getMutator()) - .setSafe(rowIndex, result.getLong(pci.index)); + .setSafe(rowIndex, result.getLong(pci.index) / 1000); } break; default: