[flink] 06/08: [hotfix][table-planner][tests] Use EnvironmentSettings to pass configuration

[tw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 607c3a7ba415cc4138f446b43c48e06faae3e369
Author: Marios Trivyzas <ma...@gmail.com>
AuthorDate: Mon Mar 21 14:55:42 2022 +0200

    [hotfix][table-planner][tests] Use EnvironmentSettings to pass configuration
    
    Use the new way for passing application specific configuration through
    the `EnviromentSettings`.
    
    (cherry picked from commit d52658557c4ed5c7b7ffc44b1229da18b9c6aa0f)
---
 .../org/apache/flink/table/api/TableEnvironmentTest.scala     | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala
index 3f9c906..9f2e803 100644
--- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala
+++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala
@@ -21,7 +21,7 @@ package org.apache.flink.table.api
 import org.apache.flink.api.common.RuntimeExecutionMode
 import org.apache.flink.api.common.typeinfo.Types.STRING
 import org.apache.flink.api.scala._
-import org.apache.flink.configuration.{Configuration, ExecutionOptions}
+import org.apache.flink.configuration.{Configuration, CoreOptions, ExecutionOptions}
 import org.apache.flink.core.testutils.FlinkAssertions.anyCauseMatches
 import org.apache.flink.streaming.api.environment.LocalStreamEnvironment
 import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
@@ -42,6 +42,7 @@ import org.apache.flink.types.Row
 import org.apache.calcite.plan.RelOptUtil
 import org.apache.calcite.sql.SqlExplainLevel
 import org.assertj.core.api.Assertions.{assertThat, assertThatThrownBy}
+
 import org.junit.Assert.{assertEquals, assertFalse, assertTrue, fail}
 import org.junit.rules.ExpectedException
 import org.junit.{Rule, Test}
@@ -142,11 +143,11 @@ class TableEnvironmentTest {
   @Test
   def testStreamTableEnvironmentExecutionExplainWithConfParallelism(): Unit = {
     val execEnv = StreamExecutionEnvironment.getExecutionEnvironment
-    val settings = EnvironmentSettings.newInstance().inStreamingMode().build()
-    val tEnv = StreamTableEnvironment.create(execEnv, settings)
     val configuration = new Configuration()
-    configuration.setInteger("parallelism.default", 4)
-    tEnv.getConfig.addConfiguration(configuration)
+    configuration.set(CoreOptions.DEFAULT_PARALLELISM, Integer.valueOf(4))
+    val settings =
+      EnvironmentSettings.newInstance().inStreamingMode().withConfiguration(configuration).build()
+    val tEnv = StreamTableEnvironment.create(execEnv, settings)
 
     verifyTableEnvironmentExecutionExplain(tEnv)
   }