[FSTORE-1053] Never ending materialization job (#1589)

logicalclocks · Oct 19, 2023 · f6dbf57 · f6dbf57
1 parent 4398ba1
commit f6dbf57
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/hopsworks-common/src/main/java/io/hops/hopsworks/common/jobs/yarn/YarnJob.java b/hopsworks-common/src/main/java/io/hops/hopsworks/common/jobs/yarn/YarnJob.java
@@ -249,10 +249,10 @@ public final void execute(String args) {
         public Void run() {
           YarnClientWrapper yarnClientWrapper = null;
           try {
-            yarnClientWrapper = services.getYarnClientService().getYarnClient(hdfsUser.getUserName());
-            yarnClient = yarnClientWrapper.getYarnClient();
             boolean proceed = false;
             try {
+              yarnClientWrapper = services.getYarnClientService().getYarnClient(hdfsUser.getUserName());
+              yarnClient = yarnClientWrapper.getYarnClient();
               proceed = setupJob();
             } catch (Exception ex) {
               LOG.log(Level.SEVERE, "Job Initialization Failed", ex);