[1/4] flink git commit: [FLINK-6442] [table] Add registration for TableSinks and INSERT INTO support for SQL and Table API.

[fhueske]

Repository: flink
Updated Branches:
  refs/heads/master 73a2443d4 -> 2cb37cb93


http://git-wip-us.apache.org/repos/asf/flink/blob/2cb37cb9/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/TableTestBase.scala
----------------------------------------------------------------------
diff --git 
a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/TableTestBase.scala
 
b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/TableTestBase.scala
index d99aac1..0a0d12e 100644
--- 
a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/TableTestBase.scala
+++ 
b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/TableTestBase.scala
@@ -178,7 +178,7 @@ case class BatchTableTestUtil() extends TableTestUtil {
   }
 
   def verifySql(query: String, expected: String): Unit = {
-    verifyTable(tableEnv.sql(query), expected)
+    verifyTable(tableEnv.sqlQuery(query), expected)
   }
 
   def verifyTable(resultTable: Table, expected: String): Unit = {
@@ -197,7 +197,7 @@ case class BatchTableTestUtil() extends TableTestUtil {
   }
 
   def printSql(query: String): Unit = {
-    printTable(tableEnv.sql(query))
+    printTable(tableEnv.sqlQuery(query))
   }
 
 }
@@ -256,7 +256,7 @@ case class StreamTableTestUtil() extends TableTestUtil {
   }
 
   def verifySql(query: String, expected: String): Unit = {
-    verifyTable(tableEnv.sql(query), expected)
+    verifyTable(tableEnv.sqlQuery(query), expected)
   }
 
   def verifyTable(resultTable: Table, expected: String): Unit = {
@@ -276,7 +276,7 @@ case class StreamTableTestUtil() extends TableTestUtil {
   }
 
   def printSql(query: String): Unit = {
-    printTable(tableEnv.sql(query))
+    printTable(tableEnv.sqlQuery(query))
   }
 
 }