[FLINK-1676] enableForceKryo() is not working as expected

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Pending Closed
• Affects Version/s: 0.9
• Fix Version/s: 0.9
• Assignee: Robert Metzger
• Reporter: Robert Metzger
• Created: 10/Mar/15 15:12
• Updated: 28/Feb/19 14:29
• Resolved: 12/May/15 08:35

Description

I my Flink job, I've set the following execution config

final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
env.getConfig().disableObjectReuse();
env.getConfig().enableForceKryo();

Setting a breakpoint in the PojoSerializer() constructor, you'll see that we still serialize data with the POJO serializer.