1

liugddx · Jul 22, 2024 · 9e9ede2 · 9e9ede2
1 parent ba0eb23
commit 9e9ede2
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/be/src/vec/data_types/serde/data_type_datetimev2_serde.cpp b/be/src/vec/data_types/serde/data_type_datetimev2_serde.cpp
@@ -112,12 +112,16 @@ void DataTypeDateTimeV2SerDe::write_column_to_arrow(const IColumn& column, const
                     binary_cast<UInt64, DateV2Value<DateTimeV2ValueType>>(col_data[i]);
             datetime_val.unix_timestamp(&timestamp, ctz);
 
+            uint32_t microsecond = datetime_val.microsecond();
+
             if (scale > 3) {
-                uint32_t microsecond = datetime_val.microsecond();
                 timestamp = (timestamp * 1000000) + microsecond;
             } else if (scale > 0) {
-                uint32_t millisecond = datetime_val.microsecond() / 1000;
+                uint32_t millisecond = microsecond / 1000;
+
                 timestamp = (timestamp * 1000) + millisecond;
+            } else if (scale == 0) { // 对于 datetime
+                timestamp = timestamp * 1000000; // 转换为微秒级时间戳
             }
             checkArrowStatus(timestamp_builder.Append(timestamp), column.get_name(),
                              array_builder->type()->name());

diff --git a/be/src/vec/runtime/vdatetime_value.cpp b/be/src/vec/runtime/vdatetime_value.cpp
@@ -3267,7 +3267,7 @@ bool DateV2Value<T>::unix_timestamp(int64_t* timestamp, const cctz::time_zone& c
                                                  date_v2_value_.day_, date_v2_value_.hour_,
                                                  date_v2_value_.minute_, date_v2_value_.second_),
                               ctz);
-        *timestamp = tp.time_since_epoch().count();
+        *timestamp = std::chrono::duration_cast<std::chrono::seconds>(tp.time_since_epoch()).count();
         return true;
     } else {
         const auto tp =