diff --git a/src/common_types/src/datum.rs b/src/common_types/src/datum.rs
index 9b22439a22..b5fff56437 100644
--- a/src/common_types/src/datum.rs
+++ b/src/common_types/src/datum.rs
@@ -17,7 +17,11 @@
 
 //! Datum holds different kind of data
 
-use std::{convert::TryFrom, fmt, str};
+use std::{
+    convert::TryFrom,
+    fmt,
+    str::{self, from_utf8, Utf8Error},
+};
 
 use arrow::{
     datatypes::{DataType, TimeUnit},
@@ -102,6 +106,13 @@ pub enum Error {
         hex_val: String,
         backtrace: Backtrace,
     },
+
+    #[snafu(display("Invalid string encoding, that are not utf-8 characters input:{msg}, err:{source}. \nBacktrace:\n{backtrace}"))]
+    InvalidStringEncoding {
+        msg: String,
+        source: Utf8Error,
+        backtrace: Backtrace,
+    },
 }
 
 pub type Result<T> = std::result::Result<T, Error>;
@@ -765,6 +776,11 @@ impl Datum {
         }
     }
 
+    fn valid_is_utf8(s: &str) -> Result<()> {
+        from_utf8(s.as_bytes()).context(InvalidStringEncoding { msg: s })?;
+        Ok(())
+    }
+
     pub fn try_from_sql_value(kind: &DatumKind, value: Value) -> Result<Datum> {
         match (kind, value) {
             (DatumKind::Null, Value::Null) => Ok(Datum::Null),
@@ -790,12 +806,15 @@ impl Datum {
             }
             // TODO(yingwen): Support hex string.
             (DatumKind::Varbinary, Value::SingleQuotedString(s)) => {
+                Self::valid_is_utf8(&s)?;
                 Ok(Datum::Varbinary(Bytes::from(s)))
             }
             (DatumKind::String, Value::SingleQuotedString(s)) => {
+                Self::valid_is_utf8(&s)?;
                 Ok(Datum::String(StringBytes::from(s)))
             }
             (DatumKind::Varbinary, Value::DoubleQuotedString(s)) => {
+                Self::valid_is_utf8(&s)?;
                 Ok(Datum::Varbinary(Bytes::from(s)))
             }
             (DatumKind::Varbinary, Value::HexStringLiteral(s)) => {
@@ -803,6 +822,7 @@ impl Datum {
                 Ok(Datum::Varbinary(Bytes::from(bytes)))
             }
             (DatumKind::String, Value::DoubleQuotedString(s)) => {
+                Self::valid_is_utf8(&s)?;
                 Ok(Datum::String(StringBytes::from(s)))
             }
             (DatumKind::UInt64, Value::Number(n, _long)) => {