Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- java.net.SocketInputStream.socketRead0(Native Method)
- java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
- java.net.SocketInputStream.read(SocketInputStream.java:170)
- java.net.SocketInputStream.read(SocketInputStream.java:141)
- java.net.SocketInputStream.read(SocketInputStream.java:127)
- redis.clients.jedis.util.RedisInputStream.ensureFill(RedisInputStream.java:199)
- redis.clients.jedis.util.RedisInputStream.readByte(RedisInputStream.java:43)
- redis.clients.jedis.Protocol.process(Protocol.java:155)
- redis.clients.jedis.Protocol.read(Protocol.java:220)
- redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:283)
- redis.clients.jedis.Connection.getBinaryBulkReply(Connection.java:220)
- redis.clients.jedis.Connection.getBulkReply(Connection.java:210)
- redis.clients.jedis.Jedis.get(Jedis.java:205)
- mstproject.redisDisjointSet$.find(BoruvkaRDD_RS.scala:55)
- mstproject.redisDisjointSet$.$anonfun$find$1(BoruvkaRDD_RS.scala:58)
- mstproject.redisDisjointSet$$$Lambda$2250/1289970853.apply(Unknown Source)
- scala.Option.flatMap(Option.scala:271)
- mstproject.redisDisjointSet$.find(BoruvkaRDD_RS.scala:55)
- mstproject.redisDisjointSet$.$anonfun$find$1(BoruvkaRDD_RS.scala:58)
- mstproject.redisDisjointSet$$$Lambda$2250/1289970853.apply(Unknown Source)
- scala.Option.flatMap(Option.scala:271)
- mstproject.redisDisjointSet$.find(BoruvkaRDD_RS.scala:55)
- mstproject.BoruvkaRDD_RS$.$anonfun$BoruvkaLoop$2(BoruvkaRDD_RS.scala:109)
- mstproject.BoruvkaRDD_RS$$$Lambda$2249/364725283.apply(Unknown Source)
- scala.collection.Iterator$$anon$10.next(Iterator.scala:461)
- scala.collection.Iterator$$anon$10.next(Iterator.scala:461)
- org.apache.spark.shuffle.sort.BypassMergeSortShuffleWriter.write(BypassMergeSortShuffleWriter.java:149)
- org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99)
- org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:55)
- org.apache.spark.scheduler.Task.run(Task.scala:123)
- org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$3(Executor.scala:411)
- org.apache.spark.executor.Executor$TaskRunner$$Lambda$1671/1946238231.apply(Unknown Source)
- org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
- org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
- java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
- java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
- java.lang.Thread.run(Thread.java:745)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement