flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stefan Richter (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-6690) Rescaling broken
Date Tue, 23 May 2017 19:21:04 GMT

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

Stefan Richter commented on FLINK-6690:
---------------------------------------

I have found the cause in a bug that was introduced as part of the serializer backwards compatibility
story. Reverting ~4 lines fixes the problem. I will publish the fix tomorrow.

> Rescaling broken
> ----------------
>
>                 Key: FLINK-6690
>                 URL: https://issues.apache.org/jira/browse/FLINK-6690
>             Project: Flink
>          Issue Type: Bug
>          Components: State Backends, Checkpointing
>    Affects Versions: 1.3.0, 1.4.0
>            Reporter: Chesnay Schepler
>            Assignee: Stefan Richter
>            Priority: Blocker
>
> Rescaling appears to be broken for both 1.3 and 1.4. WHen i tried it out i got the following
exception:
> {code}
> java.lang.IllegalStateException: Could not initialize keyed state backend.       at org.apache.flink.streaming.api.operators.AbstractStreamOperator.initKeyedState(AbstractStreamOperator.java:321)
      at org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:217)
      at org.apache.flink.streaming.runtime.tasks.StreamTask.initializeOperators(StreamTask.java:675)
      at org.apache.flink.streaming.runtime.tasks.StreamTask.initializeState(StreamTask.java:662)
      at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:251) 
     at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702)       at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0       at java.util.ArrayList.rangeCheck(ArrayList.java:635)
      at java.util.ArrayList.get(ArrayList.java:411)       at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend$RocksDBFullRestoreOperation.restoreKVStateData(RocksDBKeyedStateBackend.java:1183)
      at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend$RocksDBFullRestoreOperation.restoreKeyGroupsInStateHandle(RocksDBKeyedStateBackend.java:1089)
      at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend$RocksDBFullRestoreOperation.doRestore(RocksDBKeyedStateBackend.java:1070)
      at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.restore(RocksDBKeyedStateBackend.java:957)
      at org.apache.flink.streaming.runtime.tasks.StreamTask.createKeyedStateBackend(StreamTask.java:771)
      at org.apache.flink.streaming.api.operators.AbstractStreamOperator.initKeyedState(AbstractStreamOperator.java:311)
      ... 6 more
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message