回滚测试修改

Author: xuchao

core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java

@@ -423,7 +423,7 @@ private void joinFun(Object pollObj,
 
         RowTypeInfo sideOutTypeInfo = buildOutRowTypeInfo(sideJoinFieldInfo, mappingTable);
 
-        TupleTypeInfo tupleTypeInfo = new TupleTypeInfo(sideOutTypeInfo);
+        TupleTypeInfo tupleTypeInfo = new TupleTypeInfo(Types.BOOLEAN, sideOutTypeInfo);
         dsOut.getTransformation().setOutputType(tupleTypeInfo);
 
         String targetTableName = joinInfo.getNewTableName();