Open
Description
方法代码:
public Spider setScheduler(Scheduler updateScheduler) {
checkIfRunning();
//此处存在问题,这样会导致直接将内部的scheduler设置为updateScheduler,然后又尝试自己poll自己进行数据迁徙
SpiderScheduler oldScheduler = this.scheduler;
//应该修改为下面这样
//Scheduler oldScheduler = scheduler.getScheduler();
scheduler.setScheduler(updateScheduler);
Request request;
while ((request = oldScheduler.poll(this)) != null) {
System.out.println("move oldScheduler task to updateScheduler");
this.scheduler.push(request, this);
}
return this;
}
Metadata
Metadata
Assignees
Labels
No labels