"describe database" and "describe extended database" --> displaying same information hive > create database if not exists practice comment "This database was created for practice purpose" location '/home/abc/Sample' with dbproperties('Date'='2018-07-15','createdby'='Developer','Email'='developer@dev.com'); OK Time taken: 0.018 seconds hive> describe database practice; OK practice hdfs://abcdhdfs/apps/hive/warehouse/practice.db abc USER Time taken: 0.122 seconds, Fetched: 1 row(s) hive> describe database extended practice; OK practice hdfs://abcdhdfs/apps/hive/warehouse/practice.db abc USER Time taken: 0.123 seconds, Fetched: 1 row(s) ... View more

I am new to NIFI learning how each processor works.... I am trying to generate CSV file extracting some from Database, following are sequence of processors i am using to achive this ExecuteSQL -> Execute a simple query (select empno,name,deptno,age,sal from emp limit 1 ) -- Working perfectly fine UpdateAttribute -> Added a new property "schema.name"= emp -- Working perfectly fine Convert Record -> Getting Error here RecordReader - AVROReader RecordWriter - CSVRecordSetWriter AVROSchemaRegistry: { "name":"emp", "namespace":"nifi", "type":"record", "fields": [ {"name": "empno" , "type":"int"}, {"name": "name", "type":"string"}, {"name": "deptno", "type":"int"}, {"name": "age", "type":"int"}, {"name": "sal", "type":"float"} ] } Data In Queue before failure processor: [ { "empno" : 10, "name" : "abcadefshnz", "deptno" : 100, "age" : 20, "sal" : 12700.5 } ] ErrorMessage : failed to process session due to org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -51; Processor Administratively Yielded for 1 sec: org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -51 org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -51 Thanks in advance... ... View more