Hi Thomas, This is Hai who works on portable runner for Samza. I have a few minor question that I would like to get clarification on from you.
We chatted briefly at last beam meetup and you mention your flink portable runner (Python) is going into production. So today are you using Beam Python on Flink in streaming mode or batch mode? And what are you input sources (Kafka? Kinesis?) Also we talked about how bundling would help lift the perf by a lot. But it seems like flink runner today only does bundling in batch mode, not in streaming mode. Am I missing something? BTW, looking forward to the Beam @Lyft meetup in February! Thanks, Hai (LinkedIn)