Replace DataType::Int64 with DataType::Serial in function.

risingwavelabs · Mar 16, 2023 · f844338 · f844338
1 parent 2c4e74d
commit f844338
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/connector/src/source/nexmark/source/combined_event.rs b/src/connector/src/source/nexmark/source/combined_event.rs
@@ -86,7 +86,7 @@ pub(crate) fn get_event_data_types(
 
     if let Some(row_id_index) = row_id_index {
         // _row_id
-        fields.insert(row_id_index, DataType::Int64);
+        fields.insert(row_id_index, DataType::Serial);
     }
 
     fields