fix

Author: wuchong

…adapter/Flink22MultipleParameterToolTest …er/Flink22MultipleParameterToolTest.javafluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/adapter/Flink22MultipleParameterToolTest renamed to fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/adapter/Flink22MultipleParameterToolTest.java fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/adapter/Flink22MultipleParameterToolTest renamed to fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/adapter/Flink22MultipleParameterToolTest.java

@@ -18,4 +18,4 @@
 package org.apache.fluss.flink.adapter;
 
 /** Test for {@link MultipleParameterToolAdapter} in flink 2.2. */
-public class Flink22MultipleParameterToolTest extends FlinkMultipleParameterToolTest {}
+public class Flink22MultipleParameterToolTest extends FlinkMultipleParameterToolTest {}

fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogTest.java

@@ -139,7 +139,7 @@ private CatalogTable newCatalogTable(
         return new ResolvedCatalogTable(origin, resolvedSchema);
     }
 
-    protected CatalogMaterializedTable newCatalogMaterializedTable(
+    private CatalogMaterializedTable newCatalogMaterializedTable(
             ResolvedSchema resolvedSchema,
             CatalogMaterializedTable.RefreshMode refreshMode,
             Map<String, String> options) {

fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/FlinkTableSourceBatchITCase.java

@@ -311,7 +311,7 @@ void testCountPushDown(boolean partitionTable) throws Exception {
                         "Currently, Fluss only support queries on table with datalake enabled or point queries on primary key when it's in batch execution mode.");
     }
 
-    protected String prepareSourceTable(String[] keys, String partitionedKey) throws Exception {
+    private String prepareSourceTable(String[] keys, String partitionedKey) throws Exception {
         String tableName =
                 String.format("test_%s_%s", String.join("_", keys), RandomUtils.nextInt());
         if (partitionedKey == null) {
@@ -367,7 +367,7 @@ protected String prepareSourceTable(String[] keys, String partitionedKey) throws
         return tableName;
     }
 
-    protected String prepareLogTable() throws Exception {
+    private String prepareLogTable() throws Exception {
         String tableName = String.format("test_log_table_%s", RandomUtils.nextInt());
         tEnv.executeSql(
                 String.format(