[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #7287: [INLONG-7286][Sort] Fix issue of tableidentifier being null when addRow

[via GitHub]

yunqingmoswu commented on code in PR #7287:
URL: https://github.com/apache/inlong/pull/7287#discussion_r1091507002


##########
inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java:
##########
@@ -441,7 +441,10 @@ private void addBatch(T row) {
 
     @SuppressWarnings({"unchecked"})
     private void addRow(RowKind rowKind, JsonNode rootNode, JsonNode 
physicalNode, JsonNode updateBeforeNode,
-            Map<String, String> physicalData, Map<String, String> 
updateBeforeData) {
+            Map<String, String> physicalData, Map<String, String> 
updateBeforeData) throws IOException {
+        String tableIdentifier = StringUtils.join(

Review Comment:
   make sure this can resolve it ?



-- 
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: commits-unsubscr...@inlong.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org