diff --git a/python/ray/data/_internal/execution/streaming_executor_state.py b/python/ray/data/_internal/execution/streaming_executor_state.py
index d80fdfc64402..6140d6f70554 100644
--- a/python/ray/data/_internal/execution/streaming_executor_state.py
+++ b/python/ray/data/_internal/execution/streaming_executor_state.py
@@ -436,7 +436,7 @@ def process_completed_tasks(
                                 " Ignoring this exception with remaining"
                                 f" max_errored_blocks={remaining}."
                             )
-                            logger.get_logger().warning(error_message, exc_info=e)
+                            logger.get_logger().error(error_message, exc_info=e)
                         else:
                             error_message += (
                                 " Dataset execution will now abort."