Member since
02-23-2018
6
Posts
0
Kudos Received
0
Solutions
02-27-2018
02:49 PM
@Shu I am unable to see Schema Access Strategy --->Inherit Record Schema. In my query just I am extracting the MAX(CREATE_DATE) from one table and want store it in file schemaaccessstrategy.png Today posted one more question , kindly help.. https://community.hortonworks.com/questions/175820/i-want-to-give-where-condition-in-querydatabasetab.html
... View more
02-26-2018
02:41 PM
@Shu I used ConvertRecord processor but getting below error My FlowFile has the following start structure.
Obj^A^B^Vavro.schema<8a>^B{"type":"record","name":"customer_crm_summary","namespace":"any.data","fields":[{"name":"device_tac_code","type":["null","string"]}]}
I would think this seems all ok but the the AvroReader fails with the Exception below SchemaNotFoundException avroreader.pngcsvrecordsetwriter.png Please help.
... View more
02-23-2018
11:45 AM
Hi All, I want to store the output of a query to one text file but getting the Error and data is in orc format. Example: [ixdi@wplcd-dse1 AP_POC]$ more ap_poc_track_maxdate.txt Objavro.schema▒{"type":"record","name":"NiFi_ExecuteSQL_Record","namespace":"any.data","fields":[{"name":"MAX_CREATE_DATE","type":["null","string"]}]}racle.sql.TIMEMP@75ee4c11E▒E▒K▒X▒▒W▒\7 [ixdi@wplcd-dse1 AP_POC]$ more ap_data_track_load_ts.orc Objavro.schema▒{"type":"record","name":"NiFi_ExecuteSQL_Record","namespace":"any.data","fields":[{"name":"MAX_CREATE_DATE","type":["null","string"]}]}oracle.sql.TIMAMP@5490a008▒<=<q▒s▒H=IQc▒ One more thing I want to know is How Notify Processor will work? It will notify to continue next processor once upstream processor success or it will process the data of upstream connection. Please help me to resolve this. Thank you in Advance. Regards, Jyoti
... View more
Labels:
- Labels:
-
Apache Hadoop