Hi, 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: [code] %flink val v1 = // some Flink processing val streamEnvironment = senv streamEnvironment.setStreamTimeCharacteristic (TimeCharacteristic.EventTime) streamEnvironment.setParallelism(1) val streamTableEnvironment = TableEnvironment.getTableEnvironment (streamEnvironment) [/code] 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 -- 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
