#15108 issue: "Non Panic Task error" is not an internal error (#15109)

* #15108 issue: "Non Panic Task error" is not an internal error

* #15108 issue: "Non Panic Task error" is not an internal error

* solved the error

* removing unused import

* Update datafusion/physical-plan/src/stream.rs

Co-authored-by: Alex Huang <[email protected]>

* fix

---------

Co-authored-by: Andrew Lamb <[email protected]>
Co-authored-by: Alex Huang <[email protected]>

Author: 3 people

datafusion/physical-plan/src/stream.rs

@@ -27,7 +27,7 @@ use super::{ExecutionPlan, RecordBatchStream, SendableRecordBatchStream};
 use crate::displayable;
 
 use arrow::{datatypes::SchemaRef, record_batch::RecordBatch};
-use datafusion_common::{internal_err, Result};
+use datafusion_common::{exec_err, Result};
 use datafusion_execution::TaskContext;
 
 use futures::stream::BoxStream;
@@ -128,7 +128,7 @@ impl<O: Send + 'static> ReceiverStreamBuilder<O> {
                             // the JoinSet were aborted, which in turn
                             // would imply that the receiver has been
                             // dropped and this code is not running
-                            return Some(internal_err!("Non Panic Task error: {e}"));
+                            return Some(exec_err!("Non Panic Task error: {e}"));
                         }
                     }
                 }