Yaniv Dary has uploaded a new change for review. Change subject: etl: removed engine service up requirment on start (#913384) ......................................................................
etl: removed engine service up requirment on start (#913384) Change-Id: I2b2283f1ccf2b33050f0a8bed1dd1d9a8e86efce Signed-off-by: Yaniv Dary <[email protected]> --- M data-warehouse/history_etl/etl_sources/historyETLProcedure/src/main/java/ovirt_engine_dwh/historyetl_3_2/HistoryETL.java M data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.item M data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.properties 3 files changed, 16 insertions(+), 502 deletions(-) git pull ssh://gerrit.ovirt.org:29418/ovirt-dwh refs/changes/12/12712/1 diff --git a/data-warehouse/history_etl/etl_sources/historyETLProcedure/src/main/java/ovirt_engine_dwh/historyetl_3_2/HistoryETL.java b/data-warehouse/history_etl/etl_sources/historyETLProcedure/src/main/java/ovirt_engine_dwh/historyetl_3_2/HistoryETL.java index 6cb1123..9e3c26c 100644 --- a/data-warehouse/history_etl/etl_sources/historyETLProcedure/src/main/java/ovirt_engine_dwh/historyetl_3_2/HistoryETL.java +++ b/data-warehouse/history_etl/etl_sources/historyETLProcedure/src/main/java/ovirt_engine_dwh/historyetl_3_2/HistoryETL.java @@ -39,9 +39,6 @@ //the import part of tJava_1 //import java.util.List; -//the import part of tJava_3 -//import java.util.List; - //the import part of tJava_4 //import java.util.List; @@ -887,50 +884,6 @@ } - public void tJava_3_error(Exception exception, String errorComponent, - final java.util.Map<String, Object> globalMap) - throws TalendException { - end_Hash.put("tJava_3", System.currentTimeMillis()); - - try { - - ((java.util.Map) threadLocal.get()).put("errorCode", null); - tDie_2Process(globalMap); - if (!"failure".equals(((java.util.Map) threadLocal.get()) - .get("status"))) { - ((java.util.Map) threadLocal.get()).put("status", "end"); - } - - } catch (Exception e) { - e.printStackTrace(); - } - - tJava_3_onSubJobError(exception, errorComponent, globalMap); - - } - - public void tDie_1_error(Exception exception, String errorComponent, - final java.util.Map<String, Object> globalMap) - throws TalendException { - end_Hash.put("tDie_1", System.currentTimeMillis()); - - ((java.util.Map) threadLocal.get()).put("status", "failure"); - - tDie_1_onSubJobError(exception, errorComponent, globalMap); - - } - - public void tDie_2_error(Exception exception, String errorComponent, - final java.util.Map<String, Object> globalMap) - throws TalendException { - end_Hash.put("tDie_2", System.currentTimeMillis()); - - ((java.util.Map) threadLocal.get()).put("status", "failure"); - - tDie_2_onSubJobError(exception, errorComponent, globalMap); - - } - public void tLogCatcher_1_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { @@ -1262,39 +1215,6 @@ } public void tRunJob_2_onSubJobError(Exception exception, - String errorComponent, final java.util.Map<String, Object> globalMap) - throws TalendException { - - resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread - .currentThread().getId() - + "", "FATAL", "", exception.getMessage(), ResumeUtil - .getExceptionStackTrace(exception), ""); - - } - - public void tJava_3_onSubJobError(Exception exception, - String errorComponent, final java.util.Map<String, Object> globalMap) - throws TalendException { - - resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread - .currentThread().getId() - + "", "FATAL", "", exception.getMessage(), ResumeUtil - .getExceptionStackTrace(exception), ""); - - } - - public void tDie_1_onSubJobError(Exception exception, - String errorComponent, final java.util.Map<String, Object> globalMap) - throws TalendException { - - resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread - .currentThread().getId() - + "", "FATAL", "", exception.getMessage(), ResumeUtil - .getExceptionStackTrace(exception), ""); - - } - - public void tDie_2_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { @@ -6644,311 +6564,6 @@ globalMap.put("tRunJob_2_SUBPROCESS_STATE", 1); } - public void tJava_3Process(final java.util.Map<String, Object> globalMap) - throws TalendException { - globalMap.put("tJava_3_SUBPROCESS_STATE", 0); - - final boolean execStat = this.execStat; - - String iterateId = ""; - String currentComponent = ""; - - try { - - String currentMethodName = new Exception().getStackTrace()[0] - .getMethodName(); - boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); - if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start - // the - // resume - globalResumeTicket = true; - - /** - * [tJava_3 begin ] start - */ - - ok_Hash.put("tJava_3", false); - start_Hash.put("tJava_3", System.currentTimeMillis()); - currentComponent = "tJava_3"; - - int tos_count_tJava_3 = 0; - - java.net.URL url_tHttpRequest_1 = new java.net.URL( - context.ovirtEnginePortalConnectionProtocol + "://" - + context.ovirtEnginePortalAddress + ":" - + context.ovirtEnginePortalPort - + "/OvirtEngineWeb/HealthStatus"); - java.net.HttpURLConnection urlConn_tHttpRequest_1 = (java.net.HttpURLConnection) url_tHttpRequest_1 - .openConnection(); - urlConn_tHttpRequest_1.setRequestMethod("GET"); - urlConn_tHttpRequest_1.setDoOutput(true); - urlConn_tHttpRequest_1.setDoInput(true); - urlConn_tHttpRequest_1.setUseCaches(false); - urlConn_tHttpRequest_1.connect(); - urlConn_tHttpRequest_1.disconnect(); - - /** - * [tJava_3 begin ] stop - */ - /** - * [tJava_3 main ] start - */ - - currentComponent = "tJava_3"; - - tos_count_tJava_3++; - - /** - * [tJava_3 main ] stop - */ - /** - * [tJava_3 end ] start - */ - - currentComponent = "tJava_3"; - - ok_Hash.put("tJava_3", true); - end_Hash.put("tJava_3", System.currentTimeMillis()); - - if (java.net.HttpURLConnection.HTTP_OK != (urlConn_tHttpRequest_1 - .getResponseCode())) { - - tDie_1Process(globalMap); - } - - /** - * [tJava_3 end ] stop - */ - - }// end the resume - - } catch (Exception e) { - - throw new TalendException(e, currentComponent, globalMap); - - } catch (java.lang.Error error) { - - throw new java.lang.Error(error); - - } - - globalMap.put("tJava_3_SUBPROCESS_STATE", 1); - } - - public void tDie_1Process(final java.util.Map<String, Object> globalMap) - throws TalendException { - globalMap.put("tDie_1_SUBPROCESS_STATE", 0); - - final boolean execStat = this.execStat; - - String iterateId = ""; - String currentComponent = ""; - - try { - - String currentMethodName = new Exception().getStackTrace()[0] - .getMethodName(); - boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); - if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start - // the - // resume - globalResumeTicket = true; - - /** - * [tDie_1 begin ] start - */ - - ok_Hash.put("tDie_1", false); - start_Hash.put("tDie_1", System.currentTimeMillis()); - currentComponent = "tDie_1"; - - int tos_count_tDie_1 = 0; - - /** - * [tDie_1 begin ] stop - */ - /** - * [tDie_1 main ] start - */ - - currentComponent = "tDie_1"; - - tLogCatcher_1 - .addMessage( - "tDie", - "tDie_1", - 5, - "oVirt Engine Portal is not available. Please check your ETL configuration.", - 9704); - tLogCatcher_1Process(globalMap); - - talendLogs_LOGS - .addMessage( - "tDie", - "tDie_1", - 5, - "oVirt Engine Portal is not available. Please check your ETL configuration.", - 9704); - talendLogs_LOGSProcess(globalMap); - - globalMap.put("tDie_1_DIE_PRIORITY", 5); - System.err - .println("oVirt Engine Portal is not available. Please check your ETL configuration."); - globalMap - .put("tDie_1_DIE_MESSAGE", - "oVirt Engine Portal is not available. Please check your ETL configuration."); - currentComponent = "tDie_1"; - status = "failure"; - errorCode = new Integer(9704); - ((java.util.Map) threadLocal.get()).put("errorCode", - new Integer(9704)); - ((java.util.Map) threadLocal.get()).put("status", "failure"); - globalMap.put("tDie_1_DIE_CODE", errorCode); - - if (true) { - throw new TDieException(); - } - - tos_count_tDie_1++; - - /** - * [tDie_1 main ] stop - */ - /** - * [tDie_1 end ] start - */ - - currentComponent = "tDie_1"; - - ok_Hash.put("tDie_1", true); - end_Hash.put("tDie_1", System.currentTimeMillis()); - - /** - * [tDie_1 end ] stop - */ - - }// end the resume - - } catch (Exception e) { - - throw new TalendException(e, currentComponent, globalMap); - - } catch (java.lang.Error error) { - - throw new java.lang.Error(error); - - } - - globalMap.put("tDie_1_SUBPROCESS_STATE", 1); - } - - public void tDie_2Process(final java.util.Map<String, Object> globalMap) - throws TalendException { - globalMap.put("tDie_2_SUBPROCESS_STATE", 0); - - final boolean execStat = this.execStat; - - String iterateId = ""; - String currentComponent = ""; - - try { - - String currentMethodName = new Exception().getStackTrace()[0] - .getMethodName(); - boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); - if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start - // the - // resume - globalResumeTicket = true; - - /** - * [tDie_2 begin ] start - */ - - ok_Hash.put("tDie_2", false); - start_Hash.put("tDie_2", System.currentTimeMillis()); - currentComponent = "tDie_2"; - - int tos_count_tDie_2 = 0; - - /** - * [tDie_2 begin ] stop - */ - /** - * [tDie_2 main ] start - */ - - currentComponent = "tDie_2"; - - tLogCatcher_1 - .addMessage( - "tDie", - "tDie_2", - 5, - "oVirt Engine Portal is not available. Please check your ETL configuration.", - 9704); - tLogCatcher_1Process(globalMap); - - talendLogs_LOGS - .addMessage( - "tDie", - "tDie_2", - 5, - "oVirt Engine Portal is not available. Please check your ETL configuration.", - 9704); - talendLogs_LOGSProcess(globalMap); - - globalMap.put("tDie_2_DIE_PRIORITY", 5); - System.err - .println("oVirt Engine Portal is not available. Please check your ETL configuration."); - globalMap - .put("tDie_2_DIE_MESSAGE", - "oVirt Engine Portal is not available. Please check your ETL configuration."); - currentComponent = "tDie_2"; - status = "failure"; - errorCode = new Integer(9704); - ((java.util.Map) threadLocal.get()).put("errorCode", - new Integer(9704)); - ((java.util.Map) threadLocal.get()).put("status", "failure"); - globalMap.put("tDie_2_DIE_CODE", errorCode); - - if (true) { - throw new TDieException(); - } - - tos_count_tDie_2++; - - /** - * [tDie_2 main ] stop - */ - /** - * [tDie_2 end ] start - */ - - currentComponent = "tDie_2"; - - ok_Hash.put("tDie_2", true); - end_Hash.put("tDie_2", System.currentTimeMillis()); - - /** - * [tDie_2 end ] stop - */ - - }// end the resume - - } catch (Exception e) { - - throw new TalendException(e, currentComponent, globalMap); - - } catch (java.lang.Error error) { - - throw new java.lang.Error(error); - - } - - globalMap.put("tDie_2_SUBPROCESS_STATE", 1); - } - public static class event_outputStruct implements routines.system.IPersistableRow<event_outputStruct> { final static byte[] commonByteArrayLock_OVIRT_ENGINE_DWH_HistoryETL = new byte[0]; @@ -8960,48 +8575,6 @@ } }.start(); - runningThreadCount.add(1); - new Thread() { - public void run() { - java.util.Map threadRunResultMap = new java.util.HashMap(); - threadRunResultMap.put("errorCode", null); - threadRunResultMap.put("status", ""); - threadLocal.set(threadRunResultMap); - - try { - ((java.util.Map) threadLocal.get()).put("errorCode", null); - tJava_3Process(globalMap); - if (!"failure".equals(((java.util.Map) threadLocal.get()) - .get("status"))) { - ((java.util.Map) threadLocal.get()) - .put("status", "end"); - } - } catch (TalendException e_tJava_3) { - - e_tJava_3.printStackTrace(); - globalMap.put("tJava_3_SUBPROCESS_STATE", -1); - - } finally { - } - - Integer localErrorCode = (Integer) (((java.util.Map) threadLocal - .get()).get("errorCode")); - String localStatus = (String) (((java.util.Map) threadLocal - .get()).get("status")); - if (localErrorCode != null) { - if (errorCode == null - || localErrorCode.compareTo(errorCode) > 0) { - errorCode = localErrorCode; - } - } - if (!status.equals("failure")) { - status = localStatus; - } - - runningThreadCount.add(-1); - } - }.start(); - while (runningThreadCount.getCount() > 0) { try { Thread.sleep(10); @@ -9123,6 +8696,6 @@ ResumeUtil resumeUtil = null; } /************************************************************************************************ - * 238412 characters generated by Talend Open Studio for Data Integration on the - * March 5, 2013 10:11:19 AM IST + * 228006 characters generated by Talend Open Studio for Data Integration on the + * March 5, 2013 12:36:30 PM IST ************************************************************************************************/ diff --git a/data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.item b/data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.item index b51fb2f..472dcb5 100644 --- a/data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.item +++ b/data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.item @@ -186,7 +186,7 @@ <elementParameter field="MEMO" name="COMMENT" value=""/> <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> </node> - <node componentName="tPostjob" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="-192" posY="800"> + <node componentName="tPostjob" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="-192" posY="608"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tPostjob_1"/> <elementParameter field="CHECK" name="START" value="true"/> <elementParameter field="TEXT" name="CONNECTION_FORMAT" value="row"/> @@ -252,7 +252,7 @@ <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> <metadata connector="FLOW" name="tFileDelete_1"/> </node> - <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="-32" posY="800"> + <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="-32" posY="608"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJDBCRollback_1"/> <elementParameter field="COMPONENT_LIST" name="CONNECTION" value="tJDBCConnection_2"/> <elementParameter field="CHECK" name="CLOSE" value="true"/> @@ -263,7 +263,7 @@ <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> <metadata connector="FLOW" name="tJDBCRollback_1"/> </node> - <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="192" posY="800"> + <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="192" posY="608"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJDBCRollback_2"/> <elementParameter field="COMPONENT_LIST" name="CONNECTION" value="tJDBCConnection_1"/> <elementParameter field="CHECK" name="CLOSE" value="true"/> @@ -274,7 +274,7 @@ <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> <metadata connector="FLOW" name="tJDBCRollback_2"/> </node> - <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="448" posY="800"> + <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="448" posY="608"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJDBCRollback_3"/> <elementParameter field="COMPONENT_LIST" name="CONNECTION" value="tJDBCConnection_3"/> <elementParameter field="CHECK" name="CLOSE" value="true"/> @@ -285,7 +285,7 @@ <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> <metadata connector="FLOW" name="tJDBCRollback_3"/> </node> - <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="704" posY="800"> + <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="704" posY="608"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJDBCRollback_4"/> <elementParameter field="COMPONENT_LIST" name="CONNECTION" value="tJDBCConnection_4"/> <elementParameter field="CHECK" name="CLOSE" value="true"/> @@ -296,7 +296,7 @@ <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> <metadata connector="FLOW" name="tJDBCRollback_4"/> </node> - <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="960" posY="800"> + <node componentName="tJDBCRollback" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="960" posY="608"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJDBCRollback_5"/> <elementParameter field="COMPONENT_LIST" name="CONNECTION" value="tJDBCConnection_5"/> <elementParameter field="CHECK" name="CLOSE" value="true"/> @@ -393,7 +393,7 @@ <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> <metadata connector="FLOW" name="tJava_1"/> </node> - <node componentName="tRunJob" componentVersion="0.101" offsetLabelX="0" offsetLabelY="0" posX="-192" posY="672"> + <node componentName="tRunJob" componentVersion="0.101" offsetLabelX="0" offsetLabelY="0" posX="-192" posY="480"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tRunJob_2"/> <elementParameter field="CHECK" name="START" value="true"/> <elementParameter field="CHECK" name="USE_DYNAMIC_JOB" value="false"/> @@ -416,18 +416,7 @@ <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> <metadata connector="FLOW" name="tRunJob_2"/> </node> - <node componentName="tJava" componentVersion="0.101" offsetLabelX="0" offsetLabelY="0" posX="-192" posY="480"> - <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJava_3"/> - <elementParameter field="CHECK" name="START" value="true"/> - <elementParameter field="MEMO_JAVA" name="CODE" value="java.net.URL url_tHttpRequest_1 = new java.net.URL(
 						 context.ovirtEnginePortalConnectionProtocol + "://"
 							 + context.ovirtEnginePortalAddress + ":"
								 + context.ovirtEnginePortalPort
								 + "/OvirtEngineWeb/HealthStatus");
java.net.HttpURLConnection urlConn_tHttpRequest_1 = (java.net.HttpURLConnection) url_tHttpRequest_1.openConnection();
urlConn_tHttpRequest_1.setRequestMethod("GET");
urlConn_tHttpRequest_1.setDoOutput(true);
urlConn_tHttpRequest_1.setDoInput(true);
urlConn_tHttpRequest_1.setUseCaches(false);
urlConn_tHttpRequest_1.connect();
urlConn_tHttpRequest_1.disconnect();"/> - <elementParameter field="MEMO_IMPORT" name="IMPORT" value="//import java.util.List;"/> - <elementParameter field="TEXT" name="CONNECTION_FORMAT" value="row"/> - <elementParameter field="CHECK" name="INFORMATION" value="false"/> - <elementParameter field="MEMO" name="COMMENT" value=""/> - <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> - <metadata connector="FLOW" name="tJava_3"/> - </node> - <node componentName="tRowGenerator" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="1184" posY="800"> + <node componentName="tRowGenerator" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="1184" posY="608"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tRowGenerator_1"/> <elementParameter field="TEXT" name="NB_ROWS" value="1"/> <elementParameter field="TABLE" name="VALUES"> @@ -446,7 +435,7 @@ <column comment="" key="false" name="message" nullable="false" pattern="" sourceType="" type="id_String"/> </metadata> </node> - <node componentName="tLogRow" componentVersion="0.101" offsetLabelX="0" offsetLabelY="0" posX="1184" posY="896"> + <node componentName="tLogRow" componentVersion="0.101" offsetLabelX="0" offsetLabelY="0" posX="1184" posY="704"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tLogRow_1"/> <elementParameter field="RADIO" name="BASIC_MODE" value="true"/> <elementParameter field="RADIO" name="TABLE_PRINT" value="false"/> @@ -495,7 +484,7 @@ <elementParameter field="MEMO" name="COMMENT" value=""/> <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> </node> - <node componentName="tRowGenerator" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="1376" posY="800"> + <node componentName="tRowGenerator" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="1376" posY="608"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tRowGenerator_5"/> <elementParameter field="TEXT" name="NB_ROWS" value="1"/> <elementParameter field="TABLE" name="VALUES"> @@ -514,7 +503,7 @@ <column comment="" key="false" name="message" nullable="false" pattern="" sourceType="" type="id_String"/> </metadata> </node> - <node componentName="tMap" componentVersion="2.1" offsetLabelX="0" offsetLabelY="0" posX="1376" posY="896"> + <node componentName="tMap" componentVersion="2.1" offsetLabelX="0" offsetLabelY="0" posX="1376" posY="704"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tMap_2"/> <elementParameter field="EXTERNAL" name="MAP" value=""/> <elementParameter field="CLOSED_LIST" name="LINK_STYLE" value="AUTO"/> @@ -550,7 +539,7 @@ </inputTables> </nodeData> </node> - <node componentName="tJDBCOutput" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="1376" posY="992"> + <node componentName="tJDBCOutput" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="1376" posY="800"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJDBCOutput_2"/> <elementParameter field="CHECK" name="USE_EXISTING_CONNECTION" value="true"/> <elementParameter field="COMPONENT_LIST" name="CONNECTION" value="tJDBCConnection_6"/> @@ -745,7 +734,7 @@ <column defaultValue="" key="false" length="255" name="errorMessage" nullable="true" precision="0" sourceType="" type="id_String"/> </metadata> </node> - <node componentName="tJDBCClose" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="1568" posY="800"> + <node componentName="tJDBCClose" componentVersion="0.102" offsetLabelX="0" offsetLabelY="0" posX="1568" posY="608"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJDBCClose_1"/> <elementParameter field="COMPONENT_LIST" name="CONNECTION" value="tJDBCConnection_6"/> <elementParameter field="TEXT" name="LABEL" value="close_engine_events"/> @@ -894,30 +883,6 @@ <column defaultValue="" key="false" length="255" name="errorCode" nullable="true" precision="0" sourceType="" type="id_String"/> <column defaultValue="" key="false" length="255" name="errorMessage" nullable="true" precision="0" sourceType="" type="id_String"/> </metadata> - </node> - <node componentName="tDie" componentVersion="0.101" offsetLabelX="0" offsetLabelY="0" posX="-64" posY="480"> - <elementParameter field="TEXT" name="UNIQUE_NAME" value="tDie_1"/> - <elementParameter field="TEXT" name="MESSAGE" value=""oVirt Engine Portal is not available. Please check your ETL configuration.""/> - <elementParameter field="TEXT" name="CODE" value="9704"/> - <elementParameter field="CLOSED_LIST" name="PRIORITY" value="5"/> - <elementParameter field="CHECK" name="EXIT_JVM" value="false"/> - <elementParameter field="TEXT" name="CONNECTION_FORMAT" value="row"/> - <elementParameter field="CHECK" name="INFORMATION" value="false"/> - <elementParameter field="MEMO" name="COMMENT" value=""/> - <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> - <metadata connector="FLOW" name="tDie_1"/> - </node> - <node componentName="tDie" componentVersion="0.101" offsetLabelX="0" offsetLabelY="0" posX="-64" posY="576"> - <elementParameter field="TEXT" name="UNIQUE_NAME" value="tDie_2"/> - <elementParameter field="TEXT" name="MESSAGE" value=""oVirt Engine Portal is not available. Please check your ETL configuration.""/> - <elementParameter field="TEXT" name="CODE" value="9704"/> - <elementParameter field="CLOSED_LIST" name="PRIORITY" value="5"/> - <elementParameter field="CHECK" name="EXIT_JVM" value="false"/> - <elementParameter field="TEXT" name="CONNECTION_FORMAT" value="row"/> - <elementParameter field="CHECK" name="INFORMATION" value="false"/> - <elementParameter field="MEMO" name="COMMENT" value=""/> - <elementParameter field="CHECK" name="VALIDATION_RULES" value="false"/> - <metadata connector="FLOW" name="tDie_2"/> </node> <node componentName="tJava" componentVersion="0.101" offsetLabelX="0" offsetLabelY="0" posX="384" posY="224"> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJava_4"/> @@ -1100,15 +1065,6 @@ <elementParameter field="TEXT" name="NUMBER_PARALLEL" value="2"/> <elementParameter field="CHECK" name="ACTIVATE" value="true"/> <elementParameter field="TEXT" name="UNIQUE_NAME" value="iterate1"/> - </connection> - <connection connectorName="RUN_IF" label="If" lineStyle="6" metaname="tJava_3" offsetLabelX="0" offsetLabelY="0" source="tJava_3" target="tDie_1"> - <elementParameter field="MEMO_JAVA" name="CONDITION" value="java.net.HttpURLConnection.HTTP_OK != (urlConn_tHttpRequest_1.getResponseCode())"/> - <elementParameter field="CHECK" name="ACTIVATE" value="true"/> - <elementParameter field="TEXT" name="UNIQUE_NAME" value="If1"/> - </connection> - <connection connectorName="COMPONENT_ERROR" label="OnComponentError" lineStyle="5" metaname="tJava_3" offsetLabelX="0" offsetLabelY="0" source="tJava_3" target="tDie_2"> - <elementParameter field="CHECK" name="ACTIVATE" value="true"/> - <elementParameter field="TEXT" name="UNIQUE_NAME" value="OnComponentError1"/> </connection> <connection connectorName="FLOW" label="row6" lineStyle="0" metaname="tRowGenerator_1" offsetLabelX="0" offsetLabelY="0" source="tRowGenerator_1" target="tLogRow_1"> <elementParameter field="CHECK" name="TRACES_CONNECTION_ENABLE" value="true"/> @@ -1601,11 +1557,6 @@ <elementParameter field="COLOR" name="SUBJOB_COLOR" value="220;220;250"/> </subjob> <subjob> - <elementParameter field="TEXT" name="UNIQUE_NAME" value="tJava_3"/> - <elementParameter field="COLOR" name="SUBJOB_TITLE_COLOR" value="160;190;240"/> - <elementParameter field="COLOR" name="SUBJOB_COLOR" value="220;220;250"/> - </subjob> - <subjob> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tRowGenerator_1"/> <elementParameter field="COLOR" name="SUBJOB_TITLE_COLOR" value="160;190;240"/> <elementParameter field="COLOR" name="SUBJOB_COLOR" value="220;220;250"/> @@ -1632,16 +1583,6 @@ </subjob> <subjob> <elementParameter field="TEXT" name="UNIQUE_NAME" value="tLogCatcher_1"/> - <elementParameter field="COLOR" name="SUBJOB_TITLE_COLOR" value="160;190;240"/> - <elementParameter field="COLOR" name="SUBJOB_COLOR" value="220;220;250"/> - </subjob> - <subjob> - <elementParameter field="TEXT" name="UNIQUE_NAME" value="tDie_1"/> - <elementParameter field="COLOR" name="SUBJOB_TITLE_COLOR" value="160;190;240"/> - <elementParameter field="COLOR" name="SUBJOB_COLOR" value="220;220;250"/> - </subjob> - <subjob> - <elementParameter field="TEXT" name="UNIQUE_NAME" value="tDie_2"/> <elementParameter field="COLOR" name="SUBJOB_TITLE_COLOR" value="160;190;240"/> <elementParameter field="COLOR" name="SUBJOB_COLOR" value="220;220;250"/> </subjob> diff --git a/data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.properties b/data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.properties index e8c5374..9afe3df 100644 --- a/data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.properties +++ b/data-warehouse/history_etl/tos_project/process/HistoryETL_3.2.properties @@ -1,6 +1,6 @@ <?xml version="1.0" encoding="UTF-8"?> <xmi:XMI xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI"; xmlns:TalendProperties="http://www.talend.org/properties";> - <TalendProperties:Property xmi:id="_SHvzYLt3EeCeWLgt9FiAVg" id="_SHJWcLt3EeCeWLgt9FiAVg" label="HistoryETL" creationDate="2011-07-31T16:22:19.809+0300" modificationDate="2013-03-05T10:10:31.480+0200" version="3.2" statusCode="" item="_SHvzYrt3EeCeWLgt9FiAVg" displayName="HistoryETL"> + <TalendProperties:Property xmi:id="_SHvzYLt3EeCeWLgt9FiAVg" id="_SHJWcLt3EeCeWLgt9FiAVg" label="HistoryETL" creationDate="2011-07-31T16:22:19.809+0300" modificationDate="2013-03-05T12:35:33.454+0200" version="3.2" statusCode="" item="_SHvzYrt3EeCeWLgt9FiAVg" displayName="HistoryETL"> <author href="../talend.project#_SapC4EJlEeCWRqOtaF5m-w"/> </TalendProperties:Property> <TalendProperties:ItemState xmi:id="_SHvzYbt3EeCeWLgt9FiAVg" path=""/> -- To view, visit http://gerrit.ovirt.org/12712 To unsubscribe, visit http://gerrit.ovirt.org/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I2b2283f1ccf2b33050f0a8bed1dd1d9a8e86efce Gerrit-PatchSet: 1 Gerrit-Project: ovirt-dwh Gerrit-Branch: master Gerrit-Owner: Yaniv Dary <[email protected]> _______________________________________________ Engine-patches mailing list [email protected] http://lists.ovirt.org/mailman/listinfo/engine-patches
