You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/05/16 12:54:00 UTC
[jira] [Closed] (FLINK-9174) The type of state created in
ProccessWindowFunction.proccess() is inconsistency
[ https://issues.apache.org/jira/browse/FLINK-9174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek closed FLINK-9174.
-----------------------------------
Resolution: Fixed
Fix Version/s: (was: 1.5.0)
1.5.1
1.6.0
release-1.5:
4365dcb0acc1b079981d09a0e9ab04ce8e74aa84
master:
63740e7c51800599d6d4d77bb7762600df2bad88
> The type of state created in ProccessWindowFunction.proccess() is inconsistency
> -------------------------------------------------------------------------------
>
> Key: FLINK-9174
> URL: https://issues.apache.org/jira/browse/FLINK-9174
> Project: Flink
> Issue Type: Bug
> Components: State Backends, Checkpointing
> Affects Versions: 1.5.0
> Reporter: Sihua Zhou
> Assignee: Sihua Zhou
> Priority: Major
> Fix For: 1.6.0, 1.5.1
>
>
> The type of state created from windowState and globalState in {{ProcessWindowFunction.process()}} is inconsistency. For detail,
> {code}
> context.windowState().getListState(); // return type is HeapListState or RocksDBListState
> context.globalState().getListState(); // return type is UserFacingListState
> {code}
> This cause the problem in the following code,
> {code}
> Iterable<T> iterableState = listState.get();
> if (terableState.iterator().hasNext()) {
> for (T value : iterableState) {
> value.setRetracting(true);
> collector.collect(value);
> }
> state.clear();
> }
> {code}
> If the {{listState}} is created from {{context.globalState()}} is fine, but when it created from {{context.windowState()}} this will cause NPE. I met this in 1.3.2 but I found it also affect 1.5.0.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)