Skip to content

Commit

Permalink
chore: fixed Typo from #5789 (#5790)
Browse files Browse the repository at this point in the history
  • Loading branch information
harlev authored Jul 8, 2020
1 parent 60d5e39 commit 12fd154
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ static void enforceStreamStateDirAvailability(final File streamsStateDir) {
throw new KsqlServerException("Could not create the kafka streams state directory: "
+ streamsStateDir.getPath()
+ "\n Make sure the directory exists and is writable for KSQL server "
+ "\n or its parend directory is writbale by KSQL server"
+ "\n or its parent directory is writable by KSQL server"
+ "\n or change it to a writable directory by setting '"
+ KsqlConfig.KSQL_STREAMS_PREFIX + StreamsConfig.STATE_DIR_CONFIG
+ "' config in the properties file."
Expand All @@ -126,7 +126,7 @@ static void enforceStreamStateDirAvailability(final File streamsStateDir) {
throw new KsqlServerException(streamsStateDir.getPath()
+ " is not a directory."
+ "\n Make sure the directory exists and is writable for KSQL server "
+ "\n or its parend directory is writbale by KSQL server"
+ "\n or its parent directory is writable by KSQL server"
+ "\n or change it to a writable directory by setting '"
+ KsqlConfig.KSQL_STREAMS_PREFIX + StreamsConfig.STATE_DIR_CONFIG
+ "' config in the properties file."
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ public void shouldFailIfStreamsStateDirectoryCannotBeCreated() {
assertThat(e.getMessage(), containsString(
"Could not create the kafka streams state directory: /var/lib/kafka-streams\n"
+ " Make sure the directory exists and is writable for KSQL server \n"
+ " or its parend directory is writbale by KSQL server\n"
+ " or its parent directory is writable by KSQL server\n"
+ " or change it to a writable directory by setting 'ksql.streams.state.dir' config in"
+ " the properties file."));
}
Expand All @@ -126,7 +126,7 @@ public void shouldFailIfStreamsStateDirectoryIsNotDirectory() {
assertThat(e.getMessage(), containsString(
"/var/lib/kafka-streams is not a directory.\n"
+ " Make sure the directory exists and is writable for KSQL server \n"
+ " or its parend directory is writbale by KSQL server\n"
+ " or its parent directory is writable by KSQL server\n"
+ " or change it to a writable directory by setting 'ksql.streams.state.dir' config in"
+ " the properties file."));
}
Expand Down Expand Up @@ -168,4 +168,4 @@ public void shouldFailIfStreamsStateDirectoryIsNotExacutable() {
+ " or change it to a writable directory by setting 'ksql.streams.state.dir' "
+ "config in the properties file."));
}
}
}

0 comments on commit 12fd154

Please sign in to comment.