kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jeyhun Karimov <je.kari...@gmail.com>
Subject Reduce function Null checks
Date Sun, 19 Jun 2016 12:46:54 GMT
Hi community,

When using, reduce(Reducer,Reducer, KeyValueMapper,String) function in
KTable, the NullPointerExeption is thrown. In specified function, below
call is made:

        return reduce(adder, subtractor, selector, null, null, name);

and afterwards, in reduce(Reducer,Reducer,
KeyValueMapper,Serde,Serde,String) function, the exception is thrown while
creating ChangedSerializer. I think null checks should be added to escape
the exception.



  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message