Interesting question and the only way I can answer it is that it shouldn’t, but
would need more context
Oleg
> On Mar 23, 2016, at 6:27 PM, McDermott, Chris Kevin (MSDU -
> STaTS/StorefrontRemote) wrote:
>
> Thanks, Oleg.
>
> FWIW the traceback seems to correspond to this line in PutKafka.ja
Thanks, Oleg.
FWIW the traceback seems to correspond to this line in PutKafka.java
final byte[] value = new byte[(int) flowFile.getSize()];
Can the flow file size be negative?
On 3/23/16, 6:24 PM, "Oleg Zhurakousky" wrote:
>Chris
>
>Yes we have (can’t remember the details though). There w
Chris
Yes we have (can’t remember the details though). There was a lot of work around
NiFi Kafka support lately and it somewhat culminated today. So. . .
1. We’ve downgraded back to 0.8.2
https://issues.apache.org/jira/browse/NIFI-1629. You can see details in JIRA
2. We’ve done some refactoring
2016-03-23 21:29:22,383 ERROR [Timer-Driven Process Thread-5]
o.apache.nifi.processors.kafka.PutKafka
PutKafka[id=f66e4092-946e-3338-93d6-7ea3a56bfd20]
PutKafka[id=f66e4092-946e-3338-93d6-7ea3a56bfd20] failed to process session due
to java.lang.NegativeArraySizeException: java.lang.NegativeArra
