About srinivaspadala_

srinivaspadala_ · ‎10-18-2016

The same upsert command I am executing in phoenix console , its working . but from putSql, it is throwing above error. Thanks

srinivaspadala_ · ‎10-18-2016

phoenix-upsert-error.pngNifi putsql is working fine ,suddenly i am getting Row length exception for Phoenix Upsert . There is no junk data , there is no syntax error also . ERROR : PUTSQL failed to process due to java.lang.illegalArgumentException; Row length 43125 > 32767 . i observed that leftside(32767) values is constant . PFA

srinivaspadala_ · ‎10-15-2016

what is this expression languauge : $.[?(@.a...] , is it jave regex ? how can we use 2 values filter OR or AND for content filed ?? like a==1 or a==2 .

srinivaspadala_ · ‎10-14-2016

thank you . is it possible add 2 condition for content like a=='1 ' or a=='2' (or) a=='1' and i=='ss' . Thanks in advance

srinivaspadala_ · ‎10-14-2016

1. we are using UPSERT commad only in phoenix . 2. even i am unable insert 100/sec 3 . PFA of PutSQL configuration I am getting 10,000 records per second . but i am able to insert only 20-50 records per second . queue is not getting piled up , looks data loss is happening . please let me know how to improve performace .atleadt 1000/sec as said. and how to debug/test whether the data loss is happening or not . thanks in advance .

srinivaspadala_ · ‎10-13-2016

Nifi - putsql for phoenix upsert very slow , getting records 1000/sec , phoenix putsql is unabel toinsert it seems . Please let us know how to improve phoenix insertion fast .

srinivaspadala_ · ‎10-13-2016

my one processor output is a flow file which contains text lines , each line is having semicolunm , i would like to split each line into mulitple lines . input flow file : hi how ; are you i am good; how about you output flow file : hi how are you i am good how about yoy

srinivaspadala_ · ‎10-13-2016

Is there any Nifi processor to route mulitple json arrays(by splitting json array based on field/attribute condition) to multiple processor based on json field condition . ex : assume [{a:1},{a:1},{a:2},{a:2}] is jsonarray , there is a requiremnt to route a=1 contained json files are send to another processor as array . and a=2 json array to another processor

srinivaspadala_ · ‎10-13-2016

Is there any Nifi processor available to split avro file into multiple avro files based on condition ,means avro is array of json files and schema , ex : col1 ,col2, col3 .. are fields of my JSON/avro schema. my requirement is to divide avro based on col1 values . if col1 is having a, b, c values , i would like to route a set of json files to another processor as one avro file, b set to another processor ...etc ).

srinivaspadala_ · ‎10-01-2016

Is it a hbase coprocessor ?? Could you please provide full example for the above code and how to run . thanks

Online	Offline
Last Visited	‎10-23-2017 12:05 PM

Member Since	‎09-28-2016 10:04 PM
Last Visited	‎10-23-2017 12:05 PM
Posts	59
Kudos received	15

Cloudera Community

Re: Nifi - PutSQL Row length exception for Phoenix...

Nifi - PutSQL Row length exception for Phoenix Ups...

Re: Nifi processor - route json array into multipl...

Re: Nifi processor - route json array into multipl...

Re: Nifi - putsql for phoenix upsert very slow - i...

Nifi - putsql for phoenix upsert very slow - impro...

Nifi- processor to split line into multiple lines ...

Nifi processor - route json array into multiple js...

Nifi - split Avro file based on a filed or conditi...

Re: phoneix seconday index blocking the updates of...