From c83ba1079aa7ad59a6014dda6c69503c78b34202 Mon Sep 17 00:00:00 2001
From: yanghua <yanghua1127@gmail.com>
Date: Mon, 2 Sep 2019 14:56:49 +0800
Subject: [PATCH] [FLINK-13618] Update FlinkKafkaConsumerBaseMigrationTest to
 restore from 1.9 savepoint

This closes #9594.
---
 .../FlinkKafkaConsumerBaseMigrationTest.java     |   3 ++-
 ...-migration-test-flink1.9-empty-state-snapshot | Bin 0 -> 1330 bytes
 ...fka-consumer-migration-test-flink1.9-snapshot | Bin 0 -> 1384 bytes
 3 files changed, 2 insertions(+), 1 deletion(-)
 create mode 100644 flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-empty-state-snapshot
 create mode 100644 flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-snapshot

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 46aba331daac8..4b888c6f4aa79 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
@@ -106,7 +106,8 @@ public static Collection<MigrationVersion> parameters () {
 			MigrationVersion.v1_5,
 			MigrationVersion.v1_6,
 			MigrationVersion.v1_7,
-			MigrationVersion.v1_8);
+			MigrationVersion.v1_8,
+			MigrationVersion.v1_9);
 	}
 
 	public FlinkKafkaConsumerBaseMigrationTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-empty-state-snapshot b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-empty-state-snapshot
new file mode 100644
index 0000000000000000000000000000000000000000..4a328d251a8b8e689cf32d626a82844f6946eb3f
GIT binary patch
literal 1330
zcmb_b!EVz)5Z#3KzyYZTu1Fj#Bvg6Th9u>}!PHh|66(lyKya}p&e~mK?^?U-O6jNc
zLy-6ZeuX=CB-VDR6H-|qWe@g_cjnD|p0^0Kt9PLHee^h5k_5_3Ma|JO#S0pn1qekI
z<;>(sB8f7k0!3u6O6nnF9G{F{Ek>`+gbc>!aBu?VVoa9i85x}p#>3O)@QfgI@J(kQ
z{@tX)=%MG{%<-+z^P?cNLMO7_AoSh0^U(D!qxYWeprc?mb;I_+sq2nDSkt)^1&;4p
zQ}?su>#u!ebCF^wAig3v$tYW4Q8Gnyf@|LR9b7{|1ci*=5MgYG0fRzbaix(Sp>F*(
zg@2=eIKR|VIyj&2aE5~7FPbS<>w=VuX7XM}SQZ&+6>L#{@}n8$iw?l59M>QN^z`Ge
zI~{#=(NVKQVkOobPxRwKB7NlUfJr3?<dmg2=8Tb8aUt;vk`-Xe6cG%x#z_^2mF;GK
zT&KPB^ZV_aLi5}wY-PR49%)v1-X8HZ96~QQ{vuopj#I+4bz^+dylqfmSVF+MYJdEn
z`Crj|1HZW|9lona-i})ucA4jEOVjd6N~InlS)OMgrKZwDpY{X2ZLvG}dqe0>8~fRV
dEn}YNoNe5r1xSLYoTaT6V>{fsQo2X8egiO&udM(8

literal 0
HcmV?d00001

diff --git a/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-snapshot b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-snapshot
new file mode 100644
index 0000000000000000000000000000000000000000..34ef21f819932c1470aed839bb369b20015625cf
GIT binary patch
literal 1384
zcmb_bzl#$=7@b{ng@tm3l^|FIL1c&M-NlPwv0j#AO}vENjX|5`+s$k;m))6VW^xcK
z{|^5P8^K<z1UpMD1Z}LYu@ao!oR`ELK_OGj@9%x@&G!bOc{3_{ZlcTKfFv+URX97k
zp?FSXD+i&dqMTVgNhDF0RG^47%9!$I<?Sq>^1(pW`?a_h#XE_$SFi0`yMxA_72Rz_
z)^4K_*K31%v`=;rs(jHQTYo1lFb#CG({(&M=y;(Y*ntx^T|e;LN4>!99EDFhO$TlJ
z-L@Od51cY?`>EaTIic@(uHAN@JD%P(QIm@yh8*G%!AVNl7>fy0G$Xjwfgi&O_(V`h
z=?fyN%S)d@E=OExq)TZ1dz2LZjs8~eNK0A6`Cx@J<P;xkrdUmLGEp>@=Q4sxo|3tO
zCCXR6&q{l14PX(DOOSi$TL0IX4ig=&iCG~r7E_K}y1S5wiQE-1sRV(HvLTK+V<c8w
zNIZsQ445)S1Ou(HRjh-;hTT6d)ZRIL|LS3`d2SN6uwH9}Gz+}W2Jti;Lbn%Q5l#fh
zL&CImV|+Lpo1ma-3jxz2{hj~3{|5CI@MnKzjql2m&&w^V%}JI`ZB5G~Ln?I%$>1Ob
zDK!-XJ=+ZQvc=Be&kdn7EzG+Yri^)(aklV}B9H{PIUCNkRF{`aUkde&Pal7n*A0li
d>U_G{FZ;&3)1T&5V?e$Y8xKB@UKeB0egky$z0m*w

literal 0
HcmV?d00001