hi Timo: first very thank u, I have solve the ploblems,
Regarding the problem of too large state, I set the global parallelism to 7 for the program, which solved my problem very well, checkpoint is very fast, but I would like to ask if there is a way to set parallelism for each operator(translated from sql statement) instead of global settings? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/