|
@@ -2999,8 +2999,8 @@ public class DataNode extends ReconfigurableBase
|
|
|
b.setNumBytes(visible);
|
|
|
|
|
|
if (targets.length > 0) {
|
|
|
- new DataTransfer(targets, targetStorageTypes, targetStorageIds, b, stage,
|
|
|
- client).run();
|
|
|
+ new Daemon(new DataTransfer(targets, targetStorageTypes,
|
|
|
+ targetStorageIds, b, stage, client)).start();
|
|
|
}
|
|
|
}
|
|
|
|