[ https://issues.apache.org/jira/browse/KAFKA-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16763155#comment-16763155 ]
Bill Bejeck edited comment on KAFKA-7905 at 2/7/19 11:07 PM: ------------------------------------------------------------- Hi [~agrrwal], I'm still looking into it. -Can you share your code?- EDIT: I won't need any code, thanks. Thanks, Bill was (Author: bbejeck): Hi [~agrrwal], I'm still looking into it. Can you share your code? Thanks, Bill > KTable Reduce Allow Null value to be pass in Subtractor > ------------------------------------------------------- > > Key: KAFKA-7905 > URL: https://issues.apache.org/jira/browse/KAFKA-7905 > Project: Kafka > Issue Type: Bug > Components: streams > Reporter: HARSHIT AGARWAL > Priority: Major > Attachments: KTableReduceExceptionTrace.txt > > > KTable Reduce Allow Null value to be pass in Subtractor. > .reduce((aggValue, newValue) -> addCounts(aggValue, newValue), > (aggValue, oldValue) -> subtractCounts(*{color:#FF0000}aggValue{color}*, > oldValue)) > *{color:#FF0000}aggValue{color}* passed by *{color:#FF0000}{color}* > org.apache.kafka.streams.kstream.internals.KTableReduce.java is > {color:#FF0000}*null*{color}. > > Please find attached Exception Trace. -- This message was sent by Atlassian JIRA (v7.6.3#76005)