Hi everyone! I'm very new to Kotlin, and I'm trying to port some of our work on apache beam to kotlin. Most things work fine but some issues with certain Apache Beam-methods and classes are a bit tricky. Following the walkthrough on
https://beam.apache.org/get-started/wordcount-example/ I can run the code until the flatmap function. There it complains about a java.lang.NullPointerException: null value in entry: InputT=null. The same code runs fine in Java. Using IntelliJ but it doesn't translate correctly apparently. Is there some way to circumvent these issues? Thanks