illegalArgumentException MongoDB river

Maarten_Roosendaal · October 22, 2013, 2:26pm

Hi,

I'm attempting to use the MongoDB river for elasticsearch but i get a:

[2013-10-22 16:10:44,911][WARN ][river ] [node1] failed
to create river [mongodb][river-mongodb]
java.lang.IllegalArgumentException
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1310)
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1198)
at
java.util.concurrent.Executors.newFixedThreadPool(Executors.java:89)
at
com.mongodb.DynamicConnectionStatus.start(DynamicConnectionStatus.java:44)
at com.mongodb.DBTCPConnector.start(DBTCPConnector.java:52)
at com.mongodb.Mongo.(Mongo.java:337)
at com.mongodb.MongoClient.(MongoClient.java:253)
at com.mongodb.MongoClient.(MongoClient.java:230)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getMongoClient(MongoDBRiver.java:563)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getAdminDb(MongoDBRiver.java:516)
at
org.elasticsearch.river.mongodb.MongoDBRiver.isMongos(MongoDBRiver.java:494)
at
org.elasticsearch.river.mongodb.MongoDBRiver.start(MongoDBRiver.java:461)
at
org.elasticsearch.river.RiversService.createRiver(RiversService.java:146)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:270)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:264)
at
org.elasticsearch.action.support.TransportAction$ThreadedActionListener$1.run(TransportAction.java:87)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:722)

My config:
{
"type": "mongodb",
"mongodb": {
"servers": {
"host": "host",
"port": "27017"
},
"db": "catalog",
"collection": "products"
},
"index": {
"name": "testmongo",
"type": "product"
}
}

versions:
ES: 90.1
MongoDB-river: 1.6.8
MongoDB: 2.4.3

Any suggestions?

Thanks,
Maarten

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

Hendrik · October 23, 2013, 11:38am

seems "servers" need to be an array (with bracktes):

"type": "mongodb",
"mongodb": {
"servers":
[
{ "host": "host1", "port": 27017 },
{ "host": "host2", "port": 27017 }
], ...

Am Dienstag, 22. Oktober 2013 16:26:24 UTC+2 schrieb Maarten Roosendaal:

Hi,

I'm attempting to use the MongoDB river for elasticsearch but i get a:

[2013-10-22 16:10:44,911][WARN ][river ] [node1] failed
to create river [mongodb][river-mongodb]
java.lang.IllegalArgumentException
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1310)
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1198)
at
java.util.concurrent.Executors.newFixedThreadPool(Executors.java:89)
at
com.mongodb.DynamicConnectionStatus.start(DynamicConnectionStatus.java:44)
at com.mongodb.DBTCPConnector.start(DBTCPConnector.java:52)
at com.mongodb.Mongo.(Mongo.java:337)
at com.mongodb.MongoClient.(MongoClient.java:253)
at com.mongodb.MongoClient.(MongoClient.java:230)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getMongoClient(MongoDBRiver.java:563)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getAdminDb(MongoDBRiver.java:516)
at
org.elasticsearch.river.mongodb.MongoDBRiver.isMongos(MongoDBRiver.java:494)
at
org.elasticsearch.river.mongodb.MongoDBRiver.start(MongoDBRiver.java:461)
at
org.elasticsearch.river.RiversService.createRiver(RiversService.java:146)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:270)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:264)
at
org.elasticsearch.action.support.TransportAction$ThreadedActionListener$1.run(TransportAction.java:87)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:722)

My config:
{
"type": "mongodb",
"mongodb": {
"servers": {
"host": "host",
"port": "27017"
},
"db": "catalog",
"collection": "products"
},
"index": {
"name": "testmongo",
"type": "product"
}
}

versions:
ES: 90.1
MongoDB-river: 1.6.8
MongoDB: 2.4.3

Any suggestions?

Thanks,
Maarten

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

Maarten_Roosendaal · October 24, 2013, 8:19am

Thanks, that solved 1 problem, now i get a:
com.mongodb.CommandFailureException: { "serverUsed" : "#####/ip:port" ,
"code" : 18 , "ok" : 0.0 , "errmsg" : "auth fails"}

i assume the user is somehow not authorized to acces the database. Do you
need to have both a local and an admin user?

[
  { "db": "local", "user": ${mongo.local.user}, "password": ${mongo.local.password} },
  { "db": "admin", "user": ${mongo.db.user}, "password": ${mongo.db.password} }
],

Op woensdag 23 oktober 2013 13:38:12 UTC+2 schreef Hendrik:

seems "servers" need to be an array (with bracktes):

"type": "mongodb",
"mongodb": {
"servers":
[
{ "host": "host1", "port": 27017 },
{ "host": "host2", "port": 27017 }
], ...

Am Dienstag, 22. Oktober 2013 16:26:24 UTC+2 schrieb Maarten Roosendaal:

Hi,

I'm attempting to use the MongoDB river for elasticsearch but i get a:

[2013-10-22 16:10:44,911][WARN ][river ] [node1]
failed to create river [mongodb][river-mongodb]
java.lang.IllegalArgumentException
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1310)
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1198)
at
java.util.concurrent.Executors.newFixedThreadPool(Executors.java:89)
at
com.mongodb.DynamicConnectionStatus.start(DynamicConnectionStatus.java:44)
at com.mongodb.DBTCPConnector.start(DBTCPConnector.java:52)
at com.mongodb.Mongo.(Mongo.java:337)
at com.mongodb.MongoClient.(MongoClient.java:253)
at com.mongodb.MongoClient.(MongoClient.java:230)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getMongoClient(MongoDBRiver.java:563)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getAdminDb(MongoDBRiver.java:516)
at
org.elasticsearch.river.mongodb.MongoDBRiver.isMongos(MongoDBRiver.java:494)
at
org.elasticsearch.river.mongodb.MongoDBRiver.start(MongoDBRiver.java:461)
at
org.elasticsearch.river.RiversService.createRiver(RiversService.java:146)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:270)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:264)
at
org.elasticsearch.action.support.TransportAction$ThreadedActionListener$1.run(TransportAction.java:87)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:722)

My config:
{
"type": "mongodb",
"mongodb": {
"servers": {
"host": "host",
"port": "27017"
},
"db": "catalog",
"collection": "products"
},
"index": {
"name": "testmongo",
"type": "product"
}
}

versions:
ES: 90.1
MongoDB-river: 1.6.8
MongoDB: 2.4.3

Any suggestions?

Thanks,
Maarten

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

Maarten_Roosendaal · October 24, 2013, 9:35am

i have a MongoDB user with which i can connect, through robomongo, to the
mongodb cluster and to a collection aka content. However when i use this
information for the mongodb-river i either get:

com.mongodb.MongoException: not authorized for query on
local.system.namespaces or
com.mongodb.CommandFailureException: { "serverUsed" : "#####/ip:port" ,
"code" : 18 , "ok" : 0.0 , "errmsg" : "auth fails"}
depending on using 'local' or 'content' for the 'db' part op credentials

I've upgrade to ES 90.3, 1.7.0 plugin, we are using MongoDB version 2.4.5

Op donderdag 24 oktober 2013 10:19:21 UTC+2 schreef Maarten Roosendaal:

Thanks, that solved 1 problem, now i get a:
com.mongodb.CommandFailureException: { "serverUsed" : "#####/ip:port" ,
"code" : 18 , "ok" : 0.0 , "errmsg" : "auth fails"}

i assume the user is somehow not authorized to acces the database. Do you
need to have both a local and an admin user?
[
  { "db": "local", "user": ${mongo.local.user}, "password": ${mongo.local.password} },
  { "db": "admin", "user": ${mongo.db.user}, "password": ${mongo.db.password} }
],
Op woensdag 23 oktober 2013 13:38:12 UTC+2 schreef Hendrik:

seems "servers" need to be an array (with bracktes):

"type": "mongodb",
"mongodb": {
"servers":
[
{ "host": "host1", "port": 27017 },
{ "host": "host2", "port": 27017 }
], ...

Am Dienstag, 22. Oktober 2013 16:26:24 UTC+2 schrieb Maarten Roosendaal:

Hi,

I'm attempting to use the MongoDB river for elasticsearch but i get a:

[2013-10-22 16:10:44,911][WARN ][river ] [node1]
failed to create river [mongodb][river-mongodb]
java.lang.IllegalArgumentException
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1310)
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1198)
at
java.util.concurrent.Executors.newFixedThreadPool(Executors.java:89)
at
com.mongodb.DynamicConnectionStatus.start(DynamicConnectionStatus.java:44)
at com.mongodb.DBTCPConnector.start(DBTCPConnector.java:52)
at com.mongodb.Mongo.(Mongo.java:337)
at com.mongodb.MongoClient.(MongoClient.java:253)
at com.mongodb.MongoClient.(MongoClient.java:230)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getMongoClient(MongoDBRiver.java:563)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getAdminDb(MongoDBRiver.java:516)
at
org.elasticsearch.river.mongodb.MongoDBRiver.isMongos(MongoDBRiver.java:494)
at
org.elasticsearch.river.mongodb.MongoDBRiver.start(MongoDBRiver.java:461)
at
org.elasticsearch.river.RiversService.createRiver(RiversService.java:146)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:270)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:264)
at
org.elasticsearch.action.support.TransportAction$ThreadedActionListener$1.run(TransportAction.java:87)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:722)

My config:
{
"type": "mongodb",
"mongodb": {
"servers": {
"host": "host",
"port": "27017"
},
"db": "catalog",
"collection": "products"
},
"index": {
"name": "testmongo",
"type": "product"
}
}

versions:
ES: 90.1
MongoDB-river: 1.6.8
MongoDB: 2.4.3

Any suggestions?

Thanks,
Maarten

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

dave_padovano · March 4, 2015, 8:04pm

Id love to know if you found a solve for this. I am experiencing the same
issue.

On Thursday, October 24, 2013 at 5:35:57 AM UTC-4, Maarten Roosendaal wrote:

i have a MongoDB user with which i can connect, through robomongo, to the
mongodb cluster and to a collection aka content. However when i use this
information for the mongodb-river i either get:

com.mongodb.MongoException: not authorized for query on
local.system.namespaces or

com.mongodb.CommandFailureException: { "serverUsed" : "#####/ip:port" ,
"code" : 18 , "ok" : 0.0 , "errmsg" : "auth fails"}
depending on using 'local' or 'content' for the 'db' part op credentials

I've upgrade to ES 90.3, 1.7.0 plugin, we are using MongoDB version 2.4.5

Op donderdag 24 oktober 2013 10:19:21 UTC+2 schreef Maarten Roosendaal:
Thanks, that solved 1 problem, now i get a:
com.mongodb.CommandFailureException: { "serverUsed" : "#####/ip:port" ,
"code" : 18 , "ok" : 0.0 , "errmsg" : "auth fails"}

i assume the user is somehow not authorized to acces the database. Do you
need to have both a local and an admin user?
[
  { "db": "local", "user": ${mongo.local.user}, "password": ${mongo.local.password} },
  { "db": "admin", "user": ${mongo.db.user}, "password": ${mongo.db.password} }
],
Op woensdag 23 oktober 2013 13:38:12 UTC+2 schreef Hendrik:

seems "servers" need to be an array (with bracktes):

"type": "mongodb",
"mongodb": {
"servers":
[
{ "host": "host1", "port": 27017 },
{ "host": "host2", "port": 27017 }
], ...

Am Dienstag, 22. Oktober 2013 16:26:24 UTC+2 schrieb Maarten Roosendaal:

Hi,

I'm attempting to use the MongoDB river for elasticsearch but i get a:

[2013-10-22 16:10:44,911][WARN ][river ] [node1]
failed to create river [mongodb][river-mongodb]
java.lang.IllegalArgumentException
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1310)
at
java.util.concurrent.ThreadPoolExecutor.(ThreadPoolExecutor.java:1198)
at
java.util.concurrent.Executors.newFixedThreadPool(Executors.java:89)
at
com.mongodb.DynamicConnectionStatus.start(DynamicConnectionStatus.java:44)
at com.mongodb.DBTCPConnector.start(DBTCPConnector.java:52)
at com.mongodb.Mongo.(Mongo.java:337)
at com.mongodb.MongoClient.(MongoClient.java:253)
at com.mongodb.MongoClient.(MongoClient.java:230)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getMongoClient(MongoDBRiver.java:563)
at
org.elasticsearch.river.mongodb.MongoDBRiver.getAdminDb(MongoDBRiver.java:516)
at
org.elasticsearch.river.mongodb.MongoDBRiver.isMongos(MongoDBRiver.java:494)
at
org.elasticsearch.river.mongodb.MongoDBRiver.start(MongoDBRiver.java:461)
at
org.elasticsearch.river.RiversService.createRiver(RiversService.java:146)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:270)
at
org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:264)
at
org.elasticsearch.action.support.TransportAction$ThreadedActionListener$1.run(TransportAction.java:87)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:722)

My config:
{
"type": "mongodb",
"mongodb": {
"servers": {
"host": "host",
"port": "27017"
},
"db": "catalog",
"collection": "products"
},
"index": {
"name": "testmongo",
"type": "product"
}
}

versions:
ES: 90.1
MongoDB-river: 1.6.8
MongoDB: 2.4.3

Any suggestions?

Thanks,
Maarten

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/de8af3f9-b4d0-4f6e-8a34-4cd880ff294f%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.