As shown in https://ci.apache.org/projects/flink/flink-docs-master/dev/scala_api_extensions.html ,we can use scala partitial function by
import org.apache.flink.streaming.api.scala.extensions._ and replace .map by .mapWith. but the signature of def mapWith[R: TypeInformation](fun: T => R): DataStream[R] and def map[R: TypeInformation](fun: T => R): DataStream[R] are exactly the same. So how the different behavior happens? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
