NiFi: как оформить запрос в процессоре QueryRecord - PullRequest
Новая
       8

NiFi: как оформить запрос в процессоре QueryRecord

0 голосов
/ 01 апреля 2019

я использую NiFi 1.9.

ниже приведены примеры данных: 

DATETIME,bC_kWh_nt02.DLG,bC_kWh_nt03.DLGbC_kWh_nt04.DLG
25-10-2018 00:00,3499440,1962246.375,0.49
25-10-2018 00:01,3499440,1962246.375,0.49
25-10-2018 00:02,3499440,1962246.376,0.49
25-10-2018 00:03,3499440,1962246.378,0.49

я хочу создать отдельный поток для (DATETIME, bC_kWh_nt02.DLG) и (DATETIME, bC_kWh_nt03).DLG) и (DATETIME, bC_kWh_nt04.DLG)

для этого случая, я использую QueryRecord, как упомянуто ниже: 

RecordReader: CsvReader
RecordWriter: CsvWriter
attr1: select DATETIME,bC_kWh_nt02.DLG from FLOWFILE
attr2: select DATETIME,bC_kWh_nt03.DLG from FLOWFILE
attr3: select DATETIME,bC_kWh_nt04.DLG from FLOWFILE

CSVReader: стратегия доступа к схеме: пробовал "InferSchema" и"Строковые поля из заголовка" 

i am getting below error while starting QueryRecord:
2019-04-01 14:37:14,904 ERROR [Timer-Driven Process Thread-8] o.a.nifi.processors.standard.QueryRecord QueryRecord[id=ebef1551-3ded-1dc9-64ba-e91df232dee1] Unable to query StandardFlowFileRecord[uuid=ee53d147-3351-4a31-b96f-35c0c4ad2820,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1554091065466-9, container=default, section=9], offset=1642, length=564],offset=0,name=SMR_RAW_1_20181025.csv,size=564] due to org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Error while preparing statement [SELECT DATETIME, aC_kWh_mt02.DLG 
FROM FLOWFILE]: org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Error while preparing statement [SELECT DATETIME, aC_kWh_mt02.DLG 
FROM FLOWFILE]
org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Error while preparing statement [SELECT DATETIME, aC_kWh_mt02.DLG 
FROM FLOWFILE]

заранее спасибо.

...