Encode the test url

confluentinc · Dec 23, 2024 · dd790e6 · dd790e6
1 parent 600b73d
commit dd790e6
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/...db-rest-app/src/test/java/io/confluent/ksql/rest/integration/RestIntegrationTestUtil.java b/...db-rest-app/src/test/java/io/confluent/ksql/rest/integration/RestIntegrationTestUtil.java
@@ -65,6 +65,7 @@
 import io.vertx.ext.web.client.WebClientOptions;
 import io.vertx.ext.web.codec.BodyCodec;
 import java.net.URI;
+import java.net.URLEncoder;
 import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.Base64;
@@ -567,7 +568,7 @@ public static List<String> makeWsRequest(
     try {
       httpClient = vertx.createHttpClient();
 
-      final String uri = baseUri.toString() + "/ws/query?request="
+      final String uri = URLEncoder.encode(baseUri.toString() + "/ws/query?request="
           + buildStreamingRequest(sql, overrides, requestProperties)
           + "&access_token=" + credentials.get().getAuthHeader().replace(" ", "%20");
 

diff --git a/ksqldb-serde/src/test/java/io/confluent/ksql/serde/avro/KsqlAvroDeserializerTest.java b/ksqldb-serde/src/test/java/io/confluent/ksql/serde/avro/KsqlAvroDeserializerTest.java
@@ -23,7 +23,8 @@
 import static org.hamcrest.Matchers.is;
 import static org.hamcrest.Matchers.not;
 import static org.hamcrest.Matchers.nullValue;
-import static org.junit.Assert.*;
+import static org.junit.Assert.assertThrows;
+import static org.junit.Assert.fail;
 import static org.junit.internal.matchers.ThrowableMessageMatcher.hasMessage;
 
 import com.google.common.collect.ImmutableList;

diff --git a/ksqldb-serde/src/test/java/io/confluent/ksql/serde/avro/KsqlAvroSerializerTest.java b/ksqldb-serde/src/test/java/io/confluent/ksql/serde/avro/KsqlAvroSerializerTest.java
@@ -33,7 +33,8 @@
 import static org.hamcrest.Matchers.is;
 import static org.hamcrest.Matchers.not;
 import static org.hamcrest.Matchers.nullValue;
-import static org.junit.Assert.*;
+import static org.junit.Assert.assertThrows;
+import static org.junit.Assert.fail;
 import static org.junit.internal.matchers.ThrowableMessageMatcher.hasMessage;
 
 import com.google.common.collect.ImmutableList;
@@ -986,6 +987,7 @@ public void shouldSerializeMapOfStruct() {
         ImmutableMap.of(new Utf8("k"), avroOrder),
         MAP_VALUE_ORDER_AVRO_SCHEMA
     );
+
     final GenericArray<?> actual = deserialize(bytes);
     assertThat(actual, is(expected));
   }