org.apache.spark.SparkException: задание прервано из-за сбоя этапа: задание 0 на этапе 0.0 не выполнено 1 раз, последний сбой: потерянное задание 0.0 на этапе 0.0 (TID 0, localhost, драйвер исполнителя): org.bson.codecs.configuration.CodecConfigurationException: Не удается найти кодек для класса org.bson.BsonDecimal128.в org.bson.codecs.configuration.CodecCache.getOrThrow (CodecCache.java:46) в org.bson.codecs.configuration.ProvidersCodecRegistry.get (ProvidersCodecRegistry.java:63) в org.bson.codecs.configuration.ChistryCode(ChildCodecRegistry.java:51) в org.bson.codecs.BsonDocumentCodec.writeValue (BsonDocumentCodec.java:132) в org.bson.codecs.BsonDocumentCodec.encode (BsonDocumentCodec.java:112) в org.bson.codecscson.закодировать (BsonDocumentCodec.java:40) по адресу com.mongodb.connection.InsertCommandMessage.writeTheWrites (InsertCommandMessage.java:101) по адресу com.mongodb.connection.InsertCommandMessage.writeTheWrites (InsertCommandMessage.conmandMegnMoneBoneBoneBase.4)ЗаписьWriteCommandProtocol.execute (ВтriteCommandProtocol.java:101) в com.mongodb.connection.InsertCommandProtocol.execute (InsertCommandProtocol.java:67) в com.mongodb.connection.InsertCommandProtocol.execute (InsertCommandProtocol.java:37) в com.mongodb.conererSecsec..execute (DefaultServer.java:159) в com.mongodb.connection.DefaultServerConnection.executeProtocol (DefaultServerConnection.java:286) в com.mongodb.connection.DefaultServerConnection.insertCommand (DefaultServerConnection.java.mongb) at5)MixedBulkWriteOperation $ Run $ 2.executeWriteCommandProtocol (MixedBulkWriteOperation.java:455) по адресу com.mongodb.operation.MixedBulkWriteOperation $ Run $ RunExecutor.execute (MixedBulkWriteOperation.java:646) Runed по операции.: 401) в com.mongodb.operation.MixedBulkWriteOperation $ 1.call (MixedBulkWriteOperation.java:179) в com.mongodb.operation.MixedBulkWriteOperation $ 1.call (MixedBulkWriteOperation.java:168) в com.mongodb.operation.OperationHelper.withConnectionSource (OperationHelper.java:230) в com.mongodb.operation.OperationHelper.withConnection (OperationHelper.java:221) в com.mongodb.operation.MixedBulkWriteOperation.exuljWestOed.exulte Mix (: 168) в com.mongodb.operation.MixedBulkWriteOperation.execute (MixedBulkWriteOperation.java:74) в com.mongodb.Mongo.execute (Mongo.java:781) в com.mongodb.Mongo $ 2.execute (Mongo.java:764) в com.mongodb.MongoCollectionImpl.insertMany (MongoCollectionImpl.java:323) в com.mongodb.MongoCollectionImpl.insertMany (MongoCollectionImpl.java:311) в com.mongodb.spark.MongoSpark $ saveon $ $ unonf$ 1 $$ anonfun $ apply $ 2.apply (MongoSpark.scala: 119) на com.mongodb.spark.MongoSpark $$ anonfun $ save $ 1 $$ anonfun $ apply $ 1 $$ anonfun $ apply $ 2.apply (MongoSpark.scala: 119) в scala.collection.Iterator $ class.foreach (Iterator.scala: 727) в scala.collection.AbstractIterator.foreach (Iterator.scala: 1157) в com.mongodb.spark.MongoSpark $$ anonfun $ save $ 1 $$ anonfun $ apply $ 1.apply (MongoSpark.scala: 119) на com.mongodb.spark.MongoSpark $$ anonfun $ save $ 1 $$ anonfun $ apply $ 1.apply (MongoSpark.scala: 118) на com.mongodb.spark.MongoConnector$$ anonfun $ withCollectionDo $ 1.apply (MongoConnector.scala: 186) на com.mongodb.spark.MongoConnector $$ anonfun $ сCollectionDo $ 1.apply (MongoConnector.scala: 184) на com.mongodb.spark.MongoConnector $$ anonfun $withDatabaseDo $ 1.Apply (MongoConnector.scala: 171)по адресу com.mongodb.spark.MongoConnector(MongoConnector.scala: 171) на com.mongodb.spark.MongoConnector.withCollectionDo (MongoConnector.scala: 184) на com.mongodb.spark.MongoSpark $$ anonfun $ сохранить $ 1.apply (MongoSpark.scala: 118) на com.mongodb.spark.MongoSpark $$ anonfun $ save $ 1.apply (MongoSpark.scala: 117) в org.apache.spark.rdd.RDD $$ anonfun $ foreachPartition $ 1 $$ anonfun $ применить $ 29.apply (RDD.scala: 926) в org.apache.spark.rdd.RDD $$ anonfun $ foreachPartition $ 1 $$ anonfun $ apply $ 29.apply (RDD.scala: 926) в org.apache.spark.SparkContext $$ anonfun $ runJob $ 5.apply (SparkContext).scala: 2062) в org.apache.spark.SparkContext $$ anonfun $ runJob $ 5.apply (SparkContext.scala: 2062) в org.apache.spark.scheduler.ResultTask.runTask (ResultTask.scala: 87) в орг.apache.spark.scheduler.Task.run (Task.scala: 108) в org.apache.spark.executor.Executor $ TaskRunner.run (Executor.scala: 335) в java.util.concurrent.ThreadPoolExecutor.runWorker (неизвестный источник) в java.util.concurrent.ThreadPoolExecutor $ Worker.run (неизвестный источник) в java.lang.Thread.run (неизвестный)Источник)