Skip to content

Instantly share code, notes, and snippets.

@nsivabalan
Created November 10, 2021 22:52
Show Gist options
  • Save nsivabalan/ec616c2b68832707a4d9c2ba14484818 to your computer and use it in GitHub Desktop.
Save nsivabalan/ec616c2b68832707a4d9c2ba14484818 to your computer and use it in GitHub Desktop.
scala> df.write.format("hudi").
| option("hoodie.datasource.write.recordkey.field","col_str_0005").
| option("hoodie.datasource.write.keygenerator.class","org.apache.hudi.keygen.NonpartitionedKeyGenerator").
| option("hoodie.datasource.write.operation","bulk_insert").
| option("hoodie.table.name","hudi_binsert_base").
| mode(Overwrite).
| save(hudi_base)
21/11/10 22:47:34 WARN scheduler.TaskSetManager: Lost task 1504.0 in stage 12.0 (TID 4596, ip-172-31-35-206.us-east-2.compute.internal, executor 11): java.io.IOException: No space left on device
at sun.nio.ch.FileDispatcherImpl.write0(Native Method)
at sun.nio.ch.FileDispatcherImpl.write(FileDispatcherImpl.java:60)
at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)
at sun.nio.ch.IOUtil.write(IOUtil.java:51)
at sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:211)
at sun.nio.ch.FileChannelImpl.transferToTrustedChannel(FileChannelImpl.java:516)
at sun.nio.ch.FileChannelImpl.transferTo(FileChannelImpl.java:609)
at org.apache.spark.util.Utils$.copyFileStreamNIO(Utils.scala:429)
at org.apache.spark.util.Utils.copyFileStreamNIO(Utils.scala)
at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.mergeSpillsWithTransferTo(UnsafeShuffleWriter.java:468)
at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.mergeSpillsUsingStandardWriter(UnsafeShuffleWriter.java:318)
at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.mergeSpills(UnsafeShuffleWriter.java:285)
at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.closeAndWriteOutput(UnsafeShuffleWriter.java:224)
at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.write(UnsafeShuffleWriter.java:180)
at org.apache.spark.shuffle.ShuffleWriteProcessor.write(ShuffleWriteProcessor.scala:59)
at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99)
at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:52)
at org.apache.spark.scheduler.Task.run(Task.scala:127)
at org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$3(Executor.scala:446)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1377)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:449)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
21/11/10 22:47:34 WARN scheduler.TaskSetManager: Lost task 1632.0 in stage 12.0 (TID 4589, ip-172-31-35-206.us-east-2.compute.internal, executor 12): org.apache.spark.memory.SparkOutOfMemoryError: error while calling spill() on org.apache.spark.shuffle.sort.ShuffleExternalSorter@4dbc5158 : No space left on device
at org.apache.spark.memory.TaskMemoryManager.acquireExecutionMemory(TaskMemoryManager.java:222)
at org.apache.spark.memory.TaskMemoryManager.allocatePage(TaskMemoryManager.java:289)
at org.apache.spark.memory.MemoryConsumer.allocatePage(MemoryConsumer.java:116)
at org.apache.spark.shuffle.sort.ShuffleExternalSorter.acquireNewPageIfNecessary(ShuffleExternalSorter.java:385)
at org.apache.spark.shuffle.sort.ShuffleExternalSorter.insertRecord(ShuffleExternalSorter.java:409)
at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.insertRecordIntoSorter(UnsafeShuffleWriter.java:249)
at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.write(UnsafeShuffleWriter.java:178)
at org.apache.spark.shuffle.ShuffleWriteProcessor.write(ShuffleWriteProcessor.scala:59)
at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99)
at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:52)
at org.apache.spark.scheduler.Task.run(Task.scala:127)
at org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$3(Executor.scala:446)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1377)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:449)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
21/11/10 22:47:41 WARN scheduler.TaskSetManager: Lost task 1509.1 in stage 12.0 (TID 4760, ip-172-31-35-206.us-east-2.compute.internal, executor 12): org.apache.spark.memory.SparkOutOfMemoryError: error while calling spill() on org.apache.spark.shuffle.sort.ShuffleExternalSorter@69a07ade : No space left on device
at org.apache.spark.memory.TaskMemoryManager.acquireExecutionMemory(TaskMemoryManager.java:222)
at org.apache.spark.memory.TaskMemoryManager.allocatePage(TaskMemoryManager.java:289)
at org.apache.spark.memory.MemoryConsumer.allocatePage(MemoryConsumer.java:116)
at org.apache.spark.shuffle.sort.ShuffleExternalSorter.acquireNewPageIfNecessary(ShuffleExternalSorter.java:385)
at org.apache.spark.shuffle.sort.ShuffleExternalSorter.insertRecord(ShuffleExternalSorter.java:409)
at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.insertRecordIntoSorter(UnsafeShuffleWriter.java:249)
at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.write(UnsafeShuffleWriter.java:178)
at org.apache.spark.shuffle.ShuffleWriteProcessor.write(ShuffleWriteProcessor.scala:59)
at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99)
at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:52)
at org.apache.spark.scheduler.Task.run(Task.scala:127)
at org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$3(Executor.scala:446)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1377)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:449)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1495 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1728 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2568 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1566 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2600 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1465 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1574 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2837 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2969 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2314 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2709 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2370 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_36 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2485 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_726 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_823 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2481 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_96 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2244 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2846 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2546 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1738 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_613 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2464 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1940 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2606 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2453 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2955 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_733 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_958 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2090 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2000 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1602 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_6 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_836 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2668 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_597 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1369 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1327 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2813 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2342 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_329 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2712 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1989 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_353 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1091 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2678 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_451 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1483 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1847 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_317 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2443 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_828 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1607 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2067 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2362 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2100 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1485 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_21 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2077 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2103 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1221 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2691 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1331 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_447 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2123 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1741 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2326 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1480 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2477 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2585 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_200 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1236 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_202 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1603 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_111 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2842 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1860 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_723 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_435 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1969 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2796 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1367 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2723 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1868 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2932 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_822 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_739 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_936 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2835 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_952 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_229 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_211 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1057 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1726 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_66 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1247 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1614 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1370 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2189 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_213 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2329 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2580 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1599 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_81 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_362 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1691 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1858 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1071 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2579 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_344 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2976 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_478 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_581 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1076 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_948 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2124 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_51 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1073 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2444 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_214 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1702 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1807 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1216 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_607 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1065 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_939 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2920 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1962 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_717 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_816 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1351 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1810 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2197 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_946 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2690 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2235 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2451 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_351 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_741 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2937 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_190 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_835 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1996 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1592 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1941 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1093 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_577 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_466 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1215 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2213 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2360 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_339 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1225 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_468 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2080 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1458 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1239 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_964 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2323 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2598 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_199 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1975 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1498 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_734 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_731 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1875 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1863 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2241 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_827 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1347 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2950 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2208 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_599 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_457 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2195 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_467 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1097 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1226 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1452 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_308 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2724 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2925 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_942 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_590 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1727 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2816 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2802 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_842 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1354 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_580 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1736 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_902 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1105 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_2028 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_1257 !
21/11/10 22:47:42 WARN storage.BlockManagerMasterEndpoint: No more replicas available for rdd_24_501 !
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment