You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/10/01 07:17:03 UTC
[jira] [Updated] (FLINK-24436)
FsStateChangelogWriter#lastAppendedSequenceNumber return different seq
number with no writes
[ https://issues.apache.org/jira/browse/FLINK-24436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yuan Mei updated FLINK-24436:
-----------------------------
Description:
{{{code}}}
{{2157 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=-1 844 bytes}}
{{2163 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=8 17 bytes}}
{{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 0}}
{{2163 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=3 17 bytes}}
{{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 1}}
{{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 2}}
{{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 2}}
{{2163 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=3 17 bytes}}
{{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 2}}
{{2163 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=5 17 bytes}}
{{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 3}}
{{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 4}}
{{2164 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 4}}
{{{code}}}
> FsStateChangelogWriter#lastAppendedSequenceNumber return different seq number with no writes
> --------------------------------------------------------------------------------------------
>
> Key: FLINK-24436
> URL: https://issues.apache.org/jira/browse/FLINK-24436
> Project: Flink
> Issue Type: Bug
> Reporter: Yuan Mei
> Priority: Major
>
> {{{code}}}
> {{2157 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=-1 844 bytes}}
> {{2163 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=8 17 bytes}}
> {{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 0}}
> {{2163 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=3 17 bytes}}
> {{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 1}}
> {{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 2}}
> {{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 2}}
> {{2163 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=3 17 bytes}}
> {{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 2}}
> {{2163 [main] INFO org.apache.flink.changelog.fs.FsStateChangelogWriter [] - append to 00000000-0000-0000-0000-000000000000: keyGroup=5 17 bytes}}
> {{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 3}}
> {{2163 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 4}}
> {{2164 [main] INFO org.apache.flink.state.changelog.ChangelogStateBackendTestUtils [] - direct append, last appended to 4}}
> {{{code}}}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)