Я использую проверочную запись Apache Nifi, используя схемы Avro для вложенного Json.У меня возникают особые проблемы с полями map в JSON.
Схема:
{
"type": "record",
"name": "Test",
"namespace": "test_events",
"fields": [
{
"name": "id",
"type": "string"
},
{
"name": "test_attributes",
"type": {
"type": "record",
"name": "test_attributes.instance",
"fields": [
{
"name": "normal_field",
"type": [
"null",
"string"
]
},
{
"name": "nested_field",
"type": [
"null",
{
"type": "map",
"values": [
"null",
"int"
]
}
]
}
]
}
}
]
}
Данные Json:
{
"id": "aplhanum123",
"test_attributes": {
"normal_field": "normal",
"nested_field": {
"meaning": 42
}
}
}
Сообщение об аннулировании:
Записи в этом FlowFile были недействительны по следующим причинам:;Следующие 1 поля имеют значения, тип которых не соответствует схеме: [/ test_attributes / nested_field]
Я не понимаю это сообщение.Я полагаю, что nested_field в Json является действительным map и поэтому процессор не должен аннулировать его.Чего мне не хватает?
Редактировать: * Удалено } в примере JSON.* Nifi-1.7.1, проверка записи с помощью JsonTreeReader