changed collections.emptyMap (#4966)

confluentinc · Apr 1, 2020 · a8468b8 · a8468b8
1 parent 86a17a9
commit a8468b8
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/ksqldb-rest-client/src/main/java/io/confluent/ksql/rest/client/KsqlTarget.java b/ksqldb-rest-client/src/main/java/io/confluent/ksql/rest/client/KsqlTarget.java
@@ -149,12 +149,12 @@ public RestResponse<KsqlEntityList> postKsqlRequest(
 
   public RestResponse<List<StreamedRow>> postQueryRequest(
       final String ksql,
-      final Map<String, ?> serverProperties,
+      final Map<String, ?> requestProperties,
       final Optional<Long> previousCommandSeqNum
   ) {
     return post(
         QUERY_PATH,
-        createKsqlRequest(ksql, Collections.emptyMap(), previousCommandSeqNum),
+        createKsqlRequest(ksql, requestProperties, previousCommandSeqNum),
         KsqlTarget::toRows
     );
   }
@@ -176,13 +176,13 @@ public RestResponse<StreamPublisher<String>> postPrintTopicRequest(
 
   private KsqlRequest createKsqlRequest(
       final String ksql,
-      final Map<String, ?> serverProperties,
+      final Map<String, ?> requestProperties,
       final Optional<Long> previousCommandSeqNum
   ) {
     return new KsqlRequest(
         ksql,
         localProperties.toMap(),
-        serverProperties,
+        requestProperties,
         previousCommandSeqNum.orElse(null)
     );
   }