You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/01/23 12:32:33 UTC
[flink] 03/03: [FLINK-15689][table] Configure ExecutionEnvironment
from BatchTableEnvironment
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 558fdf35cc01a2e17192323add1da3df5a4bed13
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Mon Jan 20 14:54:36 2020 +0100
[FLINK-15689][table] Configure ExecutionEnvironment from BatchTableEnvironment
---
.../scala/org/apache/flink/table/api/internal/BatchTableEnvImpl.scala | 3 +++
1 file changed, 3 insertions(+)
diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/BatchTableEnvImpl.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/BatchTableEnvImpl.scala
index 53026ce..f9f3b50 100644
--- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/BatchTableEnvImpl.scala
+++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/BatchTableEnvImpl.scala
@@ -300,6 +300,9 @@ abstract class BatchTableEnvImpl(
logicalPlan match {
case node: DataSetRel =>
+ execEnv.configure(
+ config.getConfiguration,
+ Thread.currentThread().getContextClassLoader)
val plan = node.translateToPlan(this, new BatchQueryConfig)
val conversion =
getConversionMapper(