I have not specified any parallelism in the job code. So I guess, the parallelism should be set to parallelism.default defined in the flinkConfig.yaml.
An update: The TMs were on different machines and I was using FsStateBackend with state backend directories pointing to instance specific file paths. After using MemoryStateBackend instead of FsStateBackend , the issue seems to be resolved. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
