java.lang.String to org.apache.flink.api.java.tuple.Tuple2<java.lang.String, java.lang.String>