[arrow-datafusion] branch master updated: Minor: tune log level, lint (#2046)

[dheres]

This is an automated email from the ASF dual-hosted git repository.

dheres pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git


The following commit(s) were added to refs/heads/master by this push:
     new 2dcdb1f  Minor: tune log level, lint (#2046)
2dcdb1f is described below

commit 2dcdb1fbcc52d241aa8582b0d2c60fda179d8b3d
Author: Yijie Shen <henry.yijies...@gmail.com>
AuthorDate: Mon Mar 21 15:10:22 2022 +0800

    Minor: tune log level, lint (#2046)
---
 datafusion/src/dataframe.rs                         | 6 +++---
 datafusion/src/physical_plan/file_format/parquet.rs | 4 ++--
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/datafusion/src/dataframe.rs b/datafusion/src/dataframe.rs
index 643a7ce..263087d 100644
--- a/datafusion/src/dataframe.rs
+++ b/datafusion/src/dataframe.rs
@@ -352,7 +352,7 @@ impl DataFrame {
     pub async fn collect(&self) -> Result<Vec<RecordBatch>> {
         let plan = self.create_physical_plan().await?;
         let task_ctx = 
Arc::new(TaskContext::from(&self.session_state.lock().clone()));
-        Ok(collect(plan, task_ctx).await?)
+        collect(plan, task_ctx).await
     }
 
     /// Print results.
@@ -427,7 +427,7 @@ impl DataFrame {
     pub async fn collect_partitioned(&self) -> Result<Vec<Vec<RecordBatch>>> {
         let plan = self.create_physical_plan().await?;
         let task_ctx = 
Arc::new(TaskContext::from(&self.session_state.lock().clone()));
-        Ok(collect_partitioned(plan, task_ctx).await?)
+        collect_partitioned(plan, task_ctx).await
     }
 
     /// Executes this DataFrame and returns one stream per partition.
@@ -448,7 +448,7 @@ impl DataFrame {
     ) -> Result<Vec<SendableRecordBatchStream>> {
         let plan = self.create_physical_plan().await?;
         let task_ctx = 
Arc::new(TaskContext::from(&self.session_state.lock().clone()));
-        Ok(execute_stream_partitioned(plan, task_ctx).await?)
+        execute_stream_partitioned(plan, task_ctx).await
     }
 
     /// Returns the schema describing the output of this DataFrame in terms of 
columns returned,
diff --git a/datafusion/src/physical_plan/file_format/parquet.rs 
b/datafusion/src/physical_plan/file_format/parquet.rs
index 9731efb..c20d0f5 100644
--- a/datafusion/src/physical_plan/file_format/parquet.rs
+++ b/datafusion/src/physical_plan/file_format/parquet.rs
@@ -50,7 +50,7 @@ use arrow::{
     error::{ArrowError, Result as ArrowResult},
     record_batch::RecordBatch,
 };
-use log::{debug, info};
+use log::{debug, warn};
 use parquet::arrow::ArrowWriter;
 use parquet::file::{
     metadata::RowGroupMetaData,
@@ -249,7 +249,7 @@ impl ExecutionPlan for ParquetExec {
                 limit,
                 partition_col_proj,
             ) {
-                info!(
+                warn!(
                     "Parquet reader thread terminated due to error: {:?} for 
files: {:?}",
                     e, partition
                 );