[KAFKA-10152] Attempt to write checkpoint without first committing during recycle

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 2.6.0
• Component/s: streams
• Assignee: A. Sophie Blee-Goldman
• Reporter: A. Sophie Blee-Goldman
• Created: 11/Jun/20 19:24
• Updated: 13/Jun/20 02:06
• Resolved: 13/Jun/20 02:06

Description

Seen causing failure of `SmokeTestDirverIntegrationTest#shouldWorkWithRebalance locally:

Caused by: java.lang.IllegalStateException: A checkpoint should only be written if no commit is needed. at org.apache.kafka.streams.processor.internals.StreamTask.writeCheckpointIfNeed(StreamTask.java:534) at org.apache.kafka.streams.processor.internals.StreamTask.closeAndRecycleState(StreamTask.java:482) at org.apache.kafka.streams.processor.internals.StandbyTaskCreator.createStandbyTaskFromActive(StandbyTaskCreator.java:115) at org.apache.kafka.streams.processor.internals.TaskManager.handleAssignment(TaskManager.java:288)

See comment here: https://github.com/apache/kafka/pull/8833/files#r438953766

Issue Links

• duplicates: KAFKA-10150 IllegalStateException when revoking task in CREATED state
• links to: Github Pull Request #8856