Github user Aegeaner commented on a diff in the pull request: https://github.com/apache/flink/pull/5065#discussion_r155746723 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -721,6 +722,42 @@ abstract class TableEnvironment(val config: TableConfig) { */ protected def checkValidTableName(name: String): Unit + /** + * Checks if the chosen table type is valid. + * @param table The table to check + */ + protected def checkValidTableType(table: Table): Unit = { --- End diff -- I will do this
---