Hi, Flinkspector is indeed a good choice to circumvent this problem as it specifically has several mechanisms to deal with these synchronization problems. Unfortunately, I'm still looking for a reasonable solution to support checking of scala types. Maybe I will provide a version in which you can use all the functionality except the custom validation logic. This could be done relatively quickly.
Cheers, Alex -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Writing-test-for-Flink-streaming-jobs-tp7213p7247.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
