fix

dataroaring · Jun 20, 2024 · 96b8bd5 · 96b8bd5
1 parent 0222f3f
commit 96b8bd5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/persist/gson/GsonUtils.java b/fe/fe-core/src/main/java/org/apache/doris/persist/gson/GsonUtils.java
@@ -181,6 +181,7 @@
 import org.apache.doris.load.loadv2.LoadJobFinalOperation;
 import org.apache.doris.load.loadv2.MiniLoadJob;
 import org.apache.doris.load.loadv2.MiniLoadTxnCommitAttachment;
+import org.apache.doris.load.loadv2.SparkLoadJob;
 import org.apache.doris.load.loadv2.SparkLoadJob.SparkLoadJobStateUpdateInfo;
 import org.apache.doris.load.routineload.AbstractDataSourceProperties;
 import org.apache.doris.load.routineload.KafkaProgress;
@@ -548,7 +549,8 @@ public class GsonUtils {
  .registerSubtype(CloudBrokerLoadJob.class, CloudBrokerLoadJob.class.getSimpleName())
  .registerSubtype(CopyJob.class, CopyJob.class.getSimpleName())
  .registerSubtype(InsertLoadJob.class, InsertLoadJob.class.getSimpleName())
- .registerSubtype(MiniLoadJob.class, MiniLoadJob.class.getSimpleName());
+ .registerSubtype(MiniLoadJob.class, MiniLoadJob.class.getSimpleName())
+ .registerSubtype(SparkLoadJob.class, SparkLoadJob.class.getSimpleName());
 
  private static RuntimeTypeAdapterFactory<PartitionItem> partitionItemTypeAdapterFactory
  = RuntimeTypeAdapterFactory.of(PartitionItem.class, "clazz")