whiver / nifi-protobuf-processor

An Apache NiFi processor to encode and decode data using Google Protocol Buffer schemas.
MIT License
36 stars 20 forks source link

handling of null objects for flow files returned from the session 'get'-method #8

Open tbo-norcom opened 3 years ago

tbo-norcom commented 3 years ago

Hi,

we are using the decoding processor with concurrent tasks. We found that it could happen that several threads try to access the same flowfile concurrently. In this scenario, all threads except one retrieve from the session.get() call a null object instead of a flowfile object. This pull requests handles this case...

Best, Thomas

benyaa commented 2 years ago

It's already in develop