From 50f41965800f90fed5a6399b6172161c75b8c764 Mon Sep 17 00:00:00 2001 From: Hequn Cheng Date: Wed, 2 Jan 2019 19:10:59 +0800 Subject: [PATCH] Merge pull request #7242 from hequn8128/flink-10781 [FLINK-10781][fs] Update BucketingSinkMigrationTest for Flink 1.7 --- .../fs/bucketing/BucketingSinkMigrationTest.java | 3 ++- ...cketing-sink-migration-test-flink1.7-snapshot | Bin 0 -> 1952 bytes 2 files changed, 2 insertions(+), 1 deletion(-) create mode 100644 flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.7-snapshot diff --git a/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java b/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java index 981a529ddd2..fb0796aec6c 100644 --- a/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java +++ b/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java @@ -90,7 +90,8 @@ public class BucketingSinkMigrationTest { Tuple2.of(MigrationVersion.v1_3, "/var/folders/tv/b_1d8fvx23dgk1_xs8db_95h0000gn/T/junit4273542175898623023/junit3801102997056424640/1970-01-01--01/part-0-"), Tuple2.of(MigrationVersion.v1_4, "/var/folders/tv/b_1d8fvx23dgk1_xs8db_95h0000gn/T/junit3198043255809479705/junit8947526563966405708/1970-01-01--01/part-0-"), Tuple2.of(MigrationVersion.v1_5, "/tmp/junit4927100426019463155/junit2465610012100182280/1970-01-01--00/part-0-"), - Tuple2.of(MigrationVersion.v1_6, "/tmp/junit3459711376354834545/junit5114611885650086135/1970-01-01--00/part-0-")); + Tuple2.of(MigrationVersion.v1_6, "/tmp/junit3459711376354834545/junit5114611885650086135/1970-01-01--00/part-0-"), + Tuple2.of(MigrationVersion.v1_7, "/var/folders/r2/tdhx810x7yxb7q9_brnp49x40000gp/T/junit4288325607215628863/junit8132783417241536320/1970-01-01--08/part-0-")); } private final MigrationVersion testMigrateVersion; diff --git a/flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.7-snapshot b/flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.7-snapshot new file mode 100644 index 0000000000000000000000000000000000000000..9aeb1c28ee96ae5904f3820bdcff65a07f0af720 GIT binary patch literal 1952 zcmc&!y^j+|6n}dkkZ=bviG-8_2`RMuy|&k)AiiJ|TMKvcE+0zcjMsDaa_iZ>nepA; z6_L_}f`TYY3JSV3iTEd?M50K9M2ZwNP^68-pTL_n$VZL>6e%~dci+7C=J($Fy|)7} zU)mDN8k`(V<1H$6A&I0ynYEdZ_PYk>>#jYtT;J1caqQ?GiR*e}=nr+PS{*bRq*@#J z1mO5ZJhJ>IFomVTx%G`!uNkfP`eD?JTK!9%FzR*Iu0@^otNknMms(H>H-b(yH?+!g zmFvymTB{$ndYxv_`J&ZB?E+lR_{bnRiO1B~OcS<+o5YB-$s}Wj+{@`yCaEws2qzON zDNm^o5voJV6OtzTlz*17&1AG6{`R~K1Mt^_e_&Z~&<{cLDU->B8YMkOm+X)^Ogp^! z=tu9wcMAXohqXgz-(LNMiNKVNFb49Khqp{4mFgArT8z7}$D@O?>tZ3_es3xk+rp!kRV0GqN8ia%o zf?LR^soG^;A^C+O#}=GcIz#D<&xshLe);&5Uw%FF<>N(IXv2v#Bf~aP!8`E29CIqh zSvoB8i=URER(IdScLo2Ngl%(&aB~ywlnawPrW}q7-?obSUNNX|H~It4a<5T%7Oqil zM&_+4OQh%czUx$LR^73yHQdzPnZdVRr|!F+U3WaY>egJxGVMm)(k)y4bj!yAg8xk1 zjK+V_cdQGmF*ZOZ8H;ctyKp9+a!#3SCn>#-gFOr=8_97OPNzi38$6McvM5u|0jwNw zmhj<>`INAc8A^^FyMW!vDI21w@UT0T1KkM{A<^UGgB~0B9gS(cm1hZ)+wc`=<-nC) zc=&_TEEse-X3}ED5|9X8G@`dl3qu zN?JTTRfu+~L{sD$L59@b`TN^H?tb!g0kkeG?~rs#@j9r?ovuzN1IoX7@Wa`a@1Nay k^<|dalu=etTq?sZ9VJoLQ3kh