fix: rebase issue

confluentinc · Oct 17, 2019 · 9da42bd · 9da42bd
1 parent 08c6908
commit 9da42bd
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/ksql-engine/src/test/java/io/confluent/ksql/engine/InsertValuesExecutorTest.java b/ksql-engine/src/test/java/io/confluent/ksql/engine/InsertValuesExecutorTest.java
@@ -451,7 +451,7 @@ public void shouldHandleNullKeyForSourceWithKeyField() {
   @Test
   public void shouldHandleNegativeValueExpression() {
     // Given:
-    givenDataSourceWithSchema(SCHEMA, SerdeOption.none(), Optional.of(ColumnName.of("COL0")));
+    givenSourceStreamWithSchema(SCHEMA, SerdeOption.none(), Optional.of(ColumnName.of("COL0")));
 
     final ConfiguredStatement<InsertValues> statement = givenInsertValuesStrings(
         ImmutableList.of("COL0", "COL1"),
@@ -473,7 +473,7 @@ public void shouldHandleNegativeValueExpression() {
   @Test
   public void shouldHandleUdfs() {
     // Given:
-    givenDataSourceWithSchema(SINGLE_ARRAY_SCHEMA, SerdeOption.none(), Optional.empty());
+    givenSourceStreamWithSchema(SINGLE_ARRAY_SCHEMA, SerdeOption.none(), Optional.empty());
 
     final ConfiguredStatement<InsertValues> statement = givenInsertValuesStrings(
         ImmutableList.of("COL0"),
@@ -494,7 +494,7 @@ public void shouldHandleUdfs() {
   @Test
   public void shouldHandleNestedUdfs() {
     // Given:
-    givenDataSourceWithSchema(SINGLE_MAP_SCHEMA, SerdeOption.none(), Optional.empty());
+    givenSourceStreamWithSchema(SINGLE_MAP_SCHEMA, SerdeOption.none(), Optional.empty());
 
     final ConfiguredStatement<InsertValues> statement = givenInsertValuesStrings(
         ImmutableList.of("COL0"),