diff --git a/client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java b/client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java
index 2be21733d5..927faec270 100644
--- a/client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java
+++ b/client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java
@@ -314,11 +314,11 @@ public Object getESDataFromDmlData(ESMapping mapping,String owner, Map<String, O
         Object resultIdVal = null;
         for (FieldItem fieldItem : schemaItem.getSelectFields().values()) {
             ColumnItem columnItem = fieldItem.getColumnItems().iterator().next();
-            if (columnItem.getOwner() == null || columnItem.getColumnName() == null) {
+            if (columnItem.getColumnName() == null) {
                 continue;
             }
 
-            if (!columnItem.getOwner().equals(owner)) {
+            if (columnItem.getOwner() != null && !columnItem.getOwner().equals(owner)) {
                 continue;
             }