fix

risingwavelabs · Oct 9, 2024 · 032230a · 032230a
1 parent 2afb409
commit 032230a
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/src/batch/src/executor/postgres_query.rs b/src/batch/src/executor/postgres_query.rs
@@ -19,6 +19,7 @@ use risingwave_common::row::OwnedRow;
 use risingwave_common::types::{DataType, Datum, Decimal, ScalarImpl};
 use risingwave_common::util::chunk_coalesce::DataChunkBuilder;
 use risingwave_pb::batch_plan::plan_node::NodeBody;
+use thiserror_ext::AsReport;
 use tokio_postgres;
 
 use crate::error::BatchError;
@@ -139,7 +140,10 @@ impl PostgresQueryExecutor {
 
         tokio::spawn(async move {
             if let Err(e) = conn.await {
-                tracing::error!("postgres_query_executor: connection error: {:?}", e);
+                tracing::error!(
+                    "postgres_query_executor: connection error: {:?}",
+                    e.as_report()
+                );
             }
         });
 

diff --git a/src/frontend/src/expr/table_function.rs b/src/frontend/src/expr/table_function.rs
@@ -20,6 +20,7 @@ use risingwave_common::types::{DataType, ScalarImpl, StructType};
 use risingwave_connector::source::iceberg::{create_parquet_stream_builder, list_s3_directory};
 pub use risingwave_pb::expr::table_function::PbType as TableFunctionType;
 use risingwave_pb::expr::PbTableFunction;
+use thiserror_ext::AsReport;
 use tokio::runtime::Runtime;
 use tokio_postgres;
 use tokio_postgres::types::Type as TokioPgType;
@@ -303,7 +304,10 @@ impl TableFunction {
 
                     tokio::spawn(async move {
                         if let Err(e) = connection.await {
-                            eprintln!("connection error: {}", e);
+                            tracing::error!(
+                                "postgres_query_executor: connection error: {:?}",
+                                e.as_report()
+                            );
                         }
                     });