diff --git a/mindspore/ccsrc/minddata/dataset/engine/datasetops/device_queue_op.cc b/mindspore/ccsrc/minddata/dataset/engine/datasetops/device_queue_op.cc
index aa88b8479c..17b3e27029 100644
--- a/mindspore/ccsrc/minddata/dataset/engine/datasetops/device_queue_op.cc
+++ b/mindspore/ccsrc/minddata/dataset/engine/datasetops/device_queue_op.cc
@@ -215,7 +215,8 @@ Status DeviceQueueOp::SendDataToAscend() {
           MS_LOG(INFO) << "stop_send received";
           return Status::OK();
         }
-        return Status(StatusCode::kMDTDTPushFailure, "TDT Push Failed");
+        return Status(StatusCode::kMDTDTPushFailure,
+                      "TDT Push data into device Failed, please check error before this first.");
       }
       MS_LOG(INFO) << "an epoch has already sent, now stop send data.";
       stop_send_ = true;
@@ -262,7 +263,8 @@ Status DeviceQueueOp::SendRowToTdt(TensorRow currRow, bool isProfilingEnable, in
       MS_LOG(INFO) << "stop_send received";
       return Status::OK();
     }
-    return Status(StatusCode::kMDTDTPushFailure, "TDT Push Failed");
+    return Status(StatusCode::kMDTDTPushFailure,
+                  "TDT Push data into device Failed, please check error before this first.");
   }
   if (create_data_info_queue_) {
     DATA_INFO data_info;
diff --git a/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/dataset_node.cc b/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/dataset_node.cc
index 2a1fb556ac..7cf1ee8d2f 100644
--- a/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/dataset_node.cc
+++ b/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/dataset_node.cc
@@ -636,7 +636,8 @@ Status DatasetNode::ValidateParams() {
   CHECK_FAIL_RETURN_UNEXPECTED(
     num_workers_ > 0 && num_workers_ <= num_threads,
     Name() + "'s num_workers=" + std::to_string(num_workers_) +
-      ", this value is not within the required range of [1, cpu_thread_cnt=" + std::to_string(num_threads) + "].");
+      "(default=8), this value is not within the required range of [1, cpu_thread_cnt=" + std::to_string(num_threads) +
+      "], you can modify num_workers in script like:\n" + Name() + "(data_path, num_parallel_workers=4)");
   return Status::OK();
 }
 
diff --git a/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/source/generator_node.cc b/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/source/generator_node.cc
index 423b213953..19feb7079f 100644
--- a/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/source/generator_node.cc
+++ b/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/source/generator_node.cc
@@ -105,7 +105,6 @@ Status GeneratorNode::Build(std::vector<std::shared_ptr<DatasetOp>> *const node_
 
 // no validation is needed for generator op.
 Status GeneratorNode::ValidateParams() {
-  RETURN_IF_NOT_OK(DatasetNode::ValidateParams());
   if (source_len_ == 0) {
     std::string err_msg = "GeneratorNode: data row of input source must not be 0, got: " + std::to_string(source_len_);
     MS_LOG(ERROR) << err_msg;