Skip to content

Commit 0079ad2

Browse files
committed
Correcting header file name
1 parent 4096401 commit 0079ad2

File tree

9 files changed

+440
-446
lines changed

9 files changed

+440
-446
lines changed

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/catalog/Flink22CatalogITCase.java

Lines changed: 157 additions & 163 deletions
Large diffs are not rendered by default.

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalog22Test.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
import java.util.Arrays;
2929
import java.util.Collections;
3030

31-
/** Test for {@link Flink21Catalog}. */
31+
/** Test for {@link Flink22Catalog}. */
3232
public class FlinkCatalog22Test extends FlinkCatalogTest {
3333

3434
@Override

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/metrics/Flink22MetricsITCase.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,5 +17,6 @@
1717

1818
package org.apache.fluss.flink.metrics;
1919

20-
/** IT case for metrics in Flink 2.1. */
21-
public class Flink22MetricsITCase extends FlinkMetricsITCase {}
20+
/** IT case for metrics in Flink 2.2. */
21+
public class Flink22MetricsITCase extends FlinkMetricsITCase {
22+
}

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/procedure/Flink22ProcedureITCase.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,5 +17,6 @@
1717

1818
package org.apache.fluss.flink.procedure;
1919

20-
/** IT case for procedure in Flink 2.1. */
21-
public class Flink22ProcedureITCase extends FlinkProcedureITCase {}
20+
/** IT case for procedure in Flink 2.2. */
21+
public class Flink22ProcedureITCase extends FlinkProcedureITCase {
22+
}

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/security/acl/Flink22AuthorizationITCase.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,5 +17,6 @@
1717

1818
package org.apache.fluss.flink.security.acl;
1919

20-
/** IT case for authorization in Flink 2.1. */
21-
public class Flink22AuthorizationITCase extends FlinkAuthorizationITCase {}
20+
/** IT case for authorization in Flink 2.2. */
21+
public class Flink22AuthorizationITCase extends FlinkAuthorizationITCase {
22+
}

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/sink/Flink22TableSinkITCase.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,5 +17,6 @@
1717

1818
package org.apache.fluss.flink.sink;
1919

20-
/** IT case for {@link FlinkTableSink} in Flink 2.1. */
21-
public class Flink22TableSinkITCase extends FlinkTableSinkITCase {}
20+
/** IT case for {@link FlinkTableSink} in Flink 2.2. */
21+
public class Flink22TableSinkITCase extends FlinkTableSinkITCase {
22+
}

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/source/Flink22TableSourceBatchITCase.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,5 +17,6 @@
1717

1818
package org.apache.fluss.flink.source;
1919

20-
/** IT case for batch source in Flink 2.1. */
21-
public class Flink22TableSourceBatchITCase extends FlinkTableSourceBatchITCase {}
20+
/** IT case for batch source in Flink 2.2. */
21+
public class Flink22TableSourceBatchITCase extends FlinkTableSourceBatchITCase {
22+
}

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/source/Flink22TableSourceFailOverITCase.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,5 +17,6 @@
1717

1818
package org.apache.fluss.flink.source;
1919

20-
/** IT case for source failover and recovery in Flink 2.1. */
21-
public class Flink22TableSourceFailOverITCase extends FlinkTableSourceFailOverITCase {}
20+
/** IT case for source failover and recovery in Flink 2.2. */
21+
public class Flink22TableSourceFailOverITCase extends FlinkTableSourceFailOverITCase {
22+
}

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/source/Flink22TableSourceITCase.java

Lines changed: 264 additions & 270 deletions
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)