Skip to content

Commit

Permalink
[FLINK-8472] [kafka, test] Extend FlinkKafkaConsumerBaseMigrationTest…
Browse files Browse the repository at this point in the history
… for Flink 1.4
  • Loading branch information
tzulitai committed Feb 6, 2018
1 parent e609f81 commit 535d139
Showing 3 changed files with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
@@ -93,7 +93,7 @@ public class FlinkKafkaConsumerBaseMigrationTest {

@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection<MigrationVersion> parameters () {
return Arrays.asList(MigrationVersion.v1_2, MigrationVersion.v1_3);
return Arrays.asList(MigrationVersion.v1_2, MigrationVersion.v1_3, MigrationVersion.v1_4);
}

public FlinkKafkaConsumerBaseMigrationTest(MigrationVersion testMigrateVersion) {
Binary file not shown.
Binary file not shown.

0 comments on commit 535d139

Please sign in to comment.