fix

Signed-off-by: tabVersion <tabvision@bupt.icu>
risingwavelabs · Mar 17, 2023 · 95d8dea · 95d8dea
1 parent 81b284e
commit 95d8dea
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/common/src/field_generator/mod.rs b/src/common/src/field_generator/mod.rs
@@ -328,8 +328,10 @@ mod tests {
     #[test]
     fn test_deterministic_timestamp() {
         let seed = 1234;
-        let base_time: DateTime<FixedOffset> = DateTime::parse_from_rfc3339("2020-01-01T00:00:00+00:00").unwrap();
-        let mut generator = FieldGeneratorImpl::with_timestamp(Some(base_time), None, None, seed).unwrap();
+        let base_time: DateTime<FixedOffset> =
+            DateTime::parse_from_rfc3339("2020-01-01T00:00:00+00:00").unwrap();
+        let mut generator =
+            FieldGeneratorImpl::with_timestamp(Some(base_time), None, None, seed).unwrap();
         let val1 = generator.generate_json(1);
         let val2 = generator.generate_json(1);
         assert_eq!(val1, val2);

diff --git a/src/common/src/field_generator/timestamp.rs b/src/common/src/field_generator/timestamp.rs
@@ -22,7 +22,6 @@ use serde_json::{json, Value};
 use tracing::debug;
 
 use super::DEFAULT_MAX_PAST;
-use crate::array::Op;
 use crate::types::{Datum, NaiveDateTimeWrapper, Scalar};
 
 #[derive(Debug)]

diff --git a/src/connector/src/source/datagen/source/reader.rs b/src/connector/src/source/datagen/source/reader.rs
@@ -16,7 +16,6 @@ use std::collections::HashMap;
 
 use anyhow::{anyhow, Result};
 use async_trait::async_trait;
-use chrono::{DateTime, FixedOffset};
 use futures::{StreamExt, TryStreamExt};
 use futures_async_stream::try_stream;
 use risingwave_common::field_generator::FieldGeneratorImpl;