lordcheng10 opened a new pull request, #7456: URL: https://github.com/apache/inlong/pull/7456
…, the dirty data type should be converted to RowData for archiving. ### Prepare a Pull Request - Fixes https://github.com/apache/inlong/issues/7455 ### Motivation Start a mysql synchronization task for Iceberg and insert a type mismatch of dirty data, the archived dirty data should contain data content，eg: [time] [database] [table] [data] But the test found that it does not contain data：  ### Modifications When the types do not match, the dirty data type passed to the handleDirtyData method should not be in json format, but should be converted into a RowData object: https://github.com/apache/inlong/blob/08887b1dc240c015775cfc3c16b5ec8666833a78/inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/DynamicSchemaHandleOperator.java#L314-L316 -- 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]
