Error Connecting Through tMongodbInput (From existing Connection)

[Prateekk]

I am facing issue when I am trying to connect to tMongoDBinput from existing connection.When I check checkbox for existing Connection, Its throwing me error as "authentication failed". But when I tried with the giving configuration present in

tMongoDBinput component its connecting.

The same issue i am facing from the Metadata and connection from tMongoDBinput components existing connection.

I am using mongodb version 4 and the talend open studio Big data..

Can you please help me to resolve?

Primary issue i have seen is the version issue of Mongodb and talend compatibility with Mongodb version.

I am attaching Screenshot for the Job, error i am getting.

Exception in component tMongoDBInput_1 (MONGOTEST)

com.mongodb.MongoSecurityException: Exception authenticating MongoCredential{mechanism=XXXXXXX, userName='XXXXX', source='XXXXX', password=<hidden>, mechanismProperties={}}

at com.mongodb.internal.connection.SaslAuthenticator.wrapException(SaslAuthenticator.java:173)

at com.mongodb.internal.connection.SaslAuthenticator.access$300(SaslAuthenticator.java:40)

at com.mongodb.internal.connection.SaslAuthenticator$1.run(SaslAuthenticator.java:70)

at com.mongodb.internal.connection.SaslAuthenticator$1.run(SaslAuthenticator.java:47)

at com.mongodb.internal.connection.SaslAuthenticator.doAsSubject(SaslAuthenticator.java:179)

at com.mongodb.internal.connection.SaslAuthenticator.authenticate(SaslAuthenticator.java:47)

at com.mongodb.internal.connection.InternalStreamConnectionInitializer.authenticateAll(InternalStreamConnectionInitializer.java:151)

at com.mongodb.internal.connection.InternalStreamConnectionInitializer.initialize(InternalStreamConnectionInitializer.java:64)

at com.mongodb.internal.connection.InternalStreamConnection.open(InternalStreamConnection.java:127)

at com.mongodb.internal.connection.UsageTrackingInternalConnection.open(UsageTrackingInternalConnection.java:50)

at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.open(DefaultConnectionPool.java:390)

at com.mongodb.internal.connection.DefaultConnectionPool.get(DefaultConnectionPool.java:106)

at com.mongodb.internal.connection.DefaultConnectionPool.get(DefaultConnectionPool.java:92)

at com.mongodb.internal.connection.DefaultServer.getConnection(DefaultServer.java:85)

at com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.getConnection(ClusterBinding.java:114)

at com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:460)

at com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:406)

at com.mongodb.operation.FindOperation.execute(FindOperation.java:695)

at com.mongodb.operation.FindOperation.execute(FindOperation.java:83)

at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:179)

at com.mongodb.client.internal.MongoIterableImpl.execute(MongoIterableImpl.java:132)

at com.mongodb.client.internal.MongoIterableImpl.iterator(MongoIterableImpl.java:86)

at crmz_data_migration.mongotest_0_1.MONGOTEST.tMongoDBInput_1Process(MONGOTEST.java:1103)

at crmz_data_migration.mongotest_0_1.MONGOTEST.runJobInTOS(MONGOTEST.java:1780)

at crmz_data_migration.mongotest_0_1.MONGOTEST.main(MONGOTEST.java:1617)

Caused by: com.mongodb.MongoCommandException: Command failed with error 18 (AuthenticationFailed): 'Authentication failed.' on server uat.amtrust.asia:27017. The full response is { "ok" : 0.0, "errmsg" : "Authentication failed.", "code" : 18, "codeName" : "AuthenticationFailed" }

at com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:179)

at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:293)

at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:255)

at com.mongodb.internal.connection.CommandHelper.sendAndReceive(CommandHelper.java:83)

at com.mongodb.internal.connection.CommandHelper.executeCommand(CommandHelper.java:33)

at com.mongodb.internal.connection.SaslAuthenticator.sendSaslContinue(SaslAuthenticator.java:134)

at com.mongodb.internal.connection.SaslAuthenticator.access$200(SaslAuthenticator.java:40)

at com.mongodb.internal.connection.SaslAuthenticator$1.run(SaslAuthenticator.java:67)

... 22 more

[

[Anonymous]

Hello,

Could you please clarify what's talend bigdata product you are using?

Best regards

Sabrina