API tools faq
paste
Guest User

Untitled

a guest
Feb 20th, 2018
77
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 5.79 KB | None | 0 0
raw download clone embed print report
  1. at java.io.ByteArrayOutputStream.hugeCapacity(ByteArrayOutputStream.java:123)
  2.  
  3. at java.io.ByteArrayOutputStream.grow(ByteArrayOutputStream.java:117)
  4.  
  5. at java.io.ByteArrayOutputStream.ensureCapacity(ByteArrayOutputStream.java:93)
  6.  
  7. at java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:153)
  8.  
  9. at org.apache.spark.util.ByteBufferOutputStream.write(ByteBufferOutputStream.scala:41)
  10.  
  11. at java.io.ObjectOutputStream$BlockDataOutputStream.drain(ObjectOutputStream.java:1877)
  12.  
  13. at java.io.ObjectOutputStream$BlockDataOutputStream.setBlockDataMode(ObjectOutputStream.java:1786)
  14.  
  15. at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1189)
  16.  
  17. at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
  18.  
  19. at org.apache.spark.serializer.JavaSerializationStream.writeObject(JavaSerializer.scala:43)
  20.  
  21. at org.apache.spark.serializer.JavaSerializerInstance.serialize(JavaSerializer.scala:100)
  22.  
  23. at org.apache.spark.util.ClosureCleaner$.ensureSerializable(ClosureCleaner.scala:295)
  24.  
  25. at org.apache.spark.util.ClosureCleaner$.org$apache$spark$util$ClosureCleaner$$clean(ClosureCleaner.scala:288)
  26.  
  27. at org.apache.spark.util.ClosureCleaner$.clean(ClosureCleaner.scala:108)
  28.  
  29. at org.apache.spark.SparkContext.clean(SparkContext.scala:2288)
  30.  
  31. at org.apache.spark.rdd.RDD$$anonfun$mapPartitions$1.apply(RDD.scala:794)
  32.  
  33. at org.apache.spark.rdd.RDD$$anonfun$mapPartitions$1.apply(RDD.scala:793)
  34.  
  35. at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
  36.  
  37. at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:112)
  38.  
  39. at org.apache.spark.rdd.RDD.withScope(RDD.scala:362)
  40.  
  41. at org.apache.spark.rdd.RDD.mapPartitions(RDD.scala:793)
  42.  
  43. at org.apache.spark.rdd.RDD$$anonfun$treeAggregate$1.apply(RDD.scala:1137)
  44.  
  45. at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
  46.  
  47. at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:112)
  48.  
  49. at org.apache.spark.rdd.RDD.withScope(RDD.scala:362)
  50.  
  51. at org.apache.spark.rdd.RDD.treeAggregate(RDD.scala:1128)
  52.  
  53. at org.apache.spark.mllib.linalg.distributed.RowMatrix.computeGramianMatrix(RowMatrix.scala:122)
  54.  
  55. at org.apache.spark.mllib.linalg.distributed.RowMatrix.computeCovariance(RowMatrix.scala:344)
  56.  
  57. at org.apache.spark.mllib.stat.correlation.PearsonCorrelation$.computeCorrelationMatrix(PearsonCorrelation.scala:49)
  58.  
  59. at org.apache.spark.mllib.stat.correlation.Correlations$.corrMatrix(Correlation.scala:66)
  60.  
  61. at org.apache.spark.mllib.stat.Statistics$.corr(Statistics.scala:74)
  62.  
  63. at com.mitchell.connections.Practice$.createCorrMatrix$1(Practice.scala:141)
  64.  
  65. at com.mitchell.connections.Practice$.com$mitchell$connections$Practice$$creatingCorrmatrix$1(Practice.scala:147)
  66.  
  67. at com.mitchell.connections.Practice$$anonfun$1.apply(Practice.scala:79)
  68.  
  69. at com.mitchell.connections.Practice$$anonfun$1.apply(Practice.scala:79)
  70.  
  71. at scala.collection.parallel.AugmentedIterableIterator$class.map2combiner(RemainsIterator.scala:115)
  72.  
  73. at scala.collection.parallel.immutable.ParVector$ParVectorIterator.map2combiner(ParVector.scala:62)
  74.  
  75. at scala.collection.parallel.ParIterableLike$Map.leaf(ParIterableLike.scala:1054)
  76.  
  77. at scala.collection.parallel.Task$$anonfun$tryLeaf$1.apply$mcV$sp(Tasks.scala:49)
  78.  
  79. at scala.collection.parallel.Task$$anonfun$tryLeaf$1.apply(Tasks.scala:48)
  80.  
  81. at scala.collection.parallel.Task$$anonfun$tryLeaf$1.apply(Tasks.scala:48)
  82.  
  83. at scala.collection.parallel.Task$class.tryLeaf(Tasks.scala:51)
  84.  
  85. at scala.collection.parallel.ParIterableLike$Map.tryLeaf(ParIterableLike.scala:1051)
  86.  
  87. at scala.collection.parallel.AdaptiveWorkStealingTasks$WrappedTask$class.compute(Tasks.scala:152)
  88.  
  89. at scala.collection.parallel.AdaptiveWorkStealingForkJoinTasks$WrappedTask.compute(Tasks.scala:443)
  90.  
  91. at scala.concurrent.forkjoin.RecursiveAction.exec(RecursiveAction.java:160)
  92.  
  93. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  94.  
  95. at scala.concurrent.forkjoin.ForkJoinTask.doJoin(ForkJoinTask.java:341)
  96.  
  97. at scala.concurrent.forkjoin.ForkJoinTask.join(ForkJoinTask.java:673)
  98.  
  99. at scala.collection.parallel.ForkJoinTasks$WrappedTask$class.sync(Tasks.scala:378)
  100.  
  101. at scala.collection.parallel.AdaptiveWorkStealingForkJoinTasks$WrappedTask.sync(Tasks.scala:443)
  102.  
  103. at scala.collection.parallel.ForkJoinTasks$class.executeAndWaitResult(Tasks.scala:426)
  104.  
  105. at scala.collection.parallel.ForkJoinTaskSupport.executeAndWaitResult(TaskSupport.scala:56)
  106.  
  107. at scala.collection.parallel.ExecutionContextTasks$class.executeAndWaitResult(Tasks.scala:558)
  108.  
  109. at scala.collection.parallel.ExecutionContextTaskSupport.executeAndWaitResult(TaskSupport.scala:80)
  110.  
  111. at scala.collection.parallel.ParIterableLike$ResultMapping.leaf(ParIterableLike.scala:958)
  112.  
  113. at scala.collection.parallel.Task$$anonfun$tryLeaf$1.apply$mcV$sp(Tasks.scala:49)
  114.  
  115. at scala.collection.parallel.Task$$anonfun$tryLeaf$1.apply(Tasks.scala:48)
  116.  
  117. at scala.collection.parallel.Task$$anonfun$tryLeaf$1.apply(Tasks.scala:48)
  118.  
  119. at scala.collection.parallel.Task$class.tryLeaf(Tasks.scala:51)
  120.  
  121. at scala.collection.parallel.ParIterableLike$ResultMapping.tryLeaf(ParIterableLike.scala:953)
  122.  
  123. at scala.collection.parallel.AdaptiveWorkStealingTasks$WrappedTask$class.compute(Tasks.scala:152)
  124.  
  125. at scala.collection.parallel.AdaptiveWorkStealingForkJoinTasks$WrappedTask.compute(Tasks.scala:443)
  126.  
  127. at scala.concurrent.forkjoin.RecursiveAction.exec(RecursiveAction.java:160)
  128.  
  129. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  130.  
  131. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  132.  
  133. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  134.  
  135. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!