[TD-5517]<fix>: return error when apply schema action failed

75c217e6 · shenglian zhou · e393a561 · 75c217e6
隐藏空白更改
内联并排

Showing with 10 addition and 2 deletion

src/client/src/tscParseLineProtocol.c src/client/src/tscParseLineProtocol.c +10 -2

未找到文件。
--- a/src/client/src/tscParseLineProtocol.c
+++ b/src/client/src/tscParseLineProtocol.c
@@ -518,7 +518,11 @@ static int32_t modifyDBSchemas(TAOS* taos, SArray* stableSchemas) {
        bool actionNeeded = false;
        generateSchemaAction(pointTag, dbTagHash, dbSchema.tags, true, pointSchema->sTableName, &schemaAction, &actionNeeded);
        if (actionNeeded) {
-          applySchemaAction(taos, &schemaAction);
+          code = applySchemaAction(taos, &schemaAction);
+          if (code != 0) {
+            destroySmlSTableSchema(&dbSchema);
+            return code;
+          }
        }
      }

@@ -532,7 +536,11 @@ static int32_t modifyDBSchemas(TAOS* taos, SArray* stableSchemas) {
        bool actionNeeded = false;
        generateSchemaAction(pointCol, dbFieldHash, dbSchema.fields,false, pointSchema->sTableName, &schemaAction, &actionNeeded);
        if (actionNeeded) {
-          applySchemaAction(taos, &schemaAction);
+          code = applySchemaAction(taos, &schemaAction);
+          if (code != 0) {
+            destroySmlSTableSchema(&dbSchema);
+            return code;
+          }
        }
      }