[hotfix] Make abstract ITCase's variable as protected. (apache#944)

Author: loserwang1024

fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/catalog/FlinkCatalogITCase.java

@@ -82,7 +82,7 @@ static Configuration initClusterConf() {
     static final String DEFAULT_DB = FlinkCatalogOptions.DEFAULT_DATABASE.defaultValue();
     static Catalog catalog;
 
-    private TableEnvironment tEnv;
+    protected TableEnvironment tEnv;
 
     @BeforeAll
     static void beforeAll() {

fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/sink/FlinkTableSinkITCase.java

@@ -79,9 +79,9 @@ abstract class FlinkTableSinkITCase extends AbstractTestBase {
     static final String CATALOG_NAME = "testcatalog";
     static final String DEFAULT_DB = "defaultdb";
 
-    private StreamExecutionEnvironment env;
-    private StreamTableEnvironment tEnv;
-    private TableEnvironment tBatchEnv;
+    protected StreamExecutionEnvironment env;
+    protected StreamTableEnvironment tEnv;
+    protected TableEnvironment tBatchEnv;
 
     static Stream<Arguments> writePartitionedTableParams() {
         return Stream.of(

fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/source/FlinkTableSourceBatchITCase.java

@@ -54,7 +54,7 @@ abstract class FlinkTableSourceBatchITCase extends FlinkTestBase {
 
     static final String CATALOG_NAME = "testcatalog";
     static final String DEFAULT_DB = "defaultdb";
-    private StreamTableEnvironment tEnv;
+    protected StreamTableEnvironment tEnv;
 
     @BeforeEach
     void before() {

fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/source/FlinkTableSourceITCase.java

@@ -74,8 +74,8 @@ abstract class FlinkTableSourceITCase extends FlinkTestBase {
 
     static final String CATALOG_NAME = "testcatalog";
     static final String DEFAULT_DB = "defaultdb";
-    private StreamExecutionEnvironment execEnv;
-    private StreamTableEnvironment tEnv;
+    protected StreamExecutionEnvironment execEnv;
+    protected StreamTableEnvironment tEnv;
 
     @BeforeEach
     void before() {

fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/source/FlussSourceITCase.java

@@ -70,7 +70,7 @@ public class FlussSourceITCase extends FlinkTestBase {
     private final TableDescriptor pkTableDescriptor =
             TableDescriptor.builder().schema(PK_SCHEMA).distributedBy(1, "orderId").build();
 
-    private StreamExecutionEnvironment env;
+    protected StreamExecutionEnvironment env;
 
     @BeforeEach
     public void before() {