This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 78a6dd655ac0117859563612db3c970235759fc1 Author: Stephan Ewen <se...@apache.org> AuthorDate: Tue Mar 30 10:00:04 2021 +0200 [hotfix][tests] Remove unused code. --- .../streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java index 7337da2..62b6ff5 100644 --- a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java +++ b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java @@ -42,8 +42,6 @@ import org.apache.flink.util.Collector; import org.apache.flink.util.Preconditions; import org.apache.commons.lang3.RandomStringUtils; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import java.io.IOException; import java.io.Serializable; @@ -80,9 +78,6 @@ import java.util.Set; */ public class StickyAllocationAndLocalRecoveryTestJob { - private static final Logger LOG = - LoggerFactory.getLogger(StickyAllocationAndLocalRecoveryTestJob.class); - public static void main(String[] args) throws Exception { final ParameterTool pt = ParameterTool.fromArgs(args);