Skip to content

Commit

Permalink
fix call to sourcedescription
Browse files Browse the repository at this point in the history
  • Loading branch information
jeqo committed Jul 22, 2020
1 parent aeb3984 commit 086c4b0
Showing 1 changed file with 18 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -899,9 +899,24 @@ public void shouldFailToDescribeSourceViaExecuteStatement() {
// Given
final SourceDescriptionEntity entity = new SourceDescriptionEntity(
"describe source;",
new SourceDescription("name", Optional.empty(), Collections.emptyList(), Collections.emptyList(),
Collections.emptyList(), "type", "timestamp", "statistics", "errorStats",
false, "keyFormat", "valueFormat", "topic", 4, 1, "statement"),
new SourceDescription(
"name",
Optional.empty(),
Collections.emptyList(),
Collections.emptyList(),
Collections.emptyList(),
"type",
"timestamp",
"statistics",
"errorStats",
false,
"keyFormat",
"valueFormat",
"topic",
4,
1,
"statement",
Collections.emptyList()),
Collections.emptyList());
testEndpoints.setKsqlEndpointResponse(Collections.singletonList(entity));

Expand Down

0 comments on commit 086c4b0

Please sign in to comment.