diff --git a/paddle/fluid/framework/data_feed.cc b/paddle/fluid/framework/data_feed.cc index ed94e30e5cd8a251fe4ab926d9d6e1a5899b229d..1ed472de6c171917aa12aeeda0f4556d6917208f 100644 --- a/paddle/fluid/framework/data_feed.cc +++ b/paddle/fluid/framework/data_feed.cc @@ -106,6 +106,7 @@ void PrivateQueueDataFeed::SetQueueSize(int queue_size) { PADDLE_ENFORCE(queue_size > 0, "Illegal queue size: %d.", queue_size); queue_size_ = queue_size; queue_ = paddle::framework::MakeChannel(); + queue_->SetCapacity(queue_size); } template @@ -301,7 +302,8 @@ void MultiSlotDataFeed::Init( paddle::framework::MultiSlotDesc multi_slot_desc = data_feed_desc.multi_slot_desc(); SetBatchSize(data_feed_desc.batch_size()); - SetQueueSize(data_feed_desc.batch_size()); + // temporarily set queue size = batch size * 100 + SetQueueSize(data_feed_desc.batch_size() * 100); size_t all_slot_num = multi_slot_desc.slots_size(); all_slots_.resize(all_slot_num); all_slots_type_.resize(all_slot_num); diff --git a/paddle/fluid/framework/io/shell.cc b/paddle/fluid/framework/io/shell.cc index ab671cb5690df51c1cff141906c40cc9e74584fa..d63fee7f6e8cfe8c832226d79b5231c39ef1c326 100644 --- a/paddle/fluid/framework/io/shell.cc +++ b/paddle/fluid/framework/io/shell.cc @@ -194,7 +194,8 @@ std::shared_ptr shell_popen(const std::string& cmd, << ", err_no[" << *err_no << "]"; } if (wstatus == -1 && errno == ECHILD) { - LOG(WARNING) << "errno is ECHILD"; + // temporarily remove this warning + // LOG(WARNING) << "errno is ECHILD"; } }}; #endif @@ -285,7 +286,8 @@ std::pair, std::shared_ptr> shell_p2open( << "status[" << wstatus << "], cmd[" << cmd << "]"; if (wstatus == -1 && errno == ECHILD) { - LOG(WARNING) << "errno is ECHILD"; + // temporarily remove this warning + // LOG(WARNING) << "errno is ECHILD"; } }};