postgresql - Error with jdbc-river -

-

i'm trying load data elasticsearch jdbc-river, , i'm getting error. can tell me what's going on?

org.elasticsearch.index.mapper.mapperparsingexception: object mapping [foo] tried parse object, got eof, has concrete value been provided it?     @ org.elasticsearch.index.mapper.object.objectmapper.parse(objectmapper.java:467)     @ org.elasticsearch.index.mapper.documentmapper.parse(documentmapper.java:515)     @ org.elasticsearch.index.mapper.documentmapper.parse(documentmapper.java:462)     @ org.elasticsearch.index.shard.service.internalindexshard.preparecreate(internalindexshard.java:371)     @ org.elasticsearch.action.bulk.transportshardbulkaction.shardindexoperation(transportshardbulkaction.java:400)     @ org.elasticsearch.action.bulk.transportshardbulkaction.shardoperationonprimary(transportshardbulkaction.java:153)     @ org.elasticsearch.action.support.replication.transportshardreplicationoperationaction$asyncshardoperationaction.performonprimary(transportshardreplicationoperationaction.java:556)     @ org.elasticsearch.action.support.replication.transportshardreplicationoperationaction$asyncshardoperationaction$1.run(transportshardreplicationoperationaction.java:426)     @ java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor.java:1145)     @ java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor.java:615)     @ java.lang.thread.run(thread.java:744) [2014-03-19 22:06:06,672][info ][org.xbib.elasticsearch.river.jdbc.strategy.simple.simplerivermouth] bulk [11790] success [100 items] [15ms]

here river definition:

curl -xput 'localhost:9200/_river/my_river/_meta' -d '{               "type" : "jdbc"               , "jdbc" : {                     "url": "jdbc:postgresql://domainname.com:5432/myapp"                     , "user": "user"                     , "password": "passwd"                     , "sql": "select * foo"                     , "index": "myapp"                     , "type": "foo"                     }               }'

there no elasticsearch mapping yet. perhaps that's problem. understanding maps automatically, i'm willing add mapping if necessary.

postgres table schema ("datatype", "is_nullable"):

"integer";"yes" "boolean";"no" "boolean";"yes" "character varying";"no" "timestamp time zone";"yes" "text";"yes" "boolean";"no" "integer";"yes" "integer";"yes" "numeric";"yes" "text";"yes" "integer";"yes" "numeric";"yes" "numeric";"yes" "numeric";"yes" "character varying";"yes" "character varying";"yes" "date";"yes" "numeric";"yes" "numeric";"yes" "numeric";"yes" "character varying";"yes" "character varying";"yes" "character varying";"yes" "character varying";"yes" "boolean";"yes" "integer";"yes" "character varying";"yes" "timestamp time zone";"no" "timestamp time zone";"no" "boolean";"yes" "integer";"yes" "character varying";"yes" "numeric";"yes" "integer";"yes" "character varying";"yes" "character varying";"yes" "integer";"yes" "integer";"no" "integer";"no"

i ended not using river. used elasticsearch api through python client post documents elasticsearch application server (our application python). works good. used python's multiprocessing features improve load times 20 processes. it's loading 28,000 documents in couple minutes.

i hope helps!


Comments

Post a Comment

Popular posts from this blog

java - WrongTypeOfReturnValue exception thrown when unit testing using mockito -

-
my test list<person> mylist; @test public void testisvalidperson() { mylist = new arraylist<person>(); mylist.add(new person("tom")); when(persondao.get(person)).thenreturn(mylist); when((persondao.get(person)).isempty()).thenreturn(false);//------exception thrown boolean result = service.isvalid("tom"); assertfalse(result); } method tested: public boolean isvalid(string person){ persondao = new persondao(); person personobj = new person(person); return (persondao.get(person).isempty())?false : true; } exception thrown: org.mockito.exceptions.misusing.wrongtypeofreturnvalue: boolean cannot returned get() get() should return list *** if you're unsure why you're getting above error read on. due nature of syntax above problem might occur because: 1. exception *might* occur in wrongly written multi-threaded tests. please refer mockito faq on limitations of concurrency testing. 2. sp
Read more

php - Magento - Deleted Base url key -

-
i working on cleaning url: http://mydomain.com/shop/shop/deals i going through settings in configuration tab in admin panel on magento , change secure , unsecure base urls remove first base url "shop" web page read: http://mydomain.com/shop/deals so changed unsecure base urls mydomain.com/shop mydomain.com , secure 12.345.67.89/shop 12.345.67.89. wrong thing do. i cannot reload page or admin console. how access these files through ftp , change correctly there?? when make changes in admin panel changes made in database not in file. have make changes in database. 1.go database , select core_config_data table under table find web/unsecure/base_url , web/secure/base_url . make changes here. don't forget clear cache in var/cache folder
Read more

android - How to disable Button if EditText is empty ? -

-
i have edittext , button in application. when button clicked,the text entered in edittext added listview. i want disable button if edittext empty.how ? this code button click imagebutton imb=(imagebutton)findviewbyid(r.id.btn_send); imb.setonclicklistener(new onclicklistener() { @override public void onclick(view arg0) { edittext et = (edittext)findviewbyid(r.id.edittext1); string str = et.gettext().tostring(); web1.add(str); toast.maketext(shoutsingleprogram.this, "you entered...."+str, toast.length_short).show(); adapter1.notifydatasetchanged(); et.settext(""); } }); } how can ? edittext1.addtextchangedlistener(new textwatcher() { @override public void ontextchanged(charsequence s, int start, int before, in
Read more