Skip to content

Commit

Permalink
[FLINK-35958][release] Generate reference data for state migration te…
Browse files Browse the repository at this point in the history
…sts based on release-1.20.0
  • Loading branch information
reswqa committed Aug 7, 2024
1 parent 68d8174 commit 8f587b7
Show file tree
Hide file tree
Showing 946 changed files with 38,168 additions and 6 deletions.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@

Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@

Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
*
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
*
Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
��
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
@���1��
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
@���1��
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
 ApacheFlink
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
B��y
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
B��y
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
Hass�
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
Hass�
Expand Down
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Empty file.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@

Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
%123456789012345678901234567890123456
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
$123456789012345678901234567890123456
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
Expand Up @@ -77,10 +77,10 @@
* processing-time windows operator of previous Flink versions.
*/
@ExtendWith(ParameterizedTestExtension.class)
class WindowOperatorMigrationTest implements MigrationTest {
public class WindowOperatorMigrationTest implements MigrationTest {

@Parameters(name = "Migration Savepoint: {0}")
private static Collection<FlinkVersion> parameters() {
public static Collection<FlinkVersion> parameters() {
return FlinkVersion.rangeOf(
FlinkVersion.v1_8, MigrationTest.getMostRecentlyPublishedVersion());
}
Expand Down
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
flink
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
6 changes: 6 additions & 0 deletions flink-test-utils-parent/flink-migration-test-utils/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,12 @@ under the License.
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-test-utils-junit</artifactId>
<scope>compile</scope>
</dependency>

<dependency>
<groupId>org.junit.vintage</groupId>
<artifactId>junit-vintage-engine</artifactId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@

import org.apache.flink.FlinkVersion;
import org.apache.flink.test.util.MigrationTest;
import org.apache.flink.testutils.junit.extensions.parameterized.Parameters;

import org.junit.ClassRule;
import org.junit.Rule;
Expand Down Expand Up @@ -155,10 +156,13 @@ private static Object createMigrationTest(Class<?> migrationTestClass) throws Ex
Constructor<?> constructor = constructors[0];
constructor.setAccessible(true);

// Check if we could find method labeled with @Parameterized.Parameters
System.out.println("create test!!!");
// Check if we could find method labeled with @Parameterized.Parameters or @Parameters
for (Method method : migrationTestClass.getMethods()) {
if (Modifier.isStatic(method.getModifiers())
&& method.isAnnotationPresent(Parameterized.Parameters.class)) {
&& (method.isAnnotationPresent(Parameterized.Parameters.class)
|| method.isAnnotationPresent(Parameters.class))) {
System.out.println("ffffffff!!!!");
Object argumentLists = method.invoke(null);
if (argumentLists instanceof Collection) {
return constructor.newInstance(
Expand All @@ -176,6 +180,6 @@ private static Object createMigrationTest(Class<?> migrationTestClass) throws Ex
throw new RuntimeException(
"Could not create the object for "
+ migrationTestClass
+ ": No default constructor or @Parameterized.Parameters method found.");
+ ": No default constructor or @Parameterized.Parameters or @Parameters method found.");
}
}
Original file line number Diff line number Diff line change
@@ -1 +1 @@
v1_19
v1_20
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
MANIFEST-000004
Loading

0 comments on commit 8f587b7

Please sign in to comment.