[ https://issues.apache.org/jira/browse/KAFKA-10152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sophie Blee-Goldman reassigned KAFKA-10152: ------------------------------------------- Assignee: Sophie Blee-Goldman > Attempt to write checkpoint without first committing during recycle > ------------------------------------------------------------------- > > Key: KAFKA-10152 > URL: https://issues.apache.org/jira/browse/KAFKA-10152 > Project: Kafka > Issue Type: Bug > Components: streams > Reporter: Sophie Blee-Goldman > Assignee: Sophie Blee-Goldman > Priority: Blocker > Fix For: 2.6.0 > > > Seen causing failure of > `SmokeTestDirverIntegrationTest#shouldWorkWithRebalance locally: > {code:java} > 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) > {code} > See comment here: https://github.com/apache/kafka/pull/8833/files#r438953766 -- This message was sent by Atlassian Jira (v8.3.4#803005)