[FLINK-15689][table] Configure ExecutionEnvironment from BatchTableEn…

…vironment
arne-klein · Jan 23, 2020 · b2fda00 · b2fda00
1 parent dbd0ea0
commit b2fda00
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...-table-planner/src/main/scala/org/apache/flink/table/api/internal/BatchTableEnvImpl.scala b/...-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(