[FLINK-3210] Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run()

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Later
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 08/Jan/16 17:09
• Updated: 06/Feb/16 13:58
• Resolved: 06/Feb/16 13:58

Description

Here is related code:

                byte[] valueBytes;
                if (payload == null) {
                  deletedMessages++;
                  valueBytes = null;
                } else {
...
                final T value = deserializer.deserialize(keyBytes, valueBytes, fp.topic, offset);

When valueBytes is null, there is no need to call deserializer#deserialize()