Aitozi commented on code in PR #21522:
URL: https://github.com/apache/flink/pull/21522#discussion_r1138315797
##########
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserDMLHelper.java:
##########
@@ -154,11 +154,12 @@ public HiveParserDMLHelper(
RelDataTypeFactory typeFactory = plannerContext.getTypeFactory();
LinkedHashMap<String, RelDataType> targetColToCalcType = new
LinkedHashMap<>();
List<TypeInfo> targetHiveTypes = new ArrayList<>();
- TableSchema tableSchema =
-
HiveParserUtils.fromUnresolvedSchema(destTable.getUnresolvedSchema());
- String[] fieldNames = tableSchema.getFieldNames();
+ ResolvedSchema resolvedSchema =
+
catalogManager.resolveCatalogTable(destTable).getResolvedSchema();
Review Comment:
Or we can just create a resolved version table from the
`org.apache.flink.table.catalog.hive.util.HiveTableUtil#createSchema()` ? Since
they are all physical column and the dataType have been converted.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
