From a8a4e497acf1e62c1c632724f7bf6604032302fa Mon Sep 17 00:00:00 2001
From: xueyu <278006819@qq.com>
Date: Wed, 18 Jul 2018 21:39:57 +0800
Subject: [PATCH] hotfix for SqlExecutionException msg

---
 .../flink/table/client/gateway/local/ExecutionContext.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 926bdb01a1664..9152908645a49 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 @@ private static TableSink<?> createTableSink(Execution execution, Map<String, Str
 				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.");
 	}
 
 	// --------------------------------------------------------------------------------------------