[
https://issues.apache.org/jira/browse/STORM-3043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cedric Le Roux updated STORM-3043:
----------------------------------
Description:
When using a SimpleRecordTranslator with a user-defined translator Func, a
NullPointerException will be thrown if Func.apply() returns null. A null List
object is a valid return value from apply() if the ConsumerRecord is invalid.
SimpleRecordTranslator does not check for a null result before attempting to
call the addAll method of the List.
was:
When using a SimpleRecordTranslator (or ByTopicRecordTranslator which extends
it) with a user-defined translator Func, a NullPointerException will be thrown
if Func.apply() returns null. A null List object is a valid return value from
apply() if the ConsumerRecord is invalid.
SimpleRecordTranslator does not check for a null result before attempting to
call the addAll method of the List.
> NullPointerException thrown in SimpleRecordTranslator.apply()
> -------------------------------------------------------------
>
> Key: STORM-3043
> URL: https://issues.apache.org/jira/browse/STORM-3043
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-kafka-client
> Reporter: Cedric Le Roux
> Priority: Major
> Labels: pull-request-available
>
> When using a SimpleRecordTranslator with a user-defined translator Func, a
> NullPointerException will be thrown if Func.apply() returns null. A null List
> object is a valid return value from apply() if the ConsumerRecord is invalid.
> SimpleRecordTranslator does not check for a null result before attempting to
> call the addAll method of the List.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
