diff --git a/be/src/exec/kudu/kudu-scanner.cc b/be/src/exec/kudu/kudu-scanner.cc index c053670128..260c06a2e1 100644 --- a/be/src/exec/kudu/kudu-scanner.cc +++ b/be/src/exec/kudu/kudu-scanner.cc @@ -391,7 +391,7 @@ Status KuduScanner::DecodeRowsIntoRowBatch(RowBatch* row_batch, Tuple** tuple_me } int64_t ts_micros = *reinterpret_cast( kudu_tuple->GetSlot(slot->tuple_offset())); - TimestampValue tv = TimestampValue::UtcFromUnixTimeMicros(ts_micros); + TimestampValue tv = TimestampValue::FromUnixTimeMicros(ts_micros,state_->time_zone_for_unix_time_conversions()); if (tv.HasDateAndTime()) { RawValue::Write(&tv, kudu_tuple, slot, nullptr); } else {