OriginalCompleteBefore	OriginalCompleteAfter	Before	After	Project	Commit	CompilationUnit	LineNos	Names	TemplateVariableToCodeBefore	RelevantImports	TemplateVariableToCodeAfter	isRelevant	isSafe
FlinkKafkaProducerBase<Row> kafkaProducer=createKafkaProducer(topic,properties,serializationSchema,partitioner);	SinkFunction<Row> kafkaProducer=createKafkaProducer(topic,properties,serializationSchema.orElseThrow(() -> new IllegalStateException(STR0)),partitioner);	serializationSchema	serializationSchema.orElseThrow(() -> new IllegalStateException(STR0))	flink	57b3cde863922094be4f395063317e42349aedb3	org.apache.flink.streaming.connectors.kafka.KafkaTableSink	_1 45 _2 60	_1 serializationSchema _2 serializationSchema	TCIVar serializationSchema		TCIVar serializationSchema	Uses	False