Remove redundant tcp prefix from controller URI when setting up Pravega

pravega · Sep 26, 2017 · 2fe0e92 · 2fe0e92
1 parent 261ad72
commit 2fe0e92
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/java/io/pravega/connectors/flink/utils/SetupUtils.java b/src/test/java/io/pravega/connectors/flink/utils/SetupUtils.java
@@ -105,7 +105,7 @@ public void stopAllServices() throws Exception {
      * @return URI The controller endpoint to connect to this cluster.
      */
     public URI getControllerUri() {
-        return URI.create("tcp://" + this.inProcPravegaCluster.getControllerURI());
+        return URI.create(this.inProcPravegaCluster.getControllerURI());
     }
 
     /**