You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by jq...@apache.org on 2019/08/01 07:08:49 UTC
[flink] 03/03: [hotfix] Fix static inner class name collision in
KafkaConsumerTestBase.
This is an automated email from the ASF dual-hosted git repository.
jqin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 09f96b339f4890d7a44ae92c915ea8c0f6f244cb
Author: Jiangjie (Becket) Qin <ji...@alibaba-inc.com>
AuthorDate: Thu Jul 25 12:05:44 2019 +0800
[hotfix] Fix static inner class name collision in KafkaConsumerTestBase.
---
.../streaming/connectors/kafka/KafkaConsumerTestBase.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
index 1582922..3254fa4 100644
--- a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
+++ b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
@@ -1176,7 +1176,7 @@ public abstract class KafkaConsumerTestBase extends KafkaTestBaseWithFlink {
Tuple2WithTopicSchema schema = new Tuple2WithTopicSchema(env.getConfig());
kafkaServer.produceIntoKafka(stream, "dummy", schema, props, null);
} else {
- TestDeSerializer schema = new TestDeSerializer(env.getConfig());
+ TestDeserializer schema = new TestDeserializer(env.getConfig());
kafkaServer.produceIntoKafka(stream, "dummy", schema, props);
}
@@ -1190,7 +1190,7 @@ public abstract class KafkaConsumerTestBase extends KafkaTestBaseWithFlink {
Tuple2WithTopicSchema schema = new Tuple2WithTopicSchema(env.getConfig());
stream = env.addSource(kafkaServer.getConsumer(topics, schema, props));
} else {
- TestDeSerializer schema = new TestDeSerializer(env.getConfig());
+ TestDeserializer schema = new TestDeserializer(env.getConfig());
stream = env.addSource(kafkaServer.getConsumer(topics, schema, props));
}
@@ -2207,12 +2207,12 @@ public abstract class KafkaConsumerTestBase extends KafkaTestBaseWithFlink {
}
}
- private abstract static class TestDeserializer implements
+ private abstract static class AbstractTestDeserializer implements
KafkaDeserializationSchema<Tuple3<Integer, Integer, String>> {
protected final TypeSerializer<Tuple2<Integer, Integer>> ts;
- public TestDeserializer(ExecutionConfig ec) {
+ public AbstractTestDeserializer(ExecutionConfig ec) {
ts = TypeInformation.of(new TypeHint<Tuple2<Integer, Integer>>(){}).createSerializer(ec);
}
@@ -2234,7 +2234,7 @@ public abstract class KafkaConsumerTestBase extends KafkaTestBaseWithFlink {
}
}
- private static class Tuple2WithTopicSchema extends TestDeserializer
+ private static class Tuple2WithTopicSchema extends AbstractTestDeserializer
implements KeyedSerializationSchema<Tuple3<Integer, Integer, String>> {
public Tuple2WithTopicSchema(ExecutionConfig ec) {
@@ -2264,10 +2264,10 @@ public abstract class KafkaConsumerTestBase extends KafkaTestBaseWithFlink {
}
}
- private static class TestDeSerializer extends TestDeserializer
+ private static class TestDeserializer extends AbstractTestDeserializer
implements KafkaSerializationSchema<Tuple3<Integer, Integer, String>> {
- public TestDeSerializer(ExecutionConfig ec) {
+ public TestDeserializer(ExecutionConfig ec) {
super(ec);
}