From 9535ffcf9002e63a89e2d0054d827fbca2097e66 Mon Sep 17 00:00:00 2001
From: Yun Gao <gaoyunhenhao@gmail.com>
Date: Thu, 23 Jul 2020 15:52:44 +0800
Subject: [PATCH] [FLINK-18552][tests] Update migration tests of
 FlinkKafkaProducerMigrationTest to cover migration from 1.10

---
 .../kafka/FlinkKafkaProducerMigrationTest.java   |   3 ++-
 ...-migration-kafka-producer-flink-1.10-snapshot | Bin 0 -> 1232 bytes
 2 files changed, 2 insertions(+), 1 deletion(-)
 create mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot

diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
index 10a6fee0cc3b0..0317396e31472 100644
--- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
+++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
@@ -45,7 +45,8 @@ public class FlinkKafkaProducerMigrationTest extends KafkaMigrationTestBase {
 	public static Collection<MigrationVersion> parameters() {
 		return Arrays.asList(
 			MigrationVersion.v1_8,
-			MigrationVersion.v1_9);
+			MigrationVersion.v1_9,
+			MigrationVersion.v1_10);
 	}
 
 	public FlinkKafkaProducerMigrationTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot
new file mode 100644
index 0000000000000000000000000000000000000000..e7a4f0dad9a25f79cd4f8ec569420cec301fe11d
GIT binary patch
literal 1232
zcmbtTOHRWu5OoS!BC%kL#G*UoC{4p}Ss;jr(w4*piA^zyL#?!S6`PL`CxC0P;6faL
z6&tRAgx!Ej5ELRtN;ICl`Mfs{024E2m0tmij9f`5Gt2~zB;^bbAdO+4G6^pnLt*rz
ztnvs<A+aR-@DY15Ky`zxuAIh^3u7C*(A`*fAg)IaOzKIz9<S76*Iol)c2A|5zczfY
zZGfeA#|s*$9rQxfKwfX#4^iN6c9Gw1_4eD_9x%Ht<&P8Q4;#&{*9*PCZ#4a5FHq46
zxaHZIg-1B*6Dt`|mRdq)1P>`Yvm(wIi6qa2mEt7D){X}3X}6Q{_&g$6wWX9npM~+`
zT_sCMGKvTE`Y(u(;gRTbspgrP$d{}7JHz>~)AZ4Vx;KUF$rQ49M6KkUjn^wIp_M?F
zywk^mZ1Lfc%20)N-T~E6FL^?;Kw<7VzcmX-uj5&?%r{dy|3&6c5`Sr3{rOX2Dz(Oc
zEqaSHsdoLf`}g5OXC=beO!YPlu)NQs6k(A<yJ)rI(XK%!Pn>zt|B@lDAA-BmHEMYc
dotM`*xYt+9EHg)~4A?0Hu9pG3Wx)0a?>Eq9Q}h4;

literal 0
HcmV?d00001