add log for ObSingleOpEntity decode err (#396)

Author: GroundWu

src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableRemoting.java

@@ -169,8 +169,13 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
                     "receive unexpected command code: " + response.getCmdCode().value());
                 throw new ObTableUnexpectedException(errMessage, resultCode.getRcode());
             }
-
-            payload.decode(buf);
+            try {
+                payload.decode(buf);
+            } catch (Exception e) {
+                String errMessage = TraceUtil.formatTraceMessage(conn, response,
+                        "decode meet exception, cause: " + e.getMessage());
+                throw new RuntimeException(errMessage, e);
+            }
             return payload;
         } finally {
             // Very important to release ByteBuf memory

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/ObTableSerialUtil.java

@@ -51,7 +51,7 @@ public static ObTableObjType decodeTableObjType(ByteBuf buf) {
         byte type = Serialization.decodeI8(buf);
         ObTableObjType objType = ObTableObjType.valueOf(type);
         if (objType == null) {
-            throw new IllegalArgumentException("cannot get table object type from value");
+            throw new IllegalArgumentException("cannot get table object type from value, type: " + type);
         }
         return objType;
     }

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/ObTableSingleOpEntity.java

@@ -161,31 +161,39 @@ private byte[] parseBitMap(long bitLen, List<String> aggColumnNames, List<String
      */
     @Override
     public Object decode(ByteBuf buf) {
-        // 0. decode header
-        super.decode(buf);
-
-        // 1. rowkey bitmap
-        rowKeyBitLen = Serialization.decodeVi64(buf);
-        rowKeyBitMap = parseBitMap(rowKeyBitLen, aggRowKeyNames, rowKeyNames, buf);
-
-        // 2. rowkey obobj
-        int len = (int) Serialization.decodeVi64(buf);
-        for (int i = 0; i < len; i++) {
-            ObObj obj = new ObObj();
-            ObTableSerialUtil.decode(buf, obj);
-            rowkey.add(obj);
-        }
+        int rowkeyLen = 0;
+        int propLen = 0;
+        try {
+            // 0. decode header
+            super.decode(buf);
+
+            // 1. rowkey bitmap
+            rowKeyBitLen = Serialization.decodeVi64(buf);
+            rowKeyBitMap = parseBitMap(rowKeyBitLen, aggRowKeyNames, rowKeyNames, buf);
+
+            // 2. rowkey obobj
+            rowkeyLen = (int) Serialization.decodeVi64(buf);
+            for (int i = 0; i < rowkeyLen; i++) {
+                ObObj obj = new ObObj();
+                ObTableSerialUtil.decode(buf, obj);
+                rowkey.add(obj);
+            }
 
-        // 3. properties bitmap
-        propertiesBitLen = Serialization.decodeVi64(buf);
-        propertiesBitMap = parseBitMap(propertiesBitLen, aggPropertiesNames, propertiesNames, buf);
+            // 3. properties bitmap
+            propertiesBitLen = Serialization.decodeVi64(buf);
+            propertiesBitMap = parseBitMap(propertiesBitLen, aggPropertiesNames, propertiesNames, buf);
 
-        // 4. properties obobj
-        len = (int) Serialization.decodeVi64(buf);
-        for (int i = 0; i < len; i++) {
-            ObObj obj = new ObObj();
-            ObTableSerialUtil.decode(buf, obj);
-            propertiesValues.add(obj);
+            // 4. properties obobj
+            propLen = (int) Serialization.decodeVi64(buf);
+            for (int i = 0; i < propLen; i++) {
+                ObObj obj = new ObObj();
+                ObTableSerialUtil.decode(buf, obj);
+                propertiesValues.add(obj);
+            }
+        } catch (Exception e) {
+            String errMsg = String.format("ObTableSingleOpEntity decode exception: rowkeyBitLen=%d, rowkeyLen=%d, propertiesBitLen=%d, propertiesLen=%d"
+                    , rowKeyBitLen, rowkeyLen, propertiesBitLen, propLen);
+            throw new IllegalArgumentException(errMsg + ", cause: " + e.getMessage(), e);
         }
 
         return this;