[FLINK-21069] Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.2, 1.13.0
• Component/s: Table SQL / API
• Labels: pull-request-available starter
• Assignee: Nicholas Jiang
• Reporter: Jark Wu
• Created: 21/Jan/21 10:25
• Updated: 28/May/21 07:13
• Resolved: 25/Jan/21 11:53

Description

I tried the following test, and the printed node parallelism in json plan is not 5.

  @Test
  def testExplainAndExecuteSingleSink(): Unit = {
    val env = TableEnvironmentImpl.create(settings)
    val conf = new Configuration();
    conf.setInteger("parallelism.default", 5)
    conf.setInteger("taskmanager.numberOfTaskSlots", 1)
    env.getConfig.addConfiguration(conf)
    TestTableSourceSinks.createCsvTemporarySinkTable(
      env, new TableSchema(Array("first"), Array(STRING)), "MySink1")
    TestTableSourceSinks.createPersonCsvTemporaryTable(env, "MyTable")
    println(env.explainSql("insert into MySink1 select first from MyTable",
      ExplainDetail.JSON_EXECUTION_PLAN))
}

I think the bug is because TableEnvironemnt#explain will not invoke PlannerBase#translate(modifyOperations: util.List[ModifyOperation]) where we configure the configuration into underlying StreamExecutionEnvironment.

Issue Links

• links to: GitHub Pull Request #14742