File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
streams/src/test/java/org/apache/kafka/streams/processor/internals Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1234,7 +1234,7 @@ public void shouldRetryInitializationWithBackoffWhenInitializationFails() {
12341234 }
12351235
12361236 @ Test
1237- public void shouldRethrowRuntimeExceptionInInitTaskWithStateUpdater () {
1237+ public void shouldRethrowRuntimeExceptionInInitTask () {
12381238 final StreamTask task00 = statefulTask (taskId00 , taskId00ChangelogPartitions )
12391239 .withInputPartitions (taskId00Partitions )
12401240 .inState (State .CREATED ).build ();
@@ -1599,7 +1599,7 @@ private TaskManager setUpTransitionToRunningOfRestoredTask(final Set<StreamTask>
15991599 }
16001600
16011601 @ Test
1602- public void shouldReturnCorrectBooleanWhenTryingToCompleteRestorationWithStateUpdater () {
1602+ public void shouldReturnCorrectBooleanWhenTryingToCompleteRestoration () {
16031603 final TaskManager taskManager = setUpTaskManager (ProcessingMode .AT_LEAST_ONCE , null , false );
16041604 when (stateUpdater .restoresActiveTasks ()).thenReturn (false );
16051605 assertTrue (taskManager .checkStateUpdater (time .milliseconds (), noOpResetter ));
You can’t perform that action at this time.
0 commit comments