Update merge_fuzz.rs

apache · Sep 2, 2024 · 0449f47 · 0449f47
1 parent b6aac77
commit 0449f47
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/datafusion/core/tests/fuzz_cases/merge_fuzz.rs b/datafusion/core/tests/fuzz_cases/merge_fuzz.rs
@@ -348,12 +348,7 @@ async fn test_spm_congestion() -> Result<()> {
     let spm_task =
         SpawnedTask::spawn(async move { collect(Arc::new(spm), task_ctx).await });
 
-    #[cfg(target_os = "windows")]
-    let duration = Duration::from_secs(10);
-    #[cfg(not(target_os = "windows"))]
-    let duration = Duration::from_secs(1);
-
-    let result = timeout(duration, spm_task.join()).await;
+    let result = timeout(Duration::from_secs(1), spm_task.join()).await;
     match result {
         Ok(Ok(Ok(_batches))) => Ok(()),
         Ok(Ok(Err(e))) => Err(e),