-
- Downloads
[STREAMING][MINOR] More contextual information in logs + minor code i…
…mprovements Please review and merge at your convenience. Thanks! Author: Jacek Laskowski <jacek@japila.pl> Closes #10595 from jaceklaskowski/streaming-minor-fixes.
Showing
- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/org/apache/spark/storage/BlockManager.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/storage/BlockManager.scala
- core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala 2 additions, 2 deletions...rg/apache/spark/storage/ShuffleBlockFetcherIterator.scala
- network/common/src/main/java/org/apache/spark/network/client/StreamCallback.java 2 additions, 2 deletions.../java/org/apache/spark/network/client/StreamCallback.java
- network/common/src/main/java/org/apache/spark/network/client/TransportClient.java 1 addition, 1 deletion...java/org/apache/spark/network/client/TransportClient.java
- network/common/src/main/java/org/apache/spark/network/server/RpcHandler.java 1 addition, 1 deletion...main/java/org/apache/spark/network/server/RpcHandler.java
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 6 additions, 6 deletions...n/scala/org/apache/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala 42 additions, 44 deletions...in/scala/org/apache/spark/streaming/dstream/DStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/InputDStream.scala 2 additions, 1 deletion...ala/org/apache/spark/streaming/dstream/InputDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/ReceiverInputDStream.scala 2 additions, 2 deletions...apache/spark/streaming/dstream/ReceiverInputDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala 1 addition, 1 deletion...pache/spark/streaming/receiver/ReceivedBlockHandler.scala
- streaming/src/main/scala/org/apache/spark/streaming/receiver/Receiver.scala 2 additions, 2 deletions.../scala/org/apache/spark/streaming/receiver/Receiver.scala
- streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala 3 additions, 5 deletions.../apache/spark/streaming/receiver/ReceiverSupervisor.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobSet.scala 3 additions, 5 deletions...n/scala/org/apache/spark/streaming/scheduler/JobSet.scala
Loading
Please register or sign in to comment