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

zhuzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 2ca7e411f53 [hotfix] Remove legacy code which was not removed due 
merge conflicts
2ca7e411f53 is described below

commit 2ca7e411f5341fdcfd65efb958f30756e9675e27
Author: Zhu Zhu <reed...@gmail.com>
AuthorDate: Mon Jan 30 17:04:32 2023 +0800

    [hotfix] Remove legacy code which was not removed due merge conflicts
---
 .../apache/flink/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 1da85aac147..e5115a4d3e8 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 class ParallelismSettingTest extends TableTestBase {
 
     @Test
     public void testParallelismSettingAfterSingletonShuffleRemove() {
-        
util.getStreamEnv().getConfig().setScheduler(SchedulerType.AdaptiveBatch);
         util.getTableEnv()
                 .executeSql(
                         "CREATE TABLE MySink (\n"

Reply via email to