Skip to content

Commit 787d302

Browse files
committed
[fix-34473][core] 修复设置全局并行度后,全量维表单独设置并行度不生效。
1 parent 910dd74 commit 787d302

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/java/com/dtstack/flink/sql/side/operator/SideWithAllCacheOperator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,6 @@ private static BaseAllReqRow loadFlatMap(String sideType, String sqlRootDir, Row
6060
public static DataStream getSideJoinDataStream(DataStream inputStream, String sideType, String sqlRootDir, RowTypeInfo rowTypeInfo, JoinInfo joinInfo,
6161
List<FieldInfo> outFieldInfoList, AbstractSideTableInfo sideTableInfo, String pluginLoadMode) throws Exception {
6262
BaseAllReqRow allReqRow = loadFlatMap(sideType, sqlRootDir, rowTypeInfo, joinInfo, outFieldInfoList, sideTableInfo, pluginLoadMode);
63-
return inputStream.flatMap(allReqRow);
63+
return inputStream.flatMap(allReqRow).setParallelism(sideTableInfo.getParallelism());
6464
}
6565
}

0 commit comments

Comments
 (0)