Created
November 10, 2021 22:52
-
-
Save nsivabalan/ec616c2b68832707a4d9c2ba14484818 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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