OriginalCompleteBefore	OriginalCompleteAfter	Before	After	Project	Commit	CompilationUnit	LineNos	Names	TemplateVariableToCodeBefore	RelevantImports	TemplateVariableToCodeAfter	isRelevant	isSafe
arity = ((Tuple)record).getArity()	data = SerializationUtils.getSerializer(record).serialize(record)	((Tuple)record).getArity()	SerializationUtils.getSerializer(record).serialize(record)	flink	ab8470714715cb02b32e3299f36ea64ebe85695e	org.apache.flink.python.api.streaming.plan.PythonPlanSender	_1 55 _2 32	_1 arity _2 data	xyz ((Tuple)record).getArity()	org.apache.flink.python.api.streaming.util.SerializationUtils	xyz SerializationUtils.getSerializer(record).serialize(record)	AssignedTo	True