I have a question about the states and created values within a
paragraph that uses the Apache Flink interpreter.

If I have the following code:


val v1 = // some Flink processing

val streamEnvironment = senv
(TimeCharacteristic.EventTime) streamEnvironment.setParallelism(1)
val streamTableEnvironment = TableEnvironment.getTableEnvironment


The code above creates a value for the variable v1 and changes the
state of the StremEnvironment.

Is there a possiblility to clear the state and the cached values between
the runs?

Kind regards,

Andre Schütz
COO / Founder - Wegtam GmbH
an...@wegtam.com | P: +49 (0) 381-80 699 041 | M: +49 (0) 176-218 02 604
www.wegtam.com | www.tensei-data.com | www.wegtam.net

Reply via email to