Unfortunately, setting the parallelism per SQL operator is not supported
right now.
We are currently thinking about a way of having fine-grained control
about properties of SQL operators but this is in an early design phase
and might take a while
Am 04.12.18 um 13:05 schrieb clay4444:
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/