Member since
05-14-2018
4
Posts
0
Kudos Received
0
Solutions
12-05-2018
07:49 AM
Hi I have a SQL query being used in multiple ExecuteSQL processor. Currently using both custom property file as well as registry variable to store SQL query. Which option is better to proceed with? Is there any other approach than these two? Thanks in advance.
... View more
Labels:
- Labels:
-
Apache NiFi
12-05-2018
07:39 AM
The error got resolved after adding missing processor "SplitAvro". The new flow looks like ExecuteSQL --> SplitAvro --> PutDatabasRecord
... View more
10-26-2018
12:28 PM
Thanks for the reply Matt. "Translate Field Names" property was set to false. Even after setting this property to true same issue. Also removed "namespace":"dbo" from the schema and tried. Still getting same error. Below is my sample avro: Objavro.schema¾{"type":"record","name":"NiFi_ExecuteSQL_Record","namespace":"any.data","fields":[{"name":"EmpID","type":["null","long"]},{"name":"FName","type":["null","string"]},{"name":"LName","type":["null","string"]},{"name":"DOB","type":["null","string"]},{"name":"DOJ","type":["null","string"]}]} äD¡ÅÚç.‚ÿ‘“¬1nLQTÐJohn Smith1956-10-032018-06-17äD¡ÅÚç.‚ÿ‘“¬1nLQ
... View more
10-25-2018
12:28 PM
Currently working on NiFi flow which reads a table from DB1(SQL Server1) using ExecuteSQL and put records in DB2(SQL Server2) using PutDatabasRecord processor. I'm getting error "None of the fields in the record map to the columns defined by the dbo.Employee table" while running the flow. NiFi version : 1.7.1 SQL table schema: CREATE TABLE dbo.Employee
(
EmpID bigint,
FName nvarchar(100),
LName nvarchar(100),
DOB date,
DOJ date
) ExecuteSQL property "Use Avro Logical Types" : false PutDatabasRecord property "Record Reader" : AvroReader AvroReader property "Schema Access Strategy" : Use 'Schema Text' Property Schema Text: {"type":"record","name":"Employee","namespace":"dbo","fields":[{"name":"EmpID","type":["null","long"]},{"name":"FName","type":["null","string"]},{"name":"LName","type":["null","string"]},{"name":"DOB","type":["null","string"]},{"name":"DOJ","type":["null","string"]}]} Please help me! Thanks in advance.
... View more
Labels:
- Labels:
-
Apache NiFi