reverted pom changes, applied almog's comments

confluentinc · Sep 3, 2019 · 64b9847 · 64b9847
1 parent 4ccc75b
commit 64b9847
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 10 deletions.
diff --git a/ksql-engine/pom.xml b/ksql-engine/pom.xml
@@ -167,14 +167,6 @@
             <artifactId>wiremock-jre8</artifactId>
             <scope>test</scope>
         </dependency>
-      <dependency>
-        <groupId>io.confluent.ksql</groupId>
-        <artifactId>ksql-streams</artifactId>
-      </dependency>
-        <dependency>
-            <groupId>io.confluent.ksql</groupId>
-            <artifactId>ksql-streams</artifactId>
-        </dependency>
 
     </dependencies>
 

diff --git a/ksql-engine/src/main/java/io/confluent/ksql/function/UdfLoader.java b/ksql-engine/src/main/java/io/confluent/ksql/function/UdfLoader.java
@@ -405,8 +405,9 @@ private Function<List<Schema>,Schema> handleUdfSchemaProviderAnnotation(
     final Object instance = instantiateUdfClass(theClass, annotation);
 
     return parameterSchemas -> {
-      final List<SqlType> parameterTypes = parameterSchemas.stream().map(p -> SchemaConverters
-          .connectToSqlConverter().toSqlType(p)).collect(Collectors.toList());
+      final List<SqlType> parameterTypes = parameterSchemas.stream()
+          .map(p -> SchemaConverters.connectToSqlConverter().toSqlType(p))
+          .collect(Collectors.toList());
       return SchemaConverters.sqlToConnectConverter().toConnectSchema(invokeSchemaProviderMethod(
           instance, m, parameterTypes, annotation));
     };

diff --git a/ksql-engine/src/test/resources/udf-failing-tests.jar b/ksql-engine/src/test/resources/udf-failing-tests.jar