LookupRecord using Attribute

[Thomas P.]

Hello community,

I am trying to query a MongoDB using LookupRecord which works fine when I
read the values directly from the json flow file.
But when I try to query the MongoService using an attribute, I don't find
the expected document.

Here is my nifi 1.6 setup:

json flow file:
{
  "code": "A1234",
  "authority": "MyAuthority",
  "descriptions": [
    {
      "language": "EN",
      "description": "Nifi rocks!"
    }
  ]
}

avro schema:
{
  "type" : "record",
  "name" : "MyClass",
  "namespace" : "com.test.avro",
  "fields" : [ {
    "name" : "code",
    "type" : "string"
  }, {
    "name" : "authority",
    "type" : "string"
  }, {
    "name" : "descriptions",
    "type" : {
      "type" : "array",
      "items" : {
        "type" : "record",
        "name" : "descriptions",
        "fields" : [ {
          "name" : "language",
          "type" : "string"
        }, {
          "name" : "description",
          "type" : "string"
        } ]
      }
    }
  } ]
}

two documents in mongo:
{
    "_id" : ObjectId("5b07db234fad446628118dde"),
    "code" : "A1234",
    "authority" : "MyAuthority",
    "descriptions" : [
        {
            "language" : "EN",
            "description" : "Nifi rocks!"
        }
    ]
}

{
    "_id" : ObjectId("5b07db374fad446628118e10"),
    "code" : "A1234",
    "authority" : "AnotherAuthority",
    "descriptions" : [
        {
            "language" : "EN",
            "description" : "Nifi still rocks!"
        }
    ]
}



​


Now I try to query MongoDB using a value from an attribute but it never
matches.
The attribute 'authority' is set via UpdateAttribute and contains value
"MyAuthority".


​
​
How can I query my document using attribute?


Thomas
​