Thanks guys,

 using cli param spark.es.nodes fixed problem

but still I think someone should look at engine.json param why it’s not parsing 
properly and causing issues, not sure if it’s related to PIO itself or UR 
engine tho.

Anyway using in train –conf spark.es.nodes=elasticsearch is working while 
engine.json es.nodes=”elasticsearch” throw error as posted in first mail:

org.elasticsearch.index.mapper.MapperParsingException: object mapping for 
[sparkConf.es.nodes] tried to parse field [es.nodes] as object, but found a 
concrete value

Thanks for all Your help guys!
Wojciech

Reply via email to