Hi Shu, I got the same error after adding split avro in between querydatabasetable and update attribute . Is it not possible with a single avro file I know it works fine with individual small flow files. ... View more

@Parth Karkhanis Your PutHDFS file should add an attribute to the flow file called ${hive.ddl}. You should be able to use this DDL statement to create the hive table. Work with it manually until you get the syntax correct. In my working example, I send PutHdfs to ReplaceText where I append ${hive.ddl} with ${hive.ddl} LOCATION '/user/nifi/${folderName}/${tableName}/' tblproperties ("orc.compress" = "SNAPPY") Then I send that to PutHiveQL Processor. If this answer helps, please choose ACCEPT. ... View more

You can try the processor I've implemented https://github.com/javajefe/nifi-redis-pubsub-bundle Any feedback is appreciated ... View more