You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ja...@apache.org on 2016/01/11 08:53:59 UTC
[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 <to...@cloudera.com>
Authored: Thu Nov 19 16:19:45 2015 -0800
Committer: Jacques Nadeau <ja...@apache.org>
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: