Hi,
I've developed a test where I'm caching a flowfile using
PutDistributedMapCache, then checking for entries using a DeleteDuplicate
processor. I'm finding that the DeleteDuplicate is, in fact, finding the
duplicate, but it's not removing it from the cache.
The problem is the test in DeleteDuplicate on line 189:
if (duplicate && durationMS != null && (now >=
originalCacheValue.getEntryTimeMS() + durationMS)) {
If I dig into the code, originalCacheValue.getEntryTimeMS() doesn't look to
me like it really represents a time value, so the comparison with "now"
always fails. I say that because the cache value seems to be a
serialization of the flowfile.
Maybe I've misunderstood what the doc means when it says "determines if the
cached value has already been seen". Has anyone else had difficulty with
this?
--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/
