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

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

tivanli created FLINK-11443:
-------------------------------

             Summary:  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.3, 1.6.2
            Reporter: tivanli


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}
 
{code:java}
--old sql
SELECT TUMBLE_START(rowtime, INTERVAL '1' minute) as dtEventTime,
word,
sum(frequency) as frequency
FROM test
GROUP BY word,
TUMBLE(rowtime, INTERVAL '1' minute)
--------------------------------------------------------
--new sql
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)