diff --git a/main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/metadata/MetadataToolAvroHelper.java b/main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/metadata/MetadataToolAvroHelper.java index e77fc4e4fc..fcd9b20b7a 100644 --- a/main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/metadata/MetadataToolAvroHelper.java +++ b/main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/metadata/MetadataToolAvroHelper.java @@ -181,9 +181,9 @@ public final class MetadataToolAvroHelper { || JavaTypesManager.CHARACTER.getId().equals(tt) || JavaTypesManager.PASSWORD.getId().equals(tt)) { type = AvroUtils._string(); } - - // Types with unknown elements, store as binary - if (JavaTypesManager.OBJECT.getId().equals(tt)) { + + // Types with Document/Unknown elements, store as binary + if ("id_Document".equals(tt) || JavaTypesManager.OBJECT.getId().equals(tt)) { type = AvroUtils._string(); }