using atomic instead of local variable

chowc · Jan 16, 2023 · ae50f60 · ae50f60
1 parent e794b1e
commit ae50f60
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/query/pipeline/sources/src/processors/sources/input_formats/input_context.rs b/src/query/pipeline/sources/src/processors/sources/input_formats/input_context.rs
@@ -182,7 +182,7 @@ impl InputContext {
             block_compact_thresholds,
             format_options: file_format_options,
             on_error_mode,
-            on_error_count: AtomicU64::ZERO,
+            on_error_count: AtomicU64::new(0),
         })
     }
 
@@ -223,7 +223,7 @@ impl InputContext {
             block_compact_thresholds,
             format_options: file_format_options,
             on_error_mode: OnErrorMode::AbortNum(1),
-            on_error_count: AtomicU64::ZERO,
+            on_error_count: AtomicU64::new(0),
         })
     }
 
@@ -261,7 +261,7 @@ impl InputContext {
             block_compact_thresholds,
             format_options: file_format_options,
             on_error_mode: OnErrorMode::AbortNum(1),
-            on_error_count: AtomicU64::ZERO,
+            on_error_count: AtomicU64::new(0),
         })
     }