With this last settings I was able to terminate the job the second time I retried to run it, without restarting the cluster.. If I don't register the serializer for DateTime the job doesn't start at all (from Flink 1.x you have to register it [1]). I can't understand what's wrong :(
[1] https://cwiki.apache.org/confluence/display/FLINK/Migration+Guide%3A+0.10.x+to+1.0.x Best, Flavio
