[fix-33847][core] fix other sink except kafka table schema not found problem.
@@ -124,4 +124,12 @@ public class FunctionManager {
}
}
+ public static TypeInformation[] transformTypes(Class[] fieldTypes) {
+ TypeInformation[] types = new TypeInformation[fieldTypes.length];
+ for (int i = 0; i < fieldTypes.length; i++) {
+ types[i] = TypeInformation.of(fieldTypes[i]);
+ }
+ return types;
+ }
+
}
\ No newline at end of file
