Hi flink users,
I just wanted to ask if this kind of scala map function is correct?
object JsonMapper {
private val mapper: ObjectMapper = new ObjectMapper()
}
class JsonMapper extends MapFunction[String, ObjectNode] {
override def map(value: String): ObjectNode =
JsonMapper.mapper.readValu
Hi Peter,
I'm no Scala developer but I may be able to help with some concepts:
* a static reference used inside a [Map]Function will certainly cause problems
when executed in parallel in the same JVM, e.g. a TaskManager with multiple
slots, depending on whether this static object is stateful and
I think your snippet looks good. The Jackson ObjectMapper is designed to
be reused by numerous threads, and routinely stored as a static field. It
is somewhat expensive to create.
Hope this helps,
-Eron
On Thu, Aug 3, 2017 at 7:46 AM, Nico Kruber wrote:
> Hi Peter,
> I'm no Scala developer bu
