This message was deleted.
# troubleshooting
s
This message was deleted.
d
Sounds like you've ended up with a race condition. Perhaps you've done something non-deterministic. There are various things that can cause this.
m
Flink support Scala 2.12.7, not Scala 2.12.8 as that is binary incompatible due to Scala making a breaking change. I'm guessing that can cause some unexpected issues
k
I think Scala support is externalized from Flink. I remember reading somewhere here that Scala wrappers for Flink API are separate project and community for those is rather not that active. I also remember reading that Java is more recommended than Scala. You can use Scala, but if you encounter an issue, the community support can be limited.
d