Skip to content

Commit be084d7

Browse files
committed
[fix] 修复类型大小写不匹配导致加载插件不正确
1 parent 0ff459b commit be084d7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/java/com/dtstack/flink/sql/exec/ExecuteProcessHelper.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -321,7 +321,7 @@ public static Set<URL> registerTable(SqlTree sqlTree, StreamExecutionEnvironment
321321
URL sinkTablePathUrl = PluginUtil.buildSourceAndSinkPathByLoadMode(tableInfo.getType(), AbstractTargetTableInfo.TARGET_SUFFIX, localSqlPluginPath, remoteSqlPluginPath, pluginLoadMode);
322322
pluginClassPathSets.add(sinkTablePathUrl);
323323
} else if (tableInfo instanceof AbstractSideTableInfo) {
324-
String sideOperator = ECacheType.ALL.name().equals(((AbstractSideTableInfo) tableInfo).getCacheType()) ? "all" : "async";
324+
String sideOperator = ECacheType.ALL.name().equalsIgnoreCase(((AbstractSideTableInfo) tableInfo).getCacheType()) ? "all" : "async";
325325
sideTableMap.put(tableInfo.getName(), (AbstractSideTableInfo) tableInfo);
326326

327327
URL sideTablePathUrl = PluginUtil.buildSidePathByLoadMode(tableInfo.getType(), sideOperator, AbstractSideTableInfo.TARGET_SUFFIX, localSqlPluginPath, remoteSqlPluginPath, pluginLoadMode);

0 commit comments

Comments
 (0)