flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sihua Zhou (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async
Date Mon, 30 Apr 2018 16:52:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Sihua Zhou updated FLINK-9269:
------------------------------
    Priority: Major  (was: Blocker)

> Concurrency problem in HeapKeyedStateBackend when performing checkpoint async
> -----------------------------------------------------------------------------
>
>                 Key: FLINK-9269
>                 URL: https://issues.apache.org/jira/browse/FLINK-9269
>             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.5.0
>
>
> {code:java}
> @Nonnull
> @Override
> protected SnapshotResult<KeyedStateHandle> performOperation() throws Exception
{
>     // do something
>    long[] keyGroupRangeOffsets = new long[keyGroupRange.getNumberOfKeyGroups()];
>    for (int keyGroupPos = 0; keyGroupPos < keyGroupRange.getNumberOfKeyGroups(); ++keyGroupPos)
{
>       int keyGroupId = keyGroupRange.getKeyGroupId(keyGroupPos);
>       keyGroupRangeOffsets[keyGroupPos] = localStream.getPos();
>       outView.writeInt(keyGroupId);
>       for (Map.Entry<String, StateTable<K, ?, ?>> kvState : stateTables.entrySet())
{
>         // do something
>       }
>     }
>     // do something
> }
> {code}



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

Mime
View raw message