You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/01/23 14:01:48 UTC
[08/10] flink git commit: [hotfix] Use correct ClassLoader in
FlinkKafkaConsumerBaseMigrationTest
[hotfix] Use correct ClassLoader in FlinkKafkaConsumerBaseMigrationTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16b63c24
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/16b63c24
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/16b63c24
Branch: refs/heads/release-1.2
Commit: 16b63c24ea5d34c16acaa71dc8b23cd87e82470f
Parents: 8fcd26b
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Fri Jan 13 14:13:03 2017 +0100
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Mon Jan 23 14:53:22 2017 +0100
----------------------------------------------------------------------
.../connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/16b63c24/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
index c315d31..fa93138 100644
--- a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
+++ b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
@@ -27,7 +27,6 @@ import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;
import org.apache.flink.streaming.api.watermark.Watermark;
import org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher;
import org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition;
-import org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest;
import org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness;
import org.apache.flink.streaming.util.serialization.KeyedDeserializationSchema;
import org.apache.flink.util.SerializedValue;
@@ -60,7 +59,7 @@ import static org.mockito.Mockito.mock;
public class FlinkKafkaConsumerBaseMigrationTest {
private static String getResourceFilename(String filename) {
- ClassLoader cl = WindowOperatorTest.class.getClassLoader();
+ ClassLoader cl = FlinkKafkaConsumerBaseMigrationTest.class.getClassLoader();
URL resource = cl.getResource(filename);
if (resource == null) {
throw new NullPointerException("Missing snapshot resource.");