Skip to content

Commit 91f2bbd

Browse files
committed
[Hotfix][service] Apply InternalOptionSpec in EnvInitializer.java
1 parent 55ac55c commit 91f2bbd

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

  • streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
import org.apache.streampark.common.conf.CommonConfig;
2121
import org.apache.streampark.common.conf.ConfigKeys;
2222
import org.apache.streampark.common.conf.InternalConfigHolder;
23-
import org.apache.streampark.common.conf.InternalOption;
23+
import org.apache.streampark.common.conf.InternalOptionSpec;
2424
import org.apache.streampark.common.conf.Workspace;
2525
import org.apache.streampark.common.enums.StorageType;
2626
import org.apache.streampark.common.fs.FsOperator;
@@ -96,7 +96,7 @@ private void initConfig() {
9696
.filter(env::containsProperty)
9797
.forEach(
9898
key -> {
99-
InternalOption<?> config = InternalConfigHolder.getConfig(key);
99+
InternalOptionSpec config = InternalConfigHolder.getConfig(key);
100100
AssertUtils.notNull(config);
101101
InternalConfigHolder.set(config, env.getProperty(key, config.classType()));
102102
});

0 commit comments

Comments
 (0)