Getting below while writing to MongoDB from pipeline. Please advise on the reason for the error

asked 2019-12-24 06:53:56 -0600

bhanvi gravatar image

{"header":{"stageCreator":"KafkaConsumer_01","sourceId":"PTCDS_Intiated_Event::1::2003::0","stagesPath":"KafkaConsumer_01","trackingId":"PTCDS_Intiated_Event::1::2003::0::KafkaConsumer_01","previousTrackingId":null,"raw":null,"rawMimeType":null,"errorDataCollectorId":"495d4704-2eb8-11e8-8412-470bb34b3dd9","errorPipelineName":"PDSKafkaMONGONFTDBd53d94a4-106b-48b6-9f3a-7d39309ac62c","errorStage":"MongoDB_01","errorStageLabel":"MongoDB 1","errorCode":"MONGODB_17","errorMessage":"MONGODB_17 - Error writing records to Mongo : com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting for a server that matches WritableServerSelector. Client view of cluster state is {type=UNKNOWN, servers=[{address=devecpvm010548.server.rbsgrp.net:27017, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoSecurityException: Exception authenticating MongoCredential{mechanism=null, userName='AppUser', source='admin', password=<hidden>, mechanismProperties={}}}, caused by {com.mongodb.MongoCommandException: Command failed with error 18: 'Authentication failed.' on server devecpvm010548.server.rbsgrp.net:27017. The full response is { \"ok\" : 0.0, \"errmsg\" : \"Authentication failed.\", \"code\" : 18, \"codeName\" : \"AuthenticationFailed\", \"operationTime\" : { \"$timestamp\" : { \"t\" : 1577176883, \"i\" : 1 } }, \"$clusterTime\" : { \"clusterTime\" : { \"$timestamp\" : { \"t\" : 1577176883, \"i\" : 1 } }, \"signature\" : { \"hash\" : { \"$binary\" : \"ODAJ2NuGtoVihdZk7lCFFKXddNQ=\", \"$type\" : \"00\" }, \"keyId\" : { \"$numberLong\" : \"6769165090412298271\" } } } }}}]","errorTimestamp":1577176884445,"errorStackTrace":"com.streamsets.pipeline.api.base.OnRecordErrorException: MONGODB_17 - Error writing records to Mongo : com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting for a server that matches WritableServerSelector. Client view of cluster state is {type=UNKNOWN, servers=[{address=devecpvm010548.server.rbsgrp.net:27017, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoSecurityException: Exception authenticating MongoCredential{mechanism=null, userName='AppUser', source='admin', password=<hidden>, mechanismProperties={}}}, caused by {com.mongodb.MongoCommandException: Command failed with error 18: 'Authentication failed.' on server devecpvm010548.server.rbsgrp.net:27017. The full response is { \"ok\" : 0.0, \"errmsg\" : \"Authentication failed.\", \"code\" : 18, \"codeName\" : \"AuthenticationFailed\", \"operationTime\" : { \"$timestamp\" : { \"t\" : 1577176883, \"i\" : 1 } }, \"$clusterTime\" : { \"clusterTime\" : { \"$timestamp\" : { \"t\" : 1577176883, \"i\" : 1 } }, \"signature\" : { \"hash\" : { \"$binary\" : \"ODAJ2NuGtoVihdZk7lCFFKXddNQ=\", \"$type\" : \"00\" }, \"keyId\" : { \"$numberLong\" : \"6769165090412298271\" } } } }}}]\n\tat com.streamsets.pipeline.stage.destination.mongodb.MongoDBTarget.write(MongoDBTarget.java:212)\n\tat com.streamsets.pipeline.api.base.configurablestage.DTarget.write(DTarget.java:34)\n\tat com.streamsets.datacollector.runner.StageRuntime.lambda$execute$2(StageRuntime.java:290)\n\tat com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:235)\n\tat com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:298)\n\tat com.streamsets.datacollector.runner.StagePipe.process(StagePipe.java:219)\n\tat com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.processPipe(ProductionPipelineRunner.java:810)\n\tat com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.lambda$executeRunner$3(ProductionPipelineRunner.java:854)\n\tat com.streamsets.datacollector.runner.PipeRunner.acceptConsumer(PipeRunner.java:221)\n\tat com.streamsets.datacollector.runner.PipeRunner.executeBatch(PipeRunner.java:142)\n\tat com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.executeRunner(ProductionPipelineRunner.java:853)\n\tat com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.runSourceLessBatch(ProductionPipelineRunner.java:831)\n\tat com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.runPollSource(ProductionPipelineRunner.java:569)\n\tat com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.run(ProductionPipelineRunner.java:383)\n\tat com.streamsets.datacollector.runner.Pipeline.run(Pipeline.java:527)\n\tat com.streamsets.datacollector.execution.runner.common.ProductionPipeline.run(ProductionPipeline.java:109)\n\tat com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunnable.run(ProductionPipelineRunnable.java:75)\n\tat com.streamsets.datacollector.execution.runner.standalone.StandaloneRunner.start(StandaloneRunner.java:703)\n\tat com.streamsets.datacollector.execution.runner.common.AsyncRunner ... (more)

edit retag flag offensive close merge delete