diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerTestingUtils.java b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerTestingUtils.java
index 2a2c73edc5aab78701175597a7840ee0cbf5dd4c..b9d81e3004773bf963a825a23b41dcbe48d69160 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerTestingUtils.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerTestingUtils.java
@@ -66,7 +66,7 @@ import org.apache.flink.runtime.shuffle.NettyShuffleMaster;
 import org.apache.flink.runtime.shuffle.ShuffleMaster;
 import org.apache.flink.runtime.taskexecutor.TaskExecutorOperatorEventGateway;
 import org.apache.flink.runtime.taskmanager.TaskExecutionState;
-import org.apache.flink.runtime.testingUtils.TestingUtils;
+import org.apache.flink.runtime.testutils.DirectScheduledExecutorService;
 import org.apache.flink.util.SerializedValue;
 
 import org.slf4j.Logger;
@@ -278,11 +278,11 @@ public class SchedulerTestingUtils {
 
 		private Logger log = LOG;
 		private BackPressureStatsTracker backPressureStatsTracker = VoidBackPressureStatsTracker.INSTANCE;
-		private Executor ioExecutor = TestingUtils.defaultExecutor();
+		private Executor ioExecutor = java.util.concurrent.Executors.newSingleThreadExecutor();
 		private Configuration jobMasterConfiguration = new Configuration();
-		private ScheduledExecutorService futureExecutor = TestingUtils.defaultExecutor();
+		private ScheduledExecutorService futureExecutor = new DirectScheduledExecutorService();
 		private ScheduledExecutor delayExecutor = new ScheduledExecutorServiceAdapter(futureExecutor);
-		private ClassLoader userCodeLoader = ClassLoader.getSystemClassLoader();
+		private ClassLoader userCodeLoader = getClass().getClassLoader();
 		private CheckpointRecoveryFactory checkpointRecoveryFactory = new StandaloneCheckpointRecoveryFactory();
 		private Time rpcTimeout = DEFAULT_TIMEOUT;
 		private BlobWriter blobWriter = VoidBlobWriter.getInstance();