Skip to content

Commit

Permalink
remove my changes
Browse files Browse the repository at this point in the history
  • Loading branch information
@vpapavas
vpapavas committed Sep 23, 2020
1 parent db65dcd commit ae22c04
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions ...b-rest-app/src/test/java/io/confluent/ksql/rest/server/computation/CommandRunnerTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -165,9 +165,9 @@ public void shouldRunThePriorCommandsCorrectly() {

// Then:
final InOrder inOrder = inOrder(statementExecutor);
inOrder.verify(statementExecutor).handleRestore(queuedCommand1);
inOrder.verify(statementExecutor).handleRestore(queuedCommand2);
inOrder.verify(statementExecutor).handleRestore(queuedCommand3);
inOrder.verify(statementExecutor).handleRestore(eq(queuedCommand1));
inOrder.verify(statementExecutor).handleRestore(eq(queuedCommand2));
inOrder.verify(statementExecutor).handleRestore(eq(queuedCommand3));
}

@Test
Expand Down Expand Up @@ -223,8 +223,8 @@ public void shouldOnlyRestoreCompacted() {

// Then:
final InOrder inOrder = inOrder(statementExecutor);
inOrder.verify(statementExecutor).handleRestore(queuedCommand1);
inOrder.verify(statementExecutor).handleRestore(queuedCommand3);
inOrder.verify(statementExecutor).handleRestore(eq(queuedCommand1));
inOrder.verify(statementExecutor).handleRestore(eq(queuedCommand3));

verify(statementExecutor, never()).handleRestore(queuedCommand2);
}
Expand All @@ -243,8 +243,8 @@ public void shouldProcessPartialListOfCommandsOnDeserializationExceptionInRestor

// Then:
final InOrder inOrder = inOrder(statementExecutor);
inOrder.verify(statementExecutor).handleRestore(queuedCommand1);
inOrder.verify(statementExecutor).handleRestore(queuedCommand2);
inOrder.verify(statementExecutor).handleRestore(eq(queuedCommand1));
inOrder.verify(statementExecutor).handleRestore(eq(queuedCommand2));

assertThat(commandRunner.checkCommandRunnerStatus(), is(CommandRunner.CommandRunnerStatus.DEGRADED));
assertThat(commandRunner.getCommandRunnerDegradedWarning(), is(INCOMPATIBLE_COMMANDS_ERROR_MESSAGE));
Expand Down Expand Up @@ -287,8 +287,8 @@ public void shouldProcessPartialListOfCommandsOnIncompatibleCommandInRestore() {

// Then:
final InOrder inOrder = inOrder(statementExecutor);
inOrder.verify(statementExecutor).handleRestore(queuedCommand1);
inOrder.verify(statementExecutor).handleRestore(queuedCommand2);
inOrder.verify(statementExecutor).handleRestore(eq(queuedCommand1));
inOrder.verify(statementExecutor).handleRestore(eq(queuedCommand2));

assertThat(commandRunner.checkCommandRunnerStatus(), is(CommandRunner.CommandRunnerStatus.DEGRADED));
assertThat(commandRunner.getCommandRunnerDegradedWarning(), is(INCOMPATIBLE_COMMANDS_ERROR_MESSAGE));
Expand Down

0 comments on commit ae22c04

Please sign in to comment.