corgy-w commented on issue #7429:
URL: https://github.com/apache/seatunnel/issues/7429#issuecomment-2308746618
> 分析了一下源代码：ElasticsearchRowSerializer.java 2.3.3版本： private Map<String,
Object> toDocumentMap(SeaTunnelRow row) { String[] fieldNames =
seaTunnelRowType.getFieldNames(); Map<String, Object> doc = new
HashMap<>(fieldNames.length); Object[] fields = row.getFields(); for (int i =
0; i < fieldNames.length; i++) { Object value = fields[i]; if (value instanceof
Temporal) { // jackson not support jdk8 new time api doc.put(fieldNames[i],
value.toString()); } else { doc.put(fieldNames[i], value); } } return doc; }
>
> 2.3.6版本： private Map<String, Object> toDocumentMap(SeaTunnelRow row,
SeaTunnelRowType rowType) { String[] fieldNames = rowType.getFieldNames();
Map<String, Object> doc = new HashMap<>(fieldNames.length); Object[] fields =
row.getFields(); for (int i = 0; i < fieldNames.length; i++) { Object value =
fields[i]; if (value == null) { } else if (value instanceof SeaTunnelRow) {
doc.put( fieldNames[i], toDocumentMap( (SeaTunnelRow) value, (SeaTunnelRowType)
rowType.getFieldType(i))); } else { doc.put(fieldNames[i],
convertValue(value)); } } return doc; }
>
> 应该就是 if (value == null) {}这里引起的，那如果是这样的话，必须在同步之前强制进行es
mapping提交了，想知道一下这里加null判断的初衷是什么？
All right, I'll check it and let you know
--
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]
