[jira] [Commented] (FLINK-11443) Recovering from save point error after adding "sum (constant)"

["Timo Walther (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-11443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16754779#comment-16754779 ] 

Timo Walther commented on FLINK-11443:
--------------------------------------

[~tivan] Changing SQL queries is not supported so far. If a query is changed, the optimizer might chose a different plan such that Flink's internal state can not be mapped anymore. This is a complex problem that won't be solved in the near future. We recommend to built up the state from scratch (maybe in parallel to the old query) and then perform a switch to the new query once the new job is up to date.

>  Recovering from save point error after adding "sum (constant)"
> ---------------------------------------------------------------
>
>                 Key: FLINK-11443
>                 URL: https://issues.apache.org/jira/browse/FLINK-11443
>             Project: Flink
>          Issue Type: Bug
>          Components: Table API & SQL
>    Affects Versions: 1.6.2, 1.6.3
>            Reporter: tivanli
>            Priority: Minor
>
> h3. Resuming from savepoint error when I add a "sum (2)" column to flink sql .
>  
> {code:java}
> org.apache.flink.util.StateMigrationException: State migration is currently not supported.
> 	at org.apache.flink.util.StateMigrationException.notSupported(StateMigrationException.java:42)
> 	at org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo.resolveKvStateCompatibility(RegisteredKeyValueStateBackendMetaInfo.java:212)
> 	at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.tryRegisterKvStateInformation(RocksDBKeyedStateBackend.java:1336)
> 	at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.createInternalState(RocksDBKeyedStateBackend.java:1391)
> 	at org.apache.flink.runtime.state.KeyedStateFactory.createInternalState(KeyedStateFactory.java:47)
> 	at org.apache.flink.runtime.state.ttl.TtlStateFactory.createStateAndWrapWithTtlIfEnabled(TtlStateFactory.java:63)
> 	at org.apache.flink.runtime.state.AbstractKeyedStateBackend.getOrCreateKeyedState(AbstractKeyedStateBackend.java:238)
> 	at org.apache.flink.streaming.api.operators.AbstractStreamOperator.getOrCreateKeyedState(AbstractStreamOperator.java:562)
> 	at org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.open(WindowOperator.java:240)
> 	at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:424)
> 	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:290)
> 	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
> 	at java.lang.Thread.run(Thread.java:748)
> {code}
>  Originally running sql：
> {code:java}
> SELECT TUMBLE_START(rowtime, INTERVAL '1' minute) as dtEventTime,
> word,
> sum(frequency) as frequency
> FROM test
> GROUP BY word,
> TUMBLE(rowtime, INTERVAL '1' minute)
> {code}
>  Modify sql to increase sum function
> {code:java}
> SELECT TUMBLE_START(rowtime, INTERVAL '1' minute) as dtEventTime,
> word,
> sum(frequency) as frequency,
> sum(2) as s2
> FROM test
> GROUP BY word,
> TUMBLE(rowtime, INTERVAL '1' minute)
> {code}
>  
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)