[
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)
