Skip to content

KAFKA-9742: Fix StandbyTaskEOSIntegrationTest End offset#8329

Closed
abbccdda wants to merge 1 commit intoapache:trunkfrom
abbccdda:KAFKA-9742
Closed

KAFKA-9742: Fix StandbyTaskEOSIntegrationTest End offset#8329
abbccdda wants to merge 1 commit intoapache:trunkfrom
abbccdda:KAFKA-9742

Conversation

@abbccdda
Copy link
Copy Markdown

The StandbyTaskEOSIntegrationTest was broken due to the incorrect offset setting in the checkpoint file enforced by 6cf27c9. The fix is to set the offset to a legitimate value even if the topic doesn't exist.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@vvcephei
Copy link
Copy Markdown
Contributor

test this please

@guozhangwang
Copy link
Copy Markdown
Contributor

LGTM.

@mjsax mjsax added streams tests Test fixes (including flaky tests) labels Mar 23, 2020

new OffsetCheckpoint(new File(stateDirectory.directoryForTask(taskId), ".checkpoint"))
.write(Collections.singletonMap(new TopicPartition("unknown-topic", 0), 5L));
.write(Collections.singletonMap(new TopicPartition("unknown-topic", 0), 0L));
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

this offset is added deliberately so as to make task corrupted.

@chia7712
Copy link
Copy Markdown
Member

seems #8330 is going to fix this flaky.

@abbccdda abbccdda closed this Mar 23, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

streams tests Test fixes (including flaky tests)

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants