fatal error during graph initialization

oldforum

• July 16, 2007 00:00

• Answered

Follow

hello sir
i have implemented SPLIT_RECORD component which read one record and write two to two differne toutput port.

but when i use SPLIT_RECORD in my graph its give fatal error in graph initialization.



here is my graph
<?xml version="1.0" encoding="UTF-8"?>
<Graph name="Testing split">

<Global>
<Metadata id="InMetadata" fileURL="E:/CloverETL/Examples/metadata/sales.txt"/>
<Metadata id="OutMetadata" fileURL="E:/CloverETL/Examples/metadata/time.txt"/>
<Metadata id="OutMetadata1" fileURL="E:/CloverETL/Examples/metadata/salesout.txt"/>
<Metadata id="dateMetadata" fileURL="E:/CloverETL/Examples/metadata/date.txt"/>
<DBConnection id="InterbaseDB" dbConfig="E:/CloverETL/Examples/Postgress.cfg"/>
<DBConnection id="InterbaseDB1" dbConfig="E:/CloverETL/Examples/Postgress1.cfg"/>
</Global>
<Phase number="0">
<Node id="INPUT" type="DB_INPUT_TABLE" dbConnection="InterbaseDB" sqlQuery="select customer_id,"date",prefix || ' ' || doc_no as doc_no,version,pm.person_first_name || ' ' || pm.person_last_name as sales_representative,item_id,qty,price,discount1,discount2 from sv_master as sv,employee_master as em,person_master as pm,sv_detail as sd where sv.id <> 0 and sv.current_version and sv.sales_representativ=em.id and em.person_master_id=pm.id and sd.sv_id=sv.id"/>
<Node id="SPLIT" type="SPLIT_RECORD" />
<Node id="REF" type="REFORMAT" >
import org.jetel.component.DataRecordTransform;
import org.jetel.data.*;
import java.util.Date;

public class reformatOrders extends DataRecordTransform{

int counter=1;
int field=0;

public boolean transform(DataRecord source[], DataRecord[] target){
try{


Date saleDate=GetVal.getDate(source[0],"date");
SetVal.setInt(target[0],"time_id",counter);
SetVal.setInt(target[0],"day",saleDate.getDate());
SetVal.setInt(target[0],"month",saleDate.getMonth()+1);
switch(saleDate.getMonth()+1)
{
case 1:
SetVal.setString(target[0],"month_name","January");
SetVal.setString(target[0],"quarter","Q1");
break;
case 2:
SetVal.setString(target[0],"month_name","Fabruary");
SetVal.setString(target[0],"quarter","Q1");
break;
case 3:
SetVal.setString(target[0],"month_name","March");
SetVal.setString(target[0],"quarter","Q1");
break;
case 4:
SetVal.setString(target[0],"month_name","April");
SetVal.setString(target[0],"quarter","Q2");
break;
case 5:
SetVal.setString(target[0],"month_name","May");
SetVal.setString(target[0],"quarter","Q2");
break;
case 6:
SetVal.setString(target[0],"month_name","June");
SetVal.setString(target[0],"quarter","Q2");
break;
case 7:
SetVal.setString(target[0],"month_name","July");
SetVal.setString(target[0],"quarter","Q3");
break;
case 8:
SetVal.setString(target[0],"month_name","August");
SetVal.setString(target[0],"quarter","Q3");
break;
case 9:
SetVal.setString(target[0],"month_name","September");
SetVal.setString(target[0],"quarter","Q3");
break;
case 10:
SetVal.setString(target[0],"month_name","October");
SetVal.setString(target[0],"quarter","Q4");
break;
case 11:
SetVal.setString(target[0],"month_name","November");
SetVal.setString(target[0],"quarter","Q4");
break;
case 12:
System.out.println("case 12:"+saleDate.getMonth());
SetVal.setString(target[0],"month_name","December");
SetVal.setString(target[0],"quarter","Q4");

}

SetVal.setInt(target[0],"year",saleDate.getYear()+1900);

}catch(Exception ex){
errorMessage=ex.getMessage()+" ->occured with record :"+counter;
System.out.println(errorMessage);
ex.printStackTrace();
return false;
}
counter++;
return true;
}
}
</Node>
<Node id="OUTPUT" type="DB_OUTPUT_TABLE" dbConnection="InterbaseDB1" dbTable="time"/>
<Node id="OUTPUT1" type="DB_OUTPUT_TABLE" dbConnection="InterbaseDB1" dbTable="sales"/>
<Edge id="INEDGE" fromNode="INPUT:0" toNode="SPLIT:0" metadata="InMetadata"/>
<!Edge id="MIDEDGE" fromNode="SPLIT:0" toNode="REF:0" metadata="dateMetadata"/>
<!Edge id="OUTEDGE1" fromNode="SPLIT:1" toNode="OUTPUT1:0" metadata="OutMetadata1"/>
<Edge id="OUTEDGE" fromNode="REF:0" toNode="OUTPUT:0" metadata="OutMetadata"/>
</Phase>
</Graph>


here is run methode of split

public void run()
{
boolean isDriverDifferent;

// get all ports involved
InputPort inPort = getInputPort(0);
DataRecord driverRecordread = new DataRecord(inPort.getMetadata());
driverRecordread.init();

int index=0;

// get array of all ports defined/connected - use collection Collection - getInPorts();
OutputPort outPorts[];
outPorts = (OutputPort[]) getOutPorts().toArray(new OutputPort[0]);

// create array holding incoming records
DataRecord outputRecords[];
outputRecords = new DataRecord[outPorts.length];


// initialize array of data records (for each input port one)
for (int i = 0; i < outPorts.length; i++)
{
outputRecords[i] = new DataRecord(outPorts[i].getMetadata());
outputRecords[i].init();
}

// numActive=inPorts.length;
int cou[] = new int[5];



while (runIt)
{
try
{
driverRecordread = inPort.readRecord(driverRecordread);
if(driverRecordread != null)
{
outputRecords[0]=driverRecordread.duplicate();
outputRecords[1]=driverRecordread.duplicate();
outputRecords[0].delField(0);
outputRecords[0].delField(2);
outputRecords[0].delField(3);
outputRecords[0].delField(4);
outputRecords[0].delField(5);
outputRecords[0].delField(6);
outputRecords[0].delField(7);
outputRecords[0].delField(8);
outputRecords[0].delField(9);
outputRecords[1].delField(1);
// This Function Will always Return zero.
int result_t = 0;
outPorts[0].writeRecord(outputRecords[0]);
outPorts[1].writeRecord(outputRecords[1]);
// System.out.println("In Run: index" + result_t);
}else
{
break;
}
} catch (IOException ex)
{
resultMsg = ex.getMessage();
resultCode = Node.RESULT_ERROR;
closeAllOutputPorts();
System.out.println("IO error in split:" + ex.getMessage());
ex.printStackTrace();
return;
} catch (Exception ex)
{
resultMsg = ex.getMessage();
resultCode = Node.RESULT_FATAL_ERROR;
System.out.println("error in split:" + ex.getMessage());
ex.printStackTrace();
return;
}
}

broadcastEOF();

if (runIt) {
resultMsg = "OK";
} else
{
resultMsg = "STOPPED";
}
resultCode = Node.RESULT_OK;
}


please help me quickly to implement this split record component

• 

  oldforum

  • July 16, 2007 08:23

  0

  Comment actions Permalink

  yea martin
  
  i have registered my componenet. the new line i added is look like
  
  registerComponent(SplitRecord.COMPONENT_TYPE,"org.jetel.component.SplitRecord");
• 

  oldforum

  • July 16, 2007 08:23

  0

  Comment actions Permalink

  hello sir
  
  i try to trace the problem so i have print stack trace and get the cause of exception
  
  in read methode of TransformationGraphXMLReaderWriter if make following change
  
  catch (Exception ex) {
  ex.printStackTrace();
  //throw new RuntimeException(ex);
  }
  
  after making this change i get that exception i nullpoint exception at sentence
  
  graphNode.setPhase(phaseNum);
  
  in instantiateNodes function.
  
  so i print phase to know whether it initialized properly
  my code is like
  graphNode = ComponentFactory.createComponent(nodeType,
  nodeElements.item(i));
  System.out.println("phase No. " +phaseNum);
  graphNode.setPhase(phaseNum);
  
  now on executing i get output as
  
  *** CloverETL framework/transformation graph runner ver1.7, (c) 2002-05 D.Pavlis, released under GNU Lesser General Public License ***
  
  Graph definition file: E:/CloverETL/Examples/graphsplit.txt
  phase No. 0
  phase No. 0
  java.lang.NullPointerException
  at org.jetel.graph.TransformationGraphXMLReaderWriter.instantiateNodes(TransformationGraphXMLReaderWriter.java:381)
  at org.jetel.graph.TransformationGraphXMLReaderWriter.instantiatePhases(TransformationGraphXMLReaderWriter.java:348)
  at org.jetel.graph.TransformationGraphXMLReaderWriter.read(TransformationGraphXMLReaderWriter.java:242)
  at org.jetel.main.runGraph.main(runGraph.java:124)
  Initializing DB connection: jdbc:postgresql://192.168.0.3/olap ... OK
  Initializing DB connection: jdbc:postgresql://192.168.0.3/vtech0506 ... OK
  [Clover] starting WatchDog thread ...
  [WatchDog] Thread started.
  [WatchDog] Running on 1 CPU(s) max available memory for JVM 1635 KB
  [Clover] Initializing phase: 0
  initializing edges: all edges initialized successfully...
  initializing nodes:
  INPUT ...FAILED !
  Nov 10, 2005 5:43:00 PM org.jetel.graph.Phase init
  SEVERE: At least one output port has to be defined for node INPUT
  [WatchDog] !!! Phase finished with error - stopping graph run !!!
  Failed starting graph !
  [Clover] WatchDog thread finished - total execution time: 0 (sec)
  [Clover] !!! Graph execution finished with errors !!!
  
  i get phase no for first two node but on third node throw exception
  
  one another thing is that thow in my graph definition output port for "INPUT" is defined, still INPUT failed to initialized with reason that it has not output port.
  
  
  can any body figure out problem?
• 

  oldforum

  • July 16, 2007 08:23

  0

  Comment actions Permalink

  hello martin
  that exclamations mark is not in original graph, this kept here by mistake. actualy i have commented some code for testing where is problem. after getting that when i include SPLIT node i get error i ahve removed comment for posting here and that time i forget to remove this
• 

  oldforum

  • July 16, 2007 08:23

  0

  Comment actions Permalink

  Hello,
  on second read your code i have second question. Are you sure that you register your new component in ComponentFactory class? There is static initialization block for all accessible component.
  
  Martin
• 

  oldforum

  • July 16, 2007 08:23

  0

  Comment actions Permalink

  Hello Deepak,
  can i ask you why do you have two exclamations in this lines: (?)
  
  <!Edge id="MIDEDGE" fromNode="SPLIT:0" toNode="REF:0" metadata="dateMetadata"/>
  <!Edge id="OUTEDGE1" fromNode="SPLIT:1" toNode="OUTPUT1:0" metadata="OutMetadata1"/>
  
  It seems like INPUT node dont has output edge connect. Its my first idea when i looked at your code.
  
  OtaSanek

Please sign in to leave a comment.