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
   }
 
   /**

Reply via email to