Hi everybody, I have a question about internal optimization is flink able to reuse intermediate result that are used twice in the graph?
i.e. a = readsource -> filter -> reduce -> something else even more complicated b = a filter(something) store b c = a filter(something else) store c what happens to a? is it computed twice? in my read function I have a some logging commands and I see the printed twice, but it sounds strange to me thanks cheers michele
