From 7b78b15c81eaa19f57132831a8d027ee78790eac Mon Sep 17 00:00:00 2001
From: dimitrispie <dpierrakos@gmail.com>
Date: Mon, 13 Feb 2023 09:27:00 +0200
Subject: [PATCH] Changes for copying to Impala Cluster

---
 .../dhp/oa/graph/stats/oozie_app/copyDataToImpalaCluster.sh   | 1 +
 .../eu/dnetlib/dhp/oa/graph/stats/oozie_app/workflow.xml      | 4 ++--
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/copyDataToImpalaCluster.sh b/dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/copyDataToImpalaCluster.sh
index b5209b04d..a2424a351 100644
--- a/dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/copyDataToImpalaCluster.sh
+++ b/dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/copyDataToImpalaCluster.sh
@@ -24,6 +24,7 @@ function copydb() {
   impala-shell -i impala-cluster-dn1.openaire.eu -q "drop database if exists ${db} cascade";
   impala-shell -i impala-cluster-dn1.openaire.eu -q "create database ${db}";
 
+  impala-shell -q "INVALIDATE METADATA"
   echo "creating schema for ${db}"
   for i in `impala-shell -d ${db} --delimited  -q "show tables"`;
     do
diff --git a/dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/workflow.xml b/dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/workflow.xml
index 5d2e3799e..558b9544f 100644
--- a/dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/workflow.xml
+++ b/dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/workflow.xml
@@ -103,6 +103,7 @@
             <case to="Step16_5">${wf:conf('resumeFrom') eq 'Step16_5'}</case>
             <case to="Step19-finalize">${wf:conf('resumeFrom') eq 'Step19-finalize'}</case>
             <case to="step20-createMonitorDB">${wf:conf('resumeFrom') eq 'step20-createMonitorDB'}</case>
+            <case to="step20-createMonitorDB-post">${wf:conf('resumeFrom') eq 'step20-createMonitorDB-post'}</case>
             <case to="step21-createObservatoryDB-pre">${wf:conf('resumeFrom') eq 'step21-createObservatoryDB-pre'}</case>
             <case to="step21-createObservatoryDB">${wf:conf('resumeFrom') eq 'step21-createObservatoryDB'}</case>
             <case to="step21-createObservatoryDB-post">${wf:conf('resumeFrom') eq 'step21-createObservatoryDB-post'}</case>
@@ -377,8 +378,7 @@
             <exec>monitor-post.sh</exec>
             <argument>${monitor_db_name}</argument>
             <argument>${monitor_db_shadow_name}</argument>
-            <argument>${wf:appPath()}/scripts/step20-createMonitorDB.sql</argument>
-            <file>monitor.sh</file>
+            <file>monitor-post.sh</file>
         </shell>
         <ok to="step21-createObservatoryDB-pre"/>
         <error to="Kill"/>