Issue with jobs not completing when some schema's were already present.

dstreev · Feb 4, 2025 · ce0e1e8 · ce0e1e8
1 parent dc3ae2a
commit ce0e1e8
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 9 deletions.
diff --git a/pom.xml b/pom.xml
@@ -28,7 +28,7 @@
 
     <groupId>com.cloudera.utils.hadoop</groupId>
     <artifactId>hms-mirror</artifactId>
-    <version>2.3.0.8</version>
+    <version>2.3.0.9</version>
     <packaging>jar</packaging>
 
     <name>hms-mirror</name>

diff --git a/src/main/java/com/cloudera/utils/hms/mirror/service/HMSMirrorAppService.java b/src/main/java/com/cloudera/utils/hms/mirror/service/HMSMirrorAppService.java
@@ -559,14 +559,8 @@ public Future<Boolean> run() {
                     try {
                         if (sf.isDone() && sf.get() != null) {
                             TableMirror tableMirror = sf.get().getTableMirror();
-                            if (sf.get().getStatus() == ReturnStatus.Status.ERROR) {
-                                // Check if the table was removed, so that's not a processing error.
-                                if (tableMirror != null) {
-                                    if (!tableMirror.isRemove()) {
-                                        rtn = Boolean.FALSE;
-                                    }
-                                }
-                            } else if (sf.get().getStatus() == ReturnStatus.Status.SUCCESS) {
+                            // Only push SUCCESSFUL tables to the migrationExecutions list.
+                            if (sf.get().getStatus() == ReturnStatus.Status.SUCCESS) {
                                 // Success means add table the execution list.
                                 migrationExecutions.add(tableMirror);
                             }