Could you provide a little reproducible example? Which file system are
you using? This sounds like a bug to me that should be fixed if valid.
Am 03.04.18 um 11:28 schrieb dhirajpraj:
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/
