Hi Julio,
thanks for this great example. I could reproduce it on my machine and I
could find the problem.
You need to store the newly created branch of your pipeline in some
variable like `val test = pipeline.process()` in order to access the
side outputs via `test.getSideOutput(outputSimple
Hey Timo,
To be completely honest, I _think_ they are POJO, although I use case
classes (because I want our data to be immutable).
I wrote a sample code, which basically reflects our pipeline:
https://github.com/jbiason/FlinkSample/blob/master/src/main/scala/net/juliobiason/SideoutputSample.scala
Hi Julio,
I tried to reproduce your problem locally but everything run correctly.
Could you share a little example job with us?
This worked for me:
class TestingClass {
var hello:Int =0 }
class TestAextends TestingClass {
var test:String = _
}
def main(args: Array[String]) {
// set u
