diff --git a/be/src/vec/exec/vjdbc_connector.cpp b/be/src/vec/exec/vjdbc_connector.cpp
index ece1ddbeab..d8e5405395 100644
--- a/be/src/vec/exec/vjdbc_connector.cpp
+++ b/be/src/vec/exec/vjdbc_connector.cpp
@@ -672,13 +672,8 @@ Status JdbcConnector::_cast_string_to_array(const SlotDescriptor* slot_desc, Blo
                                             int column_index, int rows) {
     DataTypePtr _target_data_type = slot_desc->get_data_type_ptr();
     std::string _target_data_type_name = _target_data_type->get_name();
-    DataTypePtr _cast_param_data_type = std::make_shared<DataTypeInt16>();
-    ColumnPtr _cast_param = _cast_param_data_type->create_column_const(
-            1, static_cast<int16_t>(_target_data_type->is_nullable()
-                                            ? ((DataTypeNullable*)(_target_data_type.get()))
-                                                      ->get_nested_type()
-                                                      ->get_type_id()
-                                            : _target_data_type->get_type_id()));
+    DataTypePtr _cast_param_data_type = _target_data_type;
+    ColumnPtr _cast_param = _cast_param_data_type->create_column_const_with_default_value(1);
 
     ColumnsWithTypeAndName argument_template;
     argument_template.reserve(2);