Member since
05-05-2019
1
Post
0
Kudos Received
0
Solutions
05-06-2019
09:20 PM
Hello, I'm trying to load the data from a sql server DB to another sql server DB. Please find the flow below. ExecuteSQL -> ConvertAvroToJSON -> ReplaceText -> ConvertJSONToSQL -> PutSQL I'm having the issue in the ConvertJSONToSQL processor. Please find the log below. Can you please help me how to fix it. ConvertJSONToSQL[id=xxxx] Failed to convert StandardFlowFileRecord[uuid=xxxx,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1556828161853-12488, container=default, section=200], offset=596441, length=1116],offset=0,name=11007398837232637,size=1116] to a SQL INSERT statement due to org.apache.nifi.processor.exception.ProcessException: None of the fields in the JSON map to the columns defined by the dbo.xxxx table; routing to failure: org.apache.nifi.processor.exception.ProcessException: None of the fields in the JSON map to the columns defined by the dbo.SITE_TYP table ConvertJSONToSQL properties Sample Json [{"TYP_ID": 1, "TYP_NM": "JERY"}] Target DDL CREATE TABLE dbo.xxxx( TYP_ID intIDENTITY(1,1), TYP_NM varchar(256)NOT NULL, DEL_FLG char(1)DEFAULT 'N' NOT NULL, CRT_DTM datetimeDEFAULT GETDATE() NOT NULL, UPDT_USER_ID varchar(11)DEFAULT CURRENT_USER NOT NULL, UPDT_DTM datetimeDEFAULT GETDATE() NOT NULL, CONSTRAINT PK_TYP PRIMARY KEY CLUSTERED (TYP_ID) )
... View more
Labels:
- Labels:
-
Apache NiFi