This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 4b3dfb5 [FLINK-10064] [table] Fix a typo in ExternalCatalogTable
4b3dfb5 is described below
commit 4b3dfb571e3b64b8fe340b29aa0d9edf1ce3fef5
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
}
/**
