ableegoldman commented on a change in pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#discussion_r439606939
##########
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java
##########
@@ -952,58 +951,11 @@ public void
shouldNotCommitOnHandleAssignmentIfOnlyStandbyTaskClosed() {
}
@Test
- public void shouldCleanupAnyTasksClosedAsDirtyAfterCommitException() {
Review comment:
This was a test I added a little while back in response to a bugfix, but
it no longer makes sense in the current context (in fact it's currently not
really testing anything at all, since the original point was to make sure the
changelog reader partitions were cleaned up but that's not even the
responsibility of the TaskManager anymore)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
