This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.6 by this push: new 8c9b59e [FLINK-10064] [table] Fix a typo in ExternalCatalogTable 8c9b59e is described below commit 8c9b59e79d35842a771214302dad75c1e99da682 Author: jerryjzhang <zhangjun2...@163.com> AuthorDate: Mon Aug 6 01:01:12 2018 +0800 [FLINK-10064] [table] Fix a typo in ExternalCatalogTable This closes #6497. --- .../scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala index 79da852..9576f34 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala @@ -88,7 +88,7 @@ class ExternalCatalogTable( * Returns whether this external table is declared as table sink. */ def isTableSink: Boolean = { - isSource + isSink } /**