fix(data-transfer): avoid task failure by processing exception messages (#2779)

* optimize error message

* fix typo

Author: LuckyPickleZZ

server/plugins/task-plugin-ob-mysql/src/main/java/com/oceanbase/odc/plugin/task/obmysql/datatransfer/task/BaseOceanBaseTransferJob.java

@@ -19,6 +19,7 @@
 import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
+import java.util.Optional;
 import java.util.function.Predicate;
 import java.util.stream.Collectors;
 
@@ -27,13 +28,15 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.oceanbase.odc.common.util.ExceptionUtils;
 import com.oceanbase.odc.core.shared.Verify;
 import com.oceanbase.odc.core.shared.constant.TaskStatus;
 import com.oceanbase.odc.plugin.task.api.datatransfer.DataTransferJob;
 import com.oceanbase.odc.plugin.task.api.datatransfer.model.DataTransferTaskResult;
 import com.oceanbase.odc.plugin.task.api.datatransfer.model.ObjectResult;
 import com.oceanbase.tools.loaddump.common.enums.DataFormat;
 import com.oceanbase.tools.loaddump.common.enums.ObjectType;
+import com.oceanbase.tools.loaddump.common.enums.ServerMode;
 import com.oceanbase.tools.loaddump.common.model.BaseParameter;
 import com.oceanbase.tools.loaddump.common.model.DumpParameter;
 import com.oceanbase.tools.loaddump.common.model.LoadParameter;
@@ -175,7 +178,12 @@ public DataTransferTaskResult call() throws Exception {
             if (dataContext != null) {
                 dataContext.shutdownNow();
             }
-            throw e;
+            String rootMessage = Optional.ofNullable(ExceptionUtils.getRootCause(e)).orElseThrow(() -> e).getMessage();
+            if (shouldEatException(rootMessage)) {
+                LOGGER.warn(rootMessage);
+            } else {
+                throw e;
+            }
         }
 
         validAllTasksSuccessed();
@@ -242,6 +250,35 @@ private void syncWaitFinished(@NonNull TaskContext context, boolean isTransferSc
         throw new InterruptedException("loop interrupted");
     }
 
+    /**
+     * @return a bool value. If it's true, the exception should be eaten.
+     */
+    private boolean shouldEatException(String errorMessage) {
+        if (StringUtils.isEmpty(errorMessage)) {
+            return false;
+        }
+        if (errorMessage.contains("No subfiles are generated from path")) {
+            return true;
+        }
+        if (errorMessage.contains("table or view does not exist")) {
+            ServerMode serverMode = parameter.getConnectionKey().getServerMode();
+            if (serverMode.isMysqlMode()) {
+                LOGGER.warn(
+                        "The current user may lack access to the oceanbase database. "
+                                + "You can execute the following SQL and retry the transfer task:\n"
+                                + "grant select on oceanbase.* to {}",
+                        parameter.getUser());
+            } else {
+                LOGGER.warn(
+                        "The current user may lack of DBA permission. "
+                                + "You can execute the following SQL and retry the transfer task:\n"
+                                + "grant select any dictionary to {}",
+                        parameter.getUser());
+            }
+        }
+        return false;
+    }
+
     private void shutdownContext(TaskContext context) {
         try {
             context.shutdown();