I have a data flow where I want read data from HDFS and write it to the hive table.
My data flow:
1. GetHDFS
2. Split text ( split the file by 1 line, as each line is valid json string)
3. splitjson ( to read the requird josn object, in my case its is gyrodata)
4. evaluatejson ( to select the requird attributes from gyrodata json object)
Next step have done after following the this answer ( here)
5.update attribute ( where i am setting the values for "hiveql.args.N.type" and "hiveql.args.N.value") as shown below
![16171-updateattribute.png 16171-updateattribute.png](https://community.cloudera.com/t5/image/serverpage/image-id/17271i63541700CF985A75/image-size/medium?v=v2&px=400)
6.replacetext processor to write the insert statement
"INSERT INTO TABLE gyroscope PARTITION(carbox_id ='Carboxtest') VALUES( ?, ?, ?, ?, ?,?, ?, ?);"
I tried the insert statement ending with semicolumn and without semicolumn but same error 😞
![16172-replacetext.png 16172-replacetext.png](https://community.cloudera.com/t5/image/serverpage/image-id/17272iB4E1D9B120B4C38E/image-size/medium?v=v2&px=400)
7. puthiveql processor with below error ':
![16173-error.png 16173-error.png](https://community.cloudera.com/t5/image/serverpage/image-id/17273iDB2B46E8763CA470/image-size/medium?v=v2&px=400)
please find below my complete flow :
![16174-completeflow.png 16174-completeflow.png](https://community.cloudera.com/t5/image/serverpage/image-id/17274i55F87FB5804EA238/image-size/medium?v=v2&px=400)