Skip to content

Commit a0a8e7a

Browse files
committed
remove
1 parent 539fcf3 commit a0a8e7a

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/SideSqlExec.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -747,7 +747,7 @@ private void joinFun(Object pollObj, Map<String, Table> localTableCache,
747747
DataStream adaptStream = tableEnv.toRetractStream(targetTable, org.apache.flink.types.Row.class)
748748
.map((Tuple2<Boolean, Row> f0) -> { return f0.f1; })
749749
.returns(Row.class);
750-
adaptStream.getTransformation().setOutputType(leftTypeInfo);
750+
//adaptStream.getTransformation().setOutputType(leftTypeInfo);
751751

752752
//join side table before keyby ===> Reducing the size of each dimension table cache of async
753753
if(sideTableInfo.isPartitionedJoin()){

0 commit comments

Comments
 (0)