scala - Runtime Context Links to wrong output type -
it seems processfunction class' context looking flink.util.outputtag output tag it's context.output() function instead of streaming.api.scala.outputtag . , datastream.getsideoutput() looking streaming.api.scala.outputtag sample code of mine: val outputtag = outputtag[(string, long, long)]("output") //stuff .process { new processfunction[(string, long), (string, long, long)] { lazy val state: valuestate[event] = getruntimecontext.getstate(new valuestatedescriptor[event]("stats", classof[event])) override def processelement(value: (string, long), ctx: processfunction[(string, long), (string, long, long)]#context, out: collector[(string, long, long)]) { val current: event = state.value() match { case null => event(value._1, 1, value._2) case event(key, count, total) => event(key, count + 1, totaltos + value._2) } state.update(current) ctx.output(output...