Skip to content

Commit

Permalink
test: stop RQTT runs from clashing (#5426)
Browse files Browse the repository at this point in the history
Ensures each RQTT run uses a unique state directory, otherwise parallel runs can interfere with each other.

Co-authored-by: Andy Coates <big-andy-coates@users.noreply.github.com>
  • Loading branch information
big-andy-coates and big-andy-coates committed May 20, 2020
1 parent f13be88 commit 0189e0a
Showing 1 changed file with 5 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.google.common.collect.ImmutableList;
import io.confluent.common.utils.TestUtils;
import io.confluent.ksql.integration.IntegrationTestHarness;
import io.confluent.ksql.integration.Retry;
import io.confluent.ksql.rest.server.TestKsqlRestApp;
Expand Down Expand Up @@ -71,6 +72,10 @@ public class RestQueryTranslationTest {

private static final TestKsqlRestApp REST_APP = TestKsqlRestApp
.builder(TEST_HARNESS::kafkaBootstrapServers)
.withProperty(
KsqlConfig.KSQL_STREAMS_PREFIX + StreamsConfig.STATE_DIR_CONFIG,
TestUtils.tempDirectory().getPath()
)
.withProperty(KsqlConfig.KSQL_STREAMS_PREFIX + StreamsConfig.NUM_STREAM_THREADS_CONFIG, 1)
.withStaticServiceContext(TEST_HARNESS::getServiceContext)
.build();
Expand Down

0 comments on commit 0189e0a

Please sign in to comment.