File tree Expand file tree Collapse file tree 2 files changed +0
-6
lines changed
network/shuffle/src/main/java/org/apache/spark/network/shuffle Expand file tree Collapse file tree 2 files changed +0
-6
lines changed Original file line number Diff line number Diff line change 2121
2222import com .google .common .annotations .VisibleForTesting ;
2323import com .google .common .collect .Lists ;
24- import io .netty .buffer .ByteBuf ;
25- import io .netty .buffer .Unpooled ;
2624import org .slf4j .Logger ;
2725import org .slf4j .LoggerFactory ;
2826
3634import org .apache .spark .network .shuffle .protocol .OpenBlocks ;
3735import org .apache .spark .network .shuffle .protocol .RegisterExecutor ;
3836import org .apache .spark .network .shuffle .protocol .StreamHandle ;
39- import org .apache .spark .network .util .JavaUtils ;
4037
4138/**
4239 * RPC Handler for a server which can serve shuffle blocks from outside of an Executor process.
Original file line number Diff line number Diff line change 2121import java .util .List ;
2222
2323import com .google .common .collect .Lists ;
24- import io .netty .buffer .ByteBuf ;
25- import io .netty .buffer .Unpooled ;
2624import org .slf4j .Logger ;
2725import org .slf4j .LoggerFactory ;
2826
3432import org .apache .spark .network .sasl .SecretKeyHolder ;
3533import org .apache .spark .network .server .NoOpRpcHandler ;
3634import org .apache .spark .network .shuffle .protocol .ExecutorShuffleInfo ;
37- import org .apache .spark .network .shuffle .protocol .OpenBlocks ;
3835import org .apache .spark .network .shuffle .protocol .RegisterExecutor ;
3936import org .apache .spark .network .util .TransportConf ;
4037
You can’t perform that action at this time.
0 commit comments