Hi Fabian, It seems like it didn't work. Let me specify what i have done:
i have a SQL that looks something like: Select a, sum(b), map[ 'sum_c', sum(c), 'sum_d', sum(d)] as my_map FROM... GROUP BY a As you said im preventing keys in the state forever by doing idle state retention time (+ im transforming to retracted stream along with a custom trigger that sends the data to the sink). I tried adding a new item to the map ( say 'sum_e', sum(e) ), cancelled with savepoint and rerun from that savepoint and got the same error as above about state incompatibility. Why do you think would that happen? Thanks Shahar -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
