You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2021/02/23 16:29:20 UTC
[flink] 02/03: [hotfix][test] Removes unused inner class
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 278dababa04883801babcada76d715baaf3b29cf
Author: Matthias Pohl <ma...@ververica.com>
AuthorDate: Fri Feb 19 08:56:17 2021 +0100
[hotfix][test] Removes unused inner class
---
.../legacy/DefaultExecutionGraphCacheTest.java | 44 ----------------------
1 file changed, 44 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/DefaultExecutionGraphCacheTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/DefaultExecutionGraphCacheTest.java
index 65593bb..ace82f9 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/DefaultExecutionGraphCacheTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/DefaultExecutionGraphCacheTest.java
@@ -18,16 +18,11 @@
package org.apache.flink.runtime.rest.handler.legacy;
-import org.apache.flink.api.common.ArchivedExecutionConfig;
-import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.api.common.JobID;
-import org.apache.flink.api.common.JobStatus;
import org.apache.flink.api.common.time.Time;
-import org.apache.flink.runtime.accumulators.StringifiedAccumulatorResult;
import org.apache.flink.runtime.concurrent.FutureUtils;
import org.apache.flink.runtime.executiongraph.AccessExecutionGraph;
import org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph;
-import org.apache.flink.runtime.executiongraph.ErrorInfo;
import org.apache.flink.runtime.messages.FlinkJobNotFoundException;
import org.apache.flink.runtime.rest.handler.legacy.utils.ArchivedExecutionGraphBuilder;
import org.apache.flink.runtime.webmonitor.RestfulGateway;
@@ -44,7 +39,6 @@ import org.junit.Test;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
-import java.util.Collections;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ExecutionException;
@@ -298,42 +292,4 @@ public class DefaultExecutionGraphCacheTest extends TestLogger {
return numRequestJobCalls.get();
}
}
-
- private static final class SuspendableAccessExecutionGraph extends ArchivedExecutionGraph {
-
- private static final long serialVersionUID = -6796543726305778101L;
-
- private JobStatus jobStatus;
-
- public SuspendableAccessExecutionGraph(JobID jobId) {
- super(
- jobId,
- "DefaultExecutionGraphCacheTest",
- Collections.emptyMap(),
- Collections.emptyList(),
- new long[0],
- JobStatus.RUNNING,
- new ErrorInfo(new FlinkException("Test"), 42L),
- "",
- new StringifiedAccumulatorResult[0],
- Collections.emptyMap(),
- new ArchivedExecutionConfig(new ExecutionConfig()),
- false,
- null,
- null,
- "stateBackendName",
- "checkpointStorageName");
-
- jobStatus = super.getState();
- }
-
- @Override
- public JobStatus getState() {
- return jobStatus;
- }
-
- public void setJobStatus(JobStatus jobStatus) {
- this.jobStatus = jobStatus;
- }
- }
}