[hotfix] Use correct ClassLoader in ContinuousFileProcessingMigrationTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/238c5032 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/238c5032 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/238c5032 Branch: refs/heads/master Commit: 238c50327de71be0dd6525e98b12dd51d04a8871 Parents: c5d77a8 Author: Aljoscha Krettek <[email protected]> Authored: Fri Jan 13 14:16:51 2017 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Tue Jan 24 10:42:34 2017 +0100 ---------------------------------------------------------------------- .../flink/hdfstests/ContinuousFileProcessingMigrationTest.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/238c5032/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java ---------------------------------------------------------------------- diff --git a/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java b/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java index 0915005..440bfcc 100644 --- a/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java +++ b/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java @@ -35,7 +35,6 @@ import org.apache.flink.streaming.api.functions.source.SourceFunction; import org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit; import org.apache.flink.streaming.api.operators.StreamSource; import org.apache.flink.streaming.api.watermark.Watermark; -import org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest; import org.apache.flink.streaming.runtime.streamrecord.StreamRecord; import org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness; import org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness; @@ -107,7 +106,7 @@ public class ContinuousFileProcessingMigrationTest { } private static String getResourceFilename(String filename) { - ClassLoader cl = WindowOperatorTest.class.getClassLoader(); + ClassLoader cl = ContinuousFileProcessingMigrationTest.class.getClassLoader(); URL resource = cl.getResource(filename); return resource.getFile(); }
