You are viewing a plain text version of this content. The canonical link for it is here.

---

- Unit testing stateful DoFn - posted by Tudor Plugaru <tu...@gorgias.com> on 2021/12/01 09:06:58 UTC, 5 replies.
- Re: Deployment difficulties with Python apps on Kubernetes Flink cluster - posted by Janek Bevendorff <ja...@uni-weimar.de> on 2021/12/02 13:22:59 UTC, 3 replies.
- ImportError: __import__ not found on python job - posted by Steve Niemitz <sn...@apache.org> on 2021/12/08 02:57:57 UTC, 5 replies.
- Fwd: Kafka manually commit offsets - posted by Juan Calvo Ferrándiz <ju...@gmail.com> on 2021/12/09 23:35:50 UTC, 9 replies.
- using FileIO to read a single input file - posted by Randal Moore <rd...@gmail.com> on 2021/12/13 23:47:32 UTC, 0 replies.
- Re: Beam program with Flink runner which can limit number of records processed in specified time when reading from Kafka - posted by Siyu Lin <si...@unity3d.com> on 2021/12/15 19:51:39 UTC, 0 replies.
- How to use avro serializer in Kafka write? - posted by "Gunasekara, Anjana" <An...@syscolabs.com> on 2021/12/17 02:24:57 UTC, 4 replies.
- Partially OT: upgrading Dataflow SDK version - posted by Sofia’s World <mm...@gmail.com> on 2021/12/17 14:27:25 UTC, 0 replies.
- Does JavaBeanUtils.getGetters work with List