fixed

sunxiaojian · sunxiaojian · commit a7cc74afe7fa · 2025-03-11T23:54:10.000+08:00
diff --git a/flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkEnvIT.java b/flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkEnvIT.java
@@ -102,6 +102,8 @@ protected String flinkByPass(String key) {
     return PropertiesConverter.FLINK_PROPERTY_PREFIX + key;
   }
 
+  protected abstract String getProvider();
+
   private void initIcebergRestServiceEnv() {
     ignoreIcebergRestService = false;
     Map<String, String> icebergRestServiceConfigs = new HashMap<>();
@@ -262,6 +264,4 @@ private String getIcebergRestServiceUri() {
     return String.format(
         "http://%s:%d/iceberg/", jettyServerConfig.getHost(), jettyServerConfig.getHttpPort());
   }
-
-  protected abstract String getProvider();
 }

Original file line number	Diff line number	Diff line change
`@@ -102,6 +102,8 @@ protected String flinkByPass(String key) {`
`102`	`102`	`return PropertiesConverter.FLINK_PROPERTY_PREFIX + key;`
`103`	`103`	`}`
`104`	`104`
	`105`	`+ protected abstract String getProvider();`
	`106`	`+`
`105`	`107`	`private void initIcebergRestServiceEnv() {`
`106`	`108`	`ignoreIcebergRestService = false;`
`107`	`109`	`Map<String, String> icebergRestServiceConfigs = new HashMap<>();`
`@@ -262,6 +264,4 @@ private String getIcebergRestServiceUri() {`
`262`	`264`	`return String.format(`
`263`	`265`	`"http://%s:%d/iceberg/", jettyServerConfig.getHost(), jettyServerConfig.getHttpPort());`
`264`	`266`	`}`
`265`		`-`
`266`		`- protected abstract String getProvider();`
`267`	`267`	`}`