@Override
    public RowData deserializeInternal(@Nullable byte[] message) throws Exception {
        if (message == null) {
            return null;
        }

        String jsonStr = new String(message, charset);
        RowData rowData = null;
        try {
            rowData = (RowData) runtimeConverter.convert(jsonStr);
        } catch (Throwable t) {
            failureHandler.onParsingMsgFailure(jsonStr, new RuntimeException(
                    String.format("Could not properly deserialize json. Text=[%s].", jsonStr), t));
        }
        return rowData;
    }
Timestamp format specification which is used to parse timestamp.
inlong-sort/sort-formats/format-rowdata/format-rowdata-json/src/main/java/org/apache/inlong/sort/formats/json/JsonRowDataDeserializationSchema.java