This is an automated email from the ASF dual-hosted git repository.
weijun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 3cfcdb65ba #15108 issue: "Non Panic Task error" is not an internal
error (#15109)
3cfcdb65ba is described below
commit 3cfcdb65ba7c3567c938983ff99ad33bc73d6f13
Author: Satyam018 <[email protected]>
AuthorDate: Thu Mar 13 14:17:41 2025 +1100
#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]>
---
datafusion/physical-plan/src/stream.rs | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/datafusion/physical-plan/src/stream.rs
b/datafusion/physical-plan/src/stream.rs
index f2324dfd9b..6b5d8f46fe 100644
--- a/datafusion/physical-plan/src/stream.rs
+++ b/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}"));
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
