java.lang.NullPointerException: null
|
at com.company.BaseCodecProvider$ImmediateValueCodec.encode(BaseCodecProvider.java:211)
|
at org.bson.codecs.EncoderContext.encodeWithChildContext(EncoderContext.java:91)
|
at org.bson.codecs.IterableCodec.writeValue(IterableCodec.java:106)
|
at org.bson.codecs.IterableCodec.encode(IterableCodec.java:90)
|
at org.bson.codecs.IterableCodec.encode(IterableCodec.java:37)
|
at org.bson.codecs.EncoderContext.encodeWithChildContext(EncoderContext.java:91)
|
at com.company.codecs.BaseCodec.writeValue(BaseCodec.java:34)
|
at com.company.BaseCodecProvider$BaseCodec.encode(BaseCodecProvider.java:250)
|
at com.company.BaseCodecProvider$BaseCodec.encode(BaseCodecProvider.java:235)
|
at org.bson.codecs.BsonDocumentWrapperCodec.encode(BsonDocumentWrapperCodec.java:63)
|
at org.bson.codecs.BsonDocumentWrapperCodec.encode(BsonDocumentWrapperCodec.java:29)
|
at com.mongodb.operation.BulkWriteBatch$WriteRequestEncoder.encode(BulkWriteBatch.java:385)
|
at com.mongodb.operation.BulkWriteBatch$WriteRequestEncoder.encode(BulkWriteBatch.java:375)
|
at org.bson.codecs.BsonDocumentWrapperCodec.encode(BsonDocumentWrapperCodec.java:63)
|
at org.bson.codecs.BsonDocumentWrapperCodec.encode(BsonDocumentWrapperCodec.java:29)
|
at com.mongodb.internal.connection.BsonWriterHelper.writeDocument(BsonWriterHelper.java:75)
|
at com.mongodb.internal.connection.BsonWriterHelper.writePayload(BsonWriterHelper.java:59)
|
at com.mongodb.internal.connection.CommandMessage.encodeMessageBodyWithMetadata(CommandMessage.java:147)
|
at com.mongodb.internal.connection.RequestMessage.encode(RequestMessage.java:138)
|
at com.mongodb.internal.connection.CommandMessage.encode(CommandMessage.java:61)
|
at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsync(InternalStreamConnection.java:329)
|
at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceiveAsync(UsageTrackingInternalConnection.java:114)
|
at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceiveAsync(DefaultConnectionPool.java:461)
|
at com.mongodb.internal.connection.CommandProtocolImpl.executeAsync(CommandProtocolImpl.java:78)
|
at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:233)
|
at com.mongodb.internal.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:285)
|
at com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:156)
|
at com.mongodb.operation.MixedBulkWriteOperation.executeCommandAsync(MixedBulkWriteOperation.java:444)
|
at com.mongodb.operation.MixedBulkWriteOperation.executeBatchesAsync(MixedBulkWriteOperation.java:350)
|
at com.mongodb.operation.MixedBulkWriteOperation.access$1000(MixedBulkWriteOperation.java:72)
|
at com.mongodb.operation.MixedBulkWriteOperation$2$1.call(MixedBulkWriteOperation.java:239)
|
at com.mongodb.operation.OperationHelper.validateWriteRequests(OperationHelper.java:189)
|
at com.mongodb.operation.MixedBulkWriteOperation$2.call(MixedBulkWriteOperation.java:222)
|
at com.mongodb.operation.OperationHelper$7.onResult(OperationHelper.java:614)
|
at com.mongodb.operation.OperationHelper$7.onResult(OperationHelper.java:611)
|
at com.mongodb.internal.connection.DefaultServer$1.onResult(DefaultServer.java:116)
|
at com.mongodb.internal.connection.DefaultServer$1.onResult(DefaultServer.java:105)
|
at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
|
at com.mongodb.internal.connection.DefaultConnectionPool.openAsync(DefaultConnectionPool.java:201)
|
at com.mongodb.internal.connection.DefaultConnectionPool.getAsync(DefaultConnectionPool.java:158)
|
at com.mongodb.internal.connection.DefaultServer.getConnectionAsync(DefaultServer.java:105)
|
at com.mongodb.binding.AsyncClusterBinding$AsyncClusterBindingConnectionSource.getConnection(AsyncClusterBinding.java:139)
|
at com.mongodb.operation.OperationHelper.withAsyncConnectionSource(OperationHelper.java:611)
|
at com.mongodb.operation.OperationHelper.access$200(OperationHelper.java:63)
|
at com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:631)
|
at com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:619)
|
at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
|
at com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:113)
|
at com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:107)
|
at com.mongodb.internal.connection.BaseCluster$ServerSelectionRequest.onResult(BaseCluster.java:436)
|
at com.mongodb.internal.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:300)
|
at com.mongodb.internal.connection.BaseCluster.selectServerAsync(BaseCluster.java:160)
|
at com.mongodb.internal.connection.SingleServerCluster.selectServerAsync(SingleServerCluster.java:41)
|
at com.mongodb.binding.AsyncClusterBinding.getAsyncClusterBindingConnectionSource(AsyncClusterBinding.java:107)
|
at com.mongodb.binding.AsyncClusterBinding.getWriteConnectionSource(AsyncClusterBinding.java:102)
|
at com.mongodb.operation.OperationHelper.withAsyncConnection(OperationHelper.java:550)
|
at com.mongodb.operation.MixedBulkWriteOperation.executeAsync(MixedBulkWriteOperation.java:216)
|
at com.mongodb.async.client.OperationExecutorImpl$2$1.onResult(OperationExecutorImpl.java:134)
|
at com.mongodb.async.client.OperationExecutorImpl$2$1.onResult(OperationExecutorImpl.java:128)
|
at com.mongodb.async.client.OperationExecutorImpl.getReadWriteBinding(OperationExecutorImpl.java:186)
|
at com.mongodb.async.client.OperationExecutorImpl.access$200(OperationExecutorImpl.java:45)
|
at com.mongodb.async.client.OperationExecutorImpl$2.onResult(OperationExecutorImpl.java:126)
|
at com.mongodb.async.client.OperationExecutorImpl$2.onResult(OperationExecutorImpl.java:120)
|
at com.mongodb.async.client.ClientSessionHelper$2.onResult(ClientSessionHelper.java:80)
|
at com.mongodb.async.client.ClientSessionHelper$2.onResult(ClientSessionHelper.java:73)
|
at com.mongodb.internal.connection.BaseCluster$ServerSelectionRequest.onResult(BaseCluster.java:436)
|
at com.mongodb.internal.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:300)
|
at com.mongodb.internal.connection.BaseCluster.selectServerAsync(BaseCluster.java:160)
|
at com.mongodb.internal.connection.SingleServerCluster.selectServerAsync(SingleServerCluster.java:41)
|
at com.mongodb.async.client.ClientSessionHelper.createClientSession(ClientSessionHelper.java:68)
|
at com.mongodb.async.client.ClientSessionHelper.withClientSession(ClientSessionHelper.java:51)
|
at com.mongodb.async.client.OperationExecutorImpl.execute(OperationExecutorImpl.java:120)
|
at com.mongodb.async.client.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1122)
|
at com.mongodb.async.client.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:491)
|
at com.mongodb.async.client.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:474)
|
at com.mongodb.reactivestreams.client.internal.MongoCollectionImpl$8.apply(MongoCollectionImpl.java:432)
|
at com.mongodb.reactivestreams.client.internal.MongoCollectionImpl$8.apply(MongoCollectionImpl.java:429)
|
at com.mongodb.async.client.SingleResultCallbackSubscription.requestInitialData(SingleResultCallbackSubscription.java:38)
|
at com.mongodb.async.client.AbstractSubscription.tryRequestInitialData(AbstractSubscription.java:170)
|
at com.mongodb.async.client.AbstractSubscription.request(AbstractSubscription.java:88)
|
at com.mongodb.reactivestreams.client.internal.ObservableToPublisher$1$1.request(ObservableToPublisher.java:48)
|
at io.reactivex.internal.operators.completable.CompletableFromPublisher$FromPublisherSubscriber.onSubscribe(CompletableFromPublisher.java:52)
|
at com.mongodb.reactivestreams.client.internal.SingleResultObservableToPublisher$1.onSubscribe(SingleResultObservableToPublisher.java:37)
|
at com.mongodb.reactivestreams.client.internal.ObservableToPublisher$1.onSubscribe(ObservableToPublisher.java:37)
|
at com.mongodb.async.client.SingleResultCallbackSubscription.<init>(SingleResultCallbackSubscription.java:33)
|
at com.mongodb.async.client.Observables$2.subscribe(Observables.java:78)
|
at com.mongodb.reactivestreams.client.internal.ObservableToPublisher.subscribe(ObservableToPublisher.java:34)
|
at com.mongodb.reactivestreams.client.internal.SingleResultObservableToPublisher.subscribe(SingleResultObservableToPublisher.java:34)
|
at io.reactivex.internal.operators.completable.CompletableFromPublisher.subscribeActual(CompletableFromPublisher.java:32)
|
at io.reactivex.Completable.subscribe(Completable.java:2309)
|
at io.reactivex.Completable.subscribe(Completable.java:2383)
|
at com.company.Mongo.lambda$getCompletable$3(Mongo.java:69)
|
at io.reactivex.internal.operators.completable.CompletableCreate.subscribeActual(CompletableCreate.java:39)
|
at io.reactivex.Completable.subscribe(Completable.java:2309)
|
at io.reactivex.internal.operators.completable.CompletableToSingle.subscribeActual(CompletableToSingle.java:38)
|
at io.reactivex.Single.subscribe(Single.java:3666)
|
at io.reactivex.internal.operators.single.SingleMap.subscribeActual(SingleMap.java:34)
|
at io.reactivex.Single.subscribe(Single.java:3666)
|
at io.reactivex.internal.operators.single.SingleToObservable.subscribeActual(SingleToObservable.java:35)
|
at io.reactivex.Observable.subscribe(Observable.java:12267)
|
at io.reactivex.internal.operators.mixed.SingleFlatMapObservable$FlatMapObserver.onSuccess(SingleFlatMapObservable.java:109)
|
at io.reactivex.internal.operators.single.SingleMap$MapSingleObserver.onSuccess(SingleMap.java:64)
|
at io.reactivex.internal.operators.observable.ObservableToListSingle$ToListObserver.onComplete(ObservableToListSingle.java:111)
|
at io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drainLoop(ObservableFlatMap.java:371)
|
at io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drain(ObservableFlatMap.java:326)
|
at io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.onComplete(ObservableFlatMap.java:303)
|
at io.reactivex.internal.observers.BasicFuseableObserver.onComplete(BasicFuseableObserver.java:119)
|
at io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drainLoop(ObservableFlatMap.java:371)
|
at io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drain(ObservableFlatMap.java:326)
|
at io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.onComplete(ObservableFlatMap.java:584)
|
at io.reactivex.internal.observers.BasicFuseableObserver.onComplete(BasicFuseableObserver.java:119)
|
at io.reactivex.internal.observers.BasicFuseableObserver.onComplete(BasicFuseableObserver.java:119)
|
at io.reactivex.internal.operators.mixed.SingleFlatMapObservable$FlatMapObserver.onComplete(SingleFlatMapObservable.java:79)
|
at io.reactivex.internal.disposables.EmptyDisposable.complete(EmptyDisposable.java:53)
|
at io.reactivex.internal.operators.observable.ObservableFromIterable.subscribeActual(ObservableFromIterable.java:50)
|
at io.reactivex.Observable.subscribe(Observable.java:12267)
|
at io.reactivex.internal.operators.mixed.SingleFlatMapObservable$FlatMapObserver.onSuccess(SingleFlatMapObservable.java:109)
|
at io.reactivex.internal.operators.single.SingleMap$MapSingleObserver.onSuccess(SingleMap.java:64)
|
at io.reactivex.internal.operators.single.SingleZipArray$ZipCoordinator.innerSuccess(SingleZipArray.java:119)
|
at io.reactivex.internal.operators.single.SingleZipArray$ZipSingleObserver.onSuccess(SingleZipArray.java:170)
|
at io.reactivex.internal.operators.single.SingleMap$MapSingleObserver.onSuccess(SingleMap.java:64)
|
at io.reactivex.internal.operators.maybe.MaybeToSingle$ToSingleMaybeSubscriber.onComplete(MaybeToSingle.java:96)
|
at io.reactivex.internal.operators.maybe.MaybeMap$MapMaybeObserver.onComplete(MaybeMap.java:99)
|
at io.reactivex.internal.operators.maybe.MaybeCreate$Emitter.onComplete(MaybeCreate.java:118)
|
at com.company.Mongo.lambda$getMaybe$8(Mongo.java:81)
|
at io.reactivex.internal.operators.maybe.MaybeCallbackObserver.onComplete(MaybeCallbackObserver.java:93)
|
at io.reactivex.internal.operators.observable.ObservableSingleMaybe$SingleElementObserver.onComplete(ObservableSingleMaybe.java:98)
|
at io.reactivex.internal.operators.observable.ObservableFromPublisher$PublisherSubscriber.onComplete(ObservableFromPublisher.java:46)
|
at com.mongodb.reactivestreams.client.internal.SingleResultObservableToPublisher$1.onComplete(SingleResultObservableToPublisher.java:56)
|
at com.mongodb.reactivestreams.client.internal.SingleResultObservableToPublisher$1.onError(SingleResultObservableToPublisher.java:48)
|
at com.mongodb.reactivestreams.client.internal.ObservableToPublisher$1.onError(ObservableToPublisher.java:71)
|
at com.mongodb.async.client.AbstractSubscription.onError(AbstractSubscription.java:132)
|
at com.mongodb.async.client.AbstractSubscription.tryProcessResultsQueue(AbstractSubscription.java:180)
|
at com.mongodb.async.client.SingleResultCallbackSubscription$1.onResult(SingleResultCallbackSubscription.java:48)
|
at com.mongodb.async.client.FindIterableImpl$1$1.onResult(FindIterableImpl.java:212)
|
at com.mongodb.async.client.FindIterableImpl$1$1.onResult(FindIterableImpl.java:205)
|
at com.mongodb.operation.AsyncQueryBatchCursor.next(AsyncQueryBatchCursor.java:174)
|
at com.mongodb.operation.AsyncQueryBatchCursor.next(AsyncQueryBatchCursor.java:118)
|
at com.mongodb.async.client.FindIterableImpl$1.onResult(FindIterableImpl.java:205)
|
at com.mongodb.async.client.FindIterableImpl$1.onResult(FindIterableImpl.java:199)
|
at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
|
at com.mongodb.async.client.OperationExecutorImpl$1$1$1.onResult(OperationExecutorImpl.java:94)
|
at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
|
at com.mongodb.operation.FindOperation$3.onResult(FindOperation.java:827)
|
at com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback.onResult(OperationHelper.java:412)
|
at com.mongodb.operation.CommandOperationHelper$10.onResult(CommandOperationHelper.java:481)
|
at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
|
at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor$2.onResult(DefaultServer.java:245)
|
at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
|
at com.mongodb.internal.connection.CommandProtocolImpl$1.onResult(CommandProtocolImpl.java:85)
|
at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection$1.onResult(DefaultConnectionPool.java:467)
|
at com.mongodb.internal.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:111)
|
at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
|
at com.mongodb.internal.connection.InternalStreamConnection$2$1.onResult(InternalStreamConnection.java:399)
|
at com.mongodb.internal.connection.InternalStreamConnection$2$1.onResult(InternalStreamConnection.java:376)
|
at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(InternalStreamConnection.java:677)
|
at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(InternalStreamConnection.java:644)
|
at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:514)
|
at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:511)
|
at com.mongodb.internal.connection.AsynchronousChannelStream$BasicCompletionHandler.completed(AsynchronousChannelStream.java:220)
|
at com.mongodb.internal.connection.AsynchronousChannelStream$BasicCompletionHandler.completed(AsynchronousChannelStream.java:203)
|
at java.base/sun.nio.ch.Invoker.invokeUnchecked(Invoker.java:127)
|
at java.base/sun.nio.ch.Invoker.invokeDirect(Invoker.java:158)
|
at java.base/sun.nio.ch.UnixAsynchronousSocketChannelImpl.implRead(UnixAsynchronousSocketChannelImpl.java:562)
|
at java.base/sun.nio.ch.AsynchronousSocketChannelImpl.read(AsynchronousSocketChannelImpl.java:277)
|
at java.base/sun.nio.ch.AsynchronousSocketChannelImpl.read(AsynchronousSocketChannelImpl.java:298)
|
at com.mongodb.internal.connection.AsynchronousSocketChannelStream$AsynchronousSocketChannelAdapter.read(AsynchronousSocketChannelStream.java:137)
|
at com.mongodb.internal.connection.AsynchronousChannelStream.readAsync(AsynchronousChannelStream.java:105)
|
at com.mongodb.internal.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:511)
|
at com.mongodb.internal.connection.InternalStreamConnection.access$1000(InternalStreamConnection.java:76)
|
at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:634)
|
at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:619)
|
at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:514)
|
at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:511)
|
at com.mongodb.internal.connection.AsynchronousChannelStream$BasicCompletionHandler.completed(AsynchronousChannelStream.java:220)
|
at com.mongodb.internal.connection.AsynchronousChannelStream$BasicCompletionHandler.completed(AsynchronousChannelStream.java:203)
|
at java.base/sun.nio.ch.Invoker.invokeUnchecked(Invoker.java:127)
|
at java.base/sun.nio.ch.UnixAsynchronousSocketChannelImpl.finishRead(UnixAsynchronousSocketChannelImpl.java:439)
|
at java.base/sun.nio.ch.UnixAsynchronousSocketChannelImpl.finish(UnixAsynchronousSocketChannelImpl.java:191)
|
at java.base/sun.nio.ch.UnixAsynchronousSocketChannelImpl.onEvent(UnixAsynchronousSocketChannelImpl.java:213)
|
at java.base/sun.nio.ch.EPollPort$EventHandlerTask.run(EPollPort.java:306)
|
at java.base/sun.nio.ch.AsynchronousChannelGroupImpl$1.run(AsynchronousChannelGroupImpl.java:112)
|
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
|
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
|
at java.base/java.lang.Thread.run(Thread.java:835)
|