Skip to content

Commit 0617ccb

Browse files
committed
rename tests to exclude stateupdater
1 parent 7a47231 commit 0617ccb

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -921,7 +921,7 @@ public void shouldCreateStandbyTaskDuringAssignment() {
921921
}
922922

923923
@Test
924-
public void shouldAddRecycledStandbyTasksFromActiveToPendingTasksToInitWithStateUpdaterEnabled() {
924+
public void shouldAddRecycledStandbyTasksFromActiveToPendingTasksToInit() {
925925
final StreamTask activeTaskToRecycle = statefulTask(taskId01, taskId01ChangelogPartitions)
926926
.withInputPartitions(taskId01Partitions)
927927
.inState(State.RUNNING).build();
@@ -944,7 +944,7 @@ public void shouldAddRecycledStandbyTasksFromActiveToPendingTasksToInitWithState
944944
}
945945

946946
@Test
947-
public void shouldThrowDuringAssignmentIfStandbyTaskToRecycleIsFoundInTasksRegistryWithStateUpdaterEnabled() {
947+
public void shouldThrowDuringAssignmentIfStandbyTaskToRecycleIsFoundInTasksRegistry() {
948948
final StandbyTask standbyTaskToRecycle = standbyTask(taskId03, taskId03ChangelogPartitions)
949949
.inState(State.RUNNING)
950950
.withInputPartitions(taskId03Partitions).build();
@@ -966,7 +966,7 @@ public void shouldThrowDuringAssignmentIfStandbyTaskToRecycleIsFoundInTasksRegis
966966
}
967967

968968
@Test
969-
public void shouldAssignActiveTaskInTasksRegistryToBeClosedCleanlyWithStateUpdaterEnabled() {
969+
public void shouldAssignActiveTaskInTasksRegistryToBeClosedCleanly() {
970970
final StreamTask activeTaskToClose = statefulTask(taskId03, taskId03ChangelogPartitions)
971971
.inState(State.RUNNING)
972972
.withInputPartitions(taskId03Partitions).build();
@@ -984,7 +984,7 @@ public void shouldAssignActiveTaskInTasksRegistryToBeClosedCleanlyWithStateUpdat
984984
}
985985

986986
@Test
987-
public void shouldThrowDuringAssignmentIfStandbyTaskToCloseIsFoundInTasksRegistryWithStateUpdaterEnabled() {
987+
public void shouldThrowDuringAssignmentIfStandbyTaskToCloseIsFoundInTasksRegistry() {
988988
final StandbyTask standbyTaskToClose = standbyTask(taskId03, taskId03ChangelogPartitions)
989989
.inState(State.RUNNING)
990990
.withInputPartitions(taskId03Partitions).build();
@@ -1003,7 +1003,7 @@ public void shouldThrowDuringAssignmentIfStandbyTaskToCloseIsFoundInTasksRegistr
10031003
}
10041004

10051005
@Test
1006-
public void shouldAssignActiveTaskInTasksRegistryToUpdateInputPartitionsWithStateUpdaterEnabled() {
1006+
public void shouldAssignActiveTaskInTasksRegistryToUpdateInputPartitions() {
10071007
final StreamTask activeTaskToUpdateInputPartitions = statefulTask(taskId03, taskId03ChangelogPartitions)
10081008
.inState(State.RUNNING)
10091009
.withInputPartitions(taskId03Partitions).build();
@@ -1024,7 +1024,7 @@ public void shouldAssignActiveTaskInTasksRegistryToUpdateInputPartitionsWithStat
10241024
}
10251025

10261026
@Test
1027-
public void shouldResumeActiveRunningTaskInTasksRegistryWithStateUpdaterEnabled() {
1027+
public void shouldResumeActiveRunningTaskInTasksRegistry() {
10281028
final StreamTask activeTaskToResume = statefulTask(taskId03, taskId03ChangelogPartitions)
10291029
.inState(State.RUNNING)
10301030
.withInputPartitions(taskId03Partitions).build();
@@ -1063,7 +1063,7 @@ public void shouldResumeActiveSuspendedTaskInTasksRegistryAndAddToStateUpdater()
10631063
}
10641064

10651065
@Test
1066-
public void shouldThrowDuringAssignmentIfStandbyTaskToUpdateInputPartitionsIsFoundInTasksRegistryWithStateUpdaterEnabled() {
1066+
public void shouldThrowDuringAssignmentIfStandbyTaskToUpdateInputPartitionsIsFoundInTasksRegistry() {
10671067
final StandbyTask standbyTaskToUpdateInputPartitions = standbyTask(taskId02, taskId02ChangelogPartitions)
10681068
.inState(State.RUNNING)
10691069
.withInputPartitions(taskId02Partitions).build();
@@ -1086,7 +1086,7 @@ public void shouldThrowDuringAssignmentIfStandbyTaskToUpdateInputPartitionsIsFou
10861086
}
10871087

10881088
@Test
1089-
public void shouldAssignMultipleTasksInTasksRegistryWithStateUpdaterEnabled() {
1089+
public void shouldAssignMultipleTasksInTasksRegistry() {
10901090
final StreamTask activeTaskToClose = statefulTask(taskId03, taskId03ChangelogPartitions)
10911091
.inState(State.RUNNING)
10921092
.withInputPartitions(taskId03Partitions).build();

0 commit comments

Comments
 (0)