я новичок в nifi, пытаюсь выполнить массовую вставку в mysql, используя nifi ниже, это моя структура потока образца.
FetchFile ->
ConvertRecord (covert csv to json) ->
SplitJson ->
EvaluateJsonPath ->
routeOnAttribute ->
JoltTransformJson (adding new key value pair) ->
MergeContent (merge all flowfiles) ->
ConvertJsontoSql (converting json to sql) ->
ExecuteSql
здесь executeSql вставляет только одну запись вместо всех записей
mergeContent содержит следующую структуру JSON
{"batch_id":"123","name":"xyz","age":"26"},
{"batch_id":"123","name":"abc","age":"29"},
{"batch_id":"123","name":"fff","age":"30"}
но executeSql вставляет только первый json, все остальные не вставляются. пожалуйста, помогите.
Заранее спасибо