You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2018/07/19 06:51:39 UTC
[2/2] flink git commit: [hotfix] [sql-client] Fix typo in
SqlExecutionException
[hotfix] [sql-client] Fix typo in SqlExecutionException
This closes #6364.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85a68286
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/85a68286
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/85a68286
Branch: refs/heads/master
Commit: 85a68286840ff5684b344bf807c206cc81feb968
Parents: fefe866
Author: xueyu <27...@qq.com>
Authored: Wed Jul 18 21:39:57 2018 +0800
Committer: Timo Walther <tw...@apache.org>
Committed: Thu Jul 19 08:51:04 2018 +0200
----------------------------------------------------------------------
.../apache/flink/table/client/gateway/local/ExecutionContext.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/85a68286/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java b/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
index 926bdb0..9152908 100644
--- a/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
+++ b/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
@@ -236,7 +236,7 @@ public class ExecutionContext<T> {
TableFactoryService.find(BatchTableSinkFactory.class, sinkProperties, classLoader);
return factory.createBatchTableSink(sinkProperties);
}
- throw new SqlExecutionException("Unsupported execution type for sources.");
+ throw new SqlExecutionException("Unsupported execution type for sinks.");
}
// --------------------------------------------------------------------------------------------