From 2ca7e411f5341fdcfd65efb958f30756e9675e27 Mon Sep 17 00:00:00 2001 From: Zhu Zhu Date: Mon, 30 Jan 2023 17:04:32 +0800 Subject: [PATCH] [hotfix] Remove legacy code which was not removed due merge conflicts --- .../table/planner/runtime/batch/ParallelismSettingTest.java | 1 - 1 file changed, 1 deletion(-) diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/ParallelismSettingTest.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/ParallelismSettingTest.java index 1da85aac1473a..e5115a4d3e858 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/ParallelismSettingTest.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/ParallelismSettingTest.java @@ -59,7 +59,6 @@ public void before() { @Test public void testParallelismSettingAfterSingletonShuffleRemove() { - util.getStreamEnv().getConfig().setScheduler(SchedulerType.AdaptiveBatch); util.getTableEnv() .executeSql( "CREATE TABLE MySink (\n"