We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 9509cab + ff8d612 commit 7a3e1deCopy full SHA for 7a3e1de
1 file changed
core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java
@@ -423,7 +423,7 @@ private void joinFun(Object pollObj,
423
424
RowTypeInfo sideOutTypeInfo = buildOutRowTypeInfo(sideJoinFieldInfo, mappingTable);
425
426
- TupleTypeInfo tupleTypeInfo = new TupleTypeInfo(sideOutTypeInfo);
+ TupleTypeInfo tupleTypeInfo = new TupleTypeInfo(Types.BOOLEAN, sideOutTypeInfo);
427
dsOut.getTransformation().setOutputType(tupleTypeInfo);
428
429
String targetTableName = joinInfo.getNewTableName();
0 commit comments