db-derby-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Parker, Patricia \(LNG-CON\)" <patricia.par...@lexisnexis.com>
Subject RE: SQL Exception: Container xxx not found
Date Fri, 11 May 2007 20:07:58 GMT
Hi Stanley,

I disabled the cache and did more analysis of the actual timing of the
events, and it appears that the problem is that the bulk load CALL
SYSCS_UTIL.SYSCS_IMPORT_DATA (?,?,?,?,?,?,?,?,?) is not entirely
finishing before I try to query the table it is populating.  I would
expect to get a locking exception, or something of that nature, but the
SQL error code that gets returned is either XSCB1 or XSCH1, both of
which come with the message "container <containerName> not found".   I
think you're right that it's a Windows caching or heap issue.  I am
getting around the problem by trapping for those two error codes,
putting my thread to sleep for awhile, then retrying.  It seems to work
fine that way.

An improvement I would suggest is having SYSCS_UTIL.SYSCS_IMPORT_DATA
indicate when it is done loading.  As it stands now, the thread I have
running it finishes before the utility finishes, and I have no elegant
way of knowing when the load is done, other than trying to use the table
and trapping for errors, as stated above.

Thanks for your help!

Patty

-----Original Message-----
From: Stanley Bradbury [mailto:Stan.Bradbury@gmail.com] 
Sent: Thursday, May 10, 2007 3:18 PM
To: Derby Discussion
Subject: Re: SQL Exception: Container xxx not found

Hi Patty -
I fear this will be a hard one to solve without a reproducible test 
case.  Before going that route (I assume it will be difficult to provide

a test case) I suggest seeing if this might be system related. 

The oddest thing is that the Exception is not in the derby.log along 
with the SQLState and stack trace.  Missing data (be it exceptions 
information or data containers) could be caused by in-memory problems or

possibly I/O caching.  Windows write caching is enabled by default and 
can cause problems in I/O intensive applications.  Please disable this 
and see if the problem persists.  This can be disabled on XP from the 
disk drive/properties/hardware tab/policy tab - more information can be 
found, along with a warning, at:  http://support.microsoft.com/kb/259716

If the problem still happens would you run your tests using a different 
JVM and/or machine to see if this corrects or effects the problem.  If 
none of these actions resolve the problem then please post the problem 
to the derby-dev for additional ideas.

Parker, Patricia (LNG-CON) wrote:
> Hi Stanley,
>
> Thanks for your reply.
>
> I am running Derby 10.2.2 in embedded mode on Windows XP platform in
> Eclipse.  I have attached both the derby.log file and a snapshot of my
> Eclipse console, since the actual SQL error shows up there on line
231.
> The corresponding messages in derby.log occur around line 185, when
the
> rollback starts to happen.
>
> The only mention I have seen of a similar problem in Derby was in the
> mail archives here...
>
<http://mail-archives.apache.org/mod_mbox/db-derby-user/200702.mbox/%3C4
> 5DBA554.10809@gmail.com%3E>
>
> The response to the above mail seemed to imply that Derby may lose
track
> of tables, so I have been trying different timings of when I define my
> tables in relation to when I do the inserts. 
>
> Here is more detail on my process.  I am running a "graph" process,
> where a node process runs on its own thread and bulk loads a bunch of
> data from a flat file into a table that it defines on-the-fly using
some
> XML that describes the data in the flat file.  After the node process
> thread completes, a connector thread runs that applies a filter to all
> the data that was just bulk loaded and inserts the filtered data into
> another brand new, defined on-the-fly table.  This is done by
performing
> an INSERT INTO <new connector table> SELECT * FROM <table created for
> node> WHERE <some filter statement>.  Since this is a graph process,
> many node threads may be processing at once, and many connector
threads
> may also be processing concurrently.  I sometimes have noticed some
> deadlocking between connectors, but it seems to recover and move on
ok.
> My problem happens whether or not a deadlock message occurs.
>
> My bulk loads have been working fine in the nodes, but I believe the
> problem may occur when my program goes to access the bulk loaded data
to
> use as data to do the inserts into my new tables in the connectors.
> Right now, I define my tables right before loading/inserting into
them.
> I have tried defining all my tables up front before running the bulk
> loads and inserts.  I have also tried sharing instances of the
> DriverManager, but that did not seem to help.  I now get a new
> DriverManager each time I do a bulk load or insert, as the log will
> show.
>
> I am currently using the isolation TRANSACTION_READ_COMMITTED, but I
> have had the same issue with TRANSACTION_SERIALIZABLE.
>
>
> Thanks again for your help.  
>
> Patty
>
> Below are my methods for bulk load and insert, and for getting a
> connection:
>
> Here is my method for doing the bulk load:  
>
>    public void importData(String tableName, List<FieldType>
columnList,
> 	    List<String> columnIndexList, String inputFile,
> 	    String columnDelimiter, String charDelimiter, boolean
> replace)
>     {
> 	StringBuffer sb = new StringBuffer();
> 	for (FieldType field : columnList)
> 	{
> 	    sb.append(field.getName().toUpperCase());
> 	    sb.append(",");
> 	}
> 	sb.deleteCharAt(sb.length() - 1);
>
> 	String insertColumns = sb.toString();
> 	log.debug("Supposed to bulk load these columns: " +
> insertColumns);
>
> 	String columnIndexes = null;
>
> 	Connection conn = getConnection();
>
> 	// convert the boolean 'replace' flag to an integer;
> 	int intReplace = replace ? 1 : 0;
>
> 	PreparedStatement ps = null;
> 	try
> 	{
> 	    ps = conn
> 		    .prepareStatement("CALL SYSCS_UTIL.SYSCS_IMPORT_DATA
> (?,?,?,?,?,?,?,?,?)");
> 	    ps.setString(1, null); // schema name
> 	    ps.setString(2, tableName.toUpperCase()); // table name
> 	    log.debug("tableName: " + tableName.toUpperCase());
> 	    ps.setString(3, insertColumns.toUpperCase());
> 	    log.debug("insertColumn: " + insertColumns.toUpperCase());
> 	    ps.setString(4, columnIndexes);
> 	    log.debug("columnIndexes: " + columnIndexes);
> 	    ps.setString(5, inputFile); // input file
> 	    log.debug("inputFile: " + inputFile);
> 	    ps.setString(6, columnDelimiter); // column delimiter
> 	    log.debug("columnDelimiter: " + columnDelimiter);
> 	    ps.setString(7, charDelimiter); // character delimiter
> 	    log.debug("charDelimiter: " + charDelimiter);
> 	    ps.setString(8, null); // code set
> 	    ps.setInt(9, intReplace); // if true, empty the table before
> 	    log.debug("intReplace: " + intReplace);
> 	    // loading. Otherwise, add the data to
> 	    // what is already there.
> 	    ps.execute();
>
> 	} catch (Throwable e)
> 	{
> 	    log.debug("exception thrown:");
>
> 	    if (e instanceof SQLException)
> 	    {
> 		printSQLError((SQLException) e);
> 	    }
> 	    else
> 	    {
> 		e.printStackTrace();
> 	    }
> 	} finally
> 	{
> 	    try
> 	    {
> 		ps.close();
> 		conn.close();
> 	    } catch (Throwable e)
> 	    {
> 		log.debug("exception thrown:");
>
> 		if (e instanceof SQLException)
> 		{
> 		    printSQLError((SQLException) e);
> 		}
> 		else
> 		{
> 		    e.printStackTrace();
> 		}
> 	    }
> 	    try
> 	    {
> 		while (!conn.isClosed())
> 		{
> 		    wait(100L);
> 		}
> 	    } 
> 	    catch (SQLException e)
> 	    {
> 		// TODO Auto-generated catch block
> 		e.printStackTrace();
> 	    } 
> 	    catch (InterruptedException e)
> 	    {
> 		// TODO Auto-generated catch block
> 		e.printStackTrace();
> 	    }
>
> 	}
>     }
>
>
> Here is my method for doing inserts:
>
>     public void insertToTable(String tableName, String
selectStatement)
>     {
> 	Connection conn = getConnection();
> 	Statement s = null;
>
> 	String insertStatement = ("INSERT INTO " + tableName + " " +
> selectStatement);
> 	log.debug("Insert statement: " + insertStatement);
> 	try
> 	{
> 	    s = conn.createStatement();
> 	    s.execute(insertStatement);
> 	} 
> 	catch (Throwable e)
> 	{
> 	    log.debug("exception thrown:");
>
> 	    if (e instanceof SQLException)
> 	    {
> 		printSQLError((SQLException) e);
> 	    }
> 	    else
> 	    {
> 		e.printStackTrace();
> 	    }
> 	} 
> 	finally
> 	{
>
> 	    /*
>                  * We end the transaction and the connection.
>                  */
>
> 	    try
> 	    {
> 		    s.close();
>
> 		//conn.commit();
> 		conn.close();
> 		log.debug("closed connection");
> 	    } 
> 	    catch (Throwable e)
> 	    {
> 		log.debug("exception thrown:");
>
> 		if (e instanceof SQLException)
> 		{
> 		    printSQLError((SQLException) e);
> 		}
> 		else
> 		{
> 		    e.printStackTrace();
> 		}
> 	    }
> 	    //Make sure connection is closed before going on
> 	    try
> 	    {
> 		while (!conn.isClosed())
> 		{
> 		    wait(100L);
> 		}
> 	    } 
> 	    catch (Throwable e)
> 	    {
> 		log.debug("exception thrown:");
>
> 		if (e instanceof SQLException)
> 		{
> 		    printSQLError((SQLException) e);
> 		}
> 		else
> 		{
> 		    e.printStackTrace();
> 		}
> 	    }
>
> 	}
>
>     }
>
>
> Method for getting connection...
>
>    private static Connection getConnection()
>     {
> 	System.out
> 		.println("DerbyDBManager starting in " + framework + "
> mode.");
> 	Connection conn = null;
> 	try
> 	{
>
>
> 	    Properties props = new Properties();
> 	    props.put("user", username);
> 	    props.put("password", "mine");
>
>
> 	    /*
>                  * The connection specifies create=true to cause the
> database to
>                  * be created. To remove the database, remove the
> directory
>                  * derbyDB and its contents. The directory derbyDB
will
> be
>                  * created under the directory that the system
property
>                  * derby.system.home points to, or the current
directory
> if
>                  * derby.system.home is not set.
>                  */
> 	    conn =
> DriverManager.getConnection("jdbc:derby:C:/Derby881;create=true",
> props);
>
> 	    log.debug("Created connection");
>
> 	    conn.setAutoCommit(true);
>
> 	
> conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
> 	} 
> 	catch (Throwable e)
> 	{
> 	    log.debug("exception thrown:");
>
> 	    if (e instanceof SQLException)
> 	    {
> 		printSQLError((SQLException) e);
> 	    }
> 	    else
> 	    {
> 		e.printStackTrace();
> 	    }
> 	}
>
> 	return conn;
>
>     }
> -----Original Message-----
> From: Stanley Bradbury [mailto:Stan.Bradbury@gmail.com] 
> Sent: Wednesday, May 09, 2007 7:59 PM
> To: Derby Discussion
> Subject: Re: SQL Exception: Container xxx not found
>
> Parker, Patricia (LNG-CON) wrote:
>   
>> Hi,
>>
>> I am developing an application that does bulk loading and inserting 
>> into tables that are created on-the-fly. I create four tables and 
>> bulk-load data into them. Then I run a process that creates four 
>> tables and selectively inserts data from the bulk-loaded tables into 
>> the newly created tables. The bulk loads seem to go fine, but during 
>> the insert process, I am randomly getting the error "SQL Exception: 
>> Container xxx not found". The error does not happen on the same table

>> every time, and some times everything runs fine. I am only writing at

>> most eight records to a table, so I have not begun to put a load on 
>> the process yet. Can you provide some guidance?
>>
>> Thanks
>>
>> Patty
>>
>>     
> Hi Patty -
> I haven't heard of problems using Derby as you describe and think some

> additional information would be helpful. There should be detailed 
> information in the derby.log file including a stack trace that will be

> helpful in zeroing in on the problem. Posting the whole log will be a 
> help in knowing the version and if other issues are being reported. 
> Also, please describe how the processes (two?) that perform 1) the
bulk 
> load and 2) the inserts are initiated and synchronized.
>   
>
------------------------------------------------------------------------
>
> configFilename:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/src/com/lexisnexis/batch/bber2/pe/config/config_pe_pooling.xml
> log4j:WARN No appenders could be found for logger
(com.lexisnexis.batch.bber2.pe.ProcessingEngine).
> log4j:WARN Please initialize the log4j system properly.
> Loading Pools in PoolManager: 
>  GenericObjectPool member type
com.lexisnexis.batch.bber2.pe.ProcessEngineController is :  maxIdle = 76
|  minIdle =  0 |  maxActive =  300 |  maxWait =  -1 |  testOnBorrow =
false |  testOnReturn =  false |  testWhileIdle =  false |
timeBetweenEvictionRunsMillis =  -1 |  numTestsPerEvictionRun =   3 |
minEvictableIdleTimeMillis =  1800000 |  softMinEvictableIdleTimeMillis
=  -1 |  whenExhaustedAction = 1 | 
> 1268 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient  - Attempting to
create a JMS Connection to: tcp://b10dhcp18147.lexis-nexis.com:61616
> 1660 [Thread-0] DEBUG
org.apache.activemq.transport.WireFormatNegotiator  - Sending:
WireFormatInfo { version=1, properties={TightEncodingEnabled=true,
TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
> 1675 [ActiveMQ Transport:
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616] DEBUG
org.apache.activemq.transport.WireFormatNegotiator  - Received
WireFormat: WireFormatInfo { version=2,
properties={TightEncodingEnabled=true, CacheSize=1024,
TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
> 1675 [ActiveMQ Transport:
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616] DEBUG
org.apache.activemq.transport.WireFormatNegotiator  -
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616 before
negotiation: OpenWireFormat{version=1, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
> 1691 [ActiveMQ Transport:
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616] DEBUG
org.apache.activemq.transport.WireFormatNegotiator  -
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616 after
negotiation: OpenWireFormat{version=1, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true,
sizePrefixDisabled=false}
> 1722 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient  - JMS Init is
filling Consumer collection 
> 2020 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient  - JMS Init is
filling Producer collection 
> 2020 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient  - JMS Init is
firing the Initialize Event: init is valid = true
> 2020 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient  - JMS Client is
shutting down all Consumers
> 2067 [Thread-0] DEBUG com.lexisnexis.batch.bber2.pe.ProcessingEngine
- JMS init successful -- assigning producers and consumers
> 2223 [Thread-7] DEBUG org.apache.activemq.ActiveMQMessageConsumer  -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:1:2,
destination = queue://IPCtoPE, message = ActiveMQTextMessage {commandId
= 5, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1, destination =
queue://IPCtoPE, transactionId = null, expiration = 0, timestamp =
1178731026972, arrival = 0, correlationId = null, replyTo = null,
persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = org.apache.activeio.packet.ByteSequence@933bcb,
marshalledProperties = org.apache.activeio.packet.ByteSequence@3ac93e,
dataStructure = null, redeliveryCounter = 57, size = 0, properties =
null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 57}
> 2239 [Thread-8] DEBUG ProcessingEngine  - Received message:
ActiveMQTextMessage {commandId = 5, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1, destination =
queue://IPCtoPE, transactionId = null, expiration = 0, timestamp =
1178731026972, arrival = 0, correlationId = null, replyTo = null,
persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = org.apache.activeio.packet.ByteSequence@933bcb,
marshalledProperties = org.apache.activeio.packet.ByteSequence@3ac93e,
dataStructure = null, redeliveryCounter = 57, size = 0, properties =
null, readOnlyProperties = true, readOnlyBody = true, text = null}
> 2505 [Thread-8] DEBUG ProcessEngineController  - In
ProcessEngineController
> In ProcessEngineControllerObjectFactory, activateObject has been
called for com.lexisnexis.batch.bber2.pe.ProcessEngineController
> 2505 [Thread-8] DEBUG ProcessingEngine  - Borrowed
ProcessEngineController contents:
com.lexisnexis.batch.bber2.pe.ProcessEngineController@114b82b
> 2505 [Thread-8] DEBUG ProcessingEngine  - Processor id:
com.lexisnexis.batch.bber2.pe.ProcessEngineController@114b82b
> 2505 [pool-1-thread-1] DEBUG ProcessEngineController  - Creating new
ListenableSimpleDirectedGraph
> 2583 [pool-1-thread-1] DEBUG GraphBuilder  - In Graph Builder
> XML file name:
C:\bber2cc\parkerpx_ProcessingEngine\BBR2_comps\ProcessingEngine\Process
ingEngine/src/com/lexisnexis/batch/bber2/pe/config/product.xml
> 2708 [pool-1-thread-1] DEBUG GraphBuilder  - adding edge to graph -
fromNode: node1 ; toNode:  node2
> 2724 [pool-1-thread-1] DEBUG GraphBuilder  - Node: node2  Has this
Input File: node1out1
> 2724 [pool-1-thread-1] DEBUG GraphBuilder  - adding edge to graph -
fromNode: node1 ; toNode:  node3
> 2724 [pool-1-thread-1] DEBUG GraphBuilder  - Node: node3  Has this
Input File: node1out1
> 2724 [pool-1-thread-1] DEBUG GraphBuilder  - adding edge to graph -
fromNode: node2 ; toNode:  node4
> 2724 [pool-1-thread-1] DEBUG GraphBuilder  - Node: node4  Has this
Input File: node2out1
> 2724 [pool-1-thread-1] DEBUG GraphBuilder  - adding edge to graph -
fromNode: node3 ; toNode:  node4
> 2724 [pool-1-thread-1] DEBUG GraphBuilder  - Node: node4  Has this
Input File: node3out1
> graph object toString #1:
([com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@1d32e45,
com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@182ef6b,
com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@1347124,
com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@1f02b85],
[com.lexisnexis.batch.bber2.pe.config.ConnectorDetailsType@b957ea=(com.l
exisnexis.batch.bber2.pe.config.ProcessDetailsType@1d32e45,com.lexisnexi
s.batch.bber2.pe.config.ProcessDetailsType@182ef6b),
com.lexisnexis.batch.bber2.pe.config.ConnectorDetailsType@1f0b7d3=(com.l
exisnexis.batch.bber2.pe.config.ProcessDetailsType@1d32e45,com.lexisnexi
s.batch.bber2.pe.config.ProcessDetailsType@1347124),
com.lexisnexis.batch.bber2.pe.config.ConnectorDetailsType@b4be3d=(com.le
xisnexis.batch.bber2.pe.config.ProcessDetailsType@182ef6b,com.lexisnexis
.batch.bber2.pe.config.ProcessDetailsType@1f02b85),
com.lexisnexis.batch.bber2.pe.config.ConnectorDetailsType@35bb0f=(com.le
xisnexis.batch.bber2.pe.config.ProcessDetailsType@1347124,com.lexisnexis
.batch.bber2.pe.config.ProcessDetailsType@1f02b85)])
> 3585 [pool-1-thread-1] DEBUG GraphRunner  - Running graph in
GraphRunner
> DerbyDBManager starting in embedded mode.
> 4978 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 5369 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
> 5369 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 5369 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 5369 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 5385 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
> 5385 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 5385 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> 5385 [pool-1-thread-1] DEBUG DerbyDBManager  - Loaded the
EmbeddedDriver.
> Send this process to worker:  node1
>          has this object name:
com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@1d32e45
> 5651 [Thread-10] DEBUG org.apache.activemq.ActiveMQSession  - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178809141318, arrival = 0, correlationId = node1, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:1, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"
standalone="yes"?>
> 5870 [Thread-12] DEBUG org.apache.activemq.ActiveMQMessageConsumer  -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:2,
destination = queue://PEToWorker, message = ActiveMQTextMessage
{commandId = 22, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178817011309, arrival = 0, correlationId = node1, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:1, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activeio.packet.ByteSequence@13af084, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 0}
> 10472 [Thread-13] DEBUG DummyWorker  - Dummy worker received this
message: <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
> 10613 [Thread-13] DEBUG org.apache.activemq.ActiveMQSession  - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:2:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:2, destination =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:1, transactionId
= null, expiration = 0, timestamp = 1178809146296, arrival = 0,
correlationId = node1, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter =
0, size = 0, properties =
{working_directory=C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/Proce
ssingEngine/ProcessingEngine/testdata/input,
output_filename=node1worker.txt}, readOnlyProperties = true,
readOnlyBody = true, text = WORKER SAYS - IM DONE}
> 10707 [ActiveMQ Session Task] DEBUG ProcessDetailThread  -  Got My
Response  for node1 from
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:1WORKER SAYS - IM
DONE
> DerbyDBManager starting in embedded mode.
> 10722 [pool-1-thread-1] DEBUG GraphRunner  - >>> Processing for node1
is really done <<<
> 10722 [pool-1-thread-1] DEBUG GraphRunner  - From GraphRunner,
ProcessDetailThread no longer running
> 10722 [pool-1-thread-1] DEBUG GraphRunner  - For Node: node1  --
connectorID: connectorId1  comes from node: node1  goes to node: node2
> DerbyDBManager starting in embedded mode.
> 10769 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 10785 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Created
connection
> 10957 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
> 10957 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 10957 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 10957 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 10988 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
> 10988 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 10988 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> 10988 [pool-1-thread-1] DEBUG DerbyDBManager  - Loaded the
EmbeddedDriver.
> 10988 [pool-1-thread-1] DEBUG GraphRunner  - For Node: node1  --
connectorID: connectorId2  comes from node: node1  goes to node: node3
> DerbyDBManager starting in embedded mode.
> 11004 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 11004 [connectorId1] DEBUG ConnectorDetailThread  - in connector for
connectorId1
> DerbyDBManager starting in embedded mode.
> 11004 [connectorId1] DEBUG DerbyDBManager  - Created connection
> 11020 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
> 11020 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 11020 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 11020 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 11035 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
> 11035 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 11035 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> 11035 [pool-1-thread-1] DEBUG DerbyDBManager  - Loaded the
EmbeddedDriver.
> 11067 [connectorId2] DEBUG ConnectorDetailThread  - in connector for
connectorId2
> DerbyDBManager starting in embedded mode.
> 11067 [connectorId2] DEBUG DerbyDBManager  - Created connection
> 11677 [ActiveMQ Session Task] DEBUG DerbyDBManager  - executed create
table node1(phone INTEGER,personNum INTEGER primary key,address
VARCHAR(254),firstName VARCHAR(254))
> 11677 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Closed
statement
> 11677 [ActiveMQ Session Task] DEBUG DerbyDBManager  - closed
connection
> 11677 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Supposed to bulk
load these columns: PERSONNUM,FIRSTNAME,ADDRESS,PHONE
> DerbyDBManager starting in embedded mode.
> 11677 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Created
connection
> 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager  - tableName: NODE1
> 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager  - insertColumn:
PERSONNUM,FIRSTNAME,ADDRESS,PHONE
> 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager  - columnIndexes:
null
> 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager  - inputFile:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/testdata/input/node1worker.txt
> 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager  - columnDelimiter:
;
> 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager  - charDelimiter:
null
> 11896 [ActiveMQ Session Task] DEBUG DerbyDBManager  - intReplace: 1
> 12460 [connectorId2] DEBUG DerbyDBManager  - executed create table
connectorId2(phone INTEGER,personNum INTEGER primary key,address
VARCHAR(254),firstName VARCHAR(254))
> 12460 [connectorId2] DEBUG DerbyDBManager  - Closed  statement
> 12460 [connectorId2] DEBUG DerbyDBManager  - closed connection
> 12460 [connectorId2] DEBUG ConnectorDetailThread  - *** Heres the
nohit condition: SELECT * FROM ME.NODE1 WHERE PERSONNUM NOT IN (SELECT
PERSONNUM FROM ME.NODE1 WHERE NODE1.PERSONNUM > 100)
> DerbyDBManager starting in embedded mode.
> 12491 [connectorId1] DEBUG DerbyDBManager  - executed create table
connectorId1(phone INTEGER,personNum INTEGER primary key,address
VARCHAR(254),firstName VARCHAR(254))
> 15527 [connectorId2] DEBUG DerbyDBManager  - Created connection
> 15527 [connectorId2] DEBUG DerbyDBManager  - Insert statement: INSERT
INTO connectorId2 SELECT * FROM ME.NODE1 WHERE PERSONNUM NOT IN (SELECT
PERSONNUM FROM ME.NODE1 WHERE NODE1.PERSONNUM > 100)
> 15606 [connectorId1] DEBUG DerbyDBManager  - Closed  statement
> 15606 [connectorId1] DEBUG DerbyDBManager  - closed connection
> 15621 [connectorId2] DEBUG DerbyDBManager  - closed connection
> 16545 [connectorId1] DEBUG ConnectorDetailThread  - *** Heres the hit
condition: SELECT * FROM ME.NODE1 WHERE NODE1.PERSONNUM > 100
> DerbyDBManager starting in embedded mode.
> 16545 [connectorId1] DEBUG DerbyDBManager  - Created connection
> 16545 [connectorId1] DEBUG DerbyDBManager  - Insert statement: INSERT
INTO connectorId1 SELECT * FROM ME.NODE1 WHERE NODE1.PERSONNUM > 100
> 16561 [connectorId1] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 16561 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 16561 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
> 16561 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 16561 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 16561 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 16576 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
> 16576 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 16576 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> 16576 [pool-1-thread-1] DEBUG DerbyDBManager  - Loaded the
EmbeddedDriver.
> Send this process to worker:  node2
>          has this object name:
com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@182ef6b
> 16780 [Thread-14] DEBUG org.apache.activemq.ActiveMQSession  - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:2,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178809152463, arrival = 0, correlationId = node2, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:2, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"
standalone="yes"?>
> 17061 [Thread-16] DEBUG org.apache.activemq.ActiveMQMessageConsumer  -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:3,
destination = queue://PEToWorker, message = ActiveMQTextMessage
{commandId = 32, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:2, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178817022432, arrival = 0, correlationId = node2, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:2, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activeio.packet.ByteSequence@1033450, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 0}
> 25545 [Thread-18] DEBUG DummyWorker  - Dummy worker received this
message: <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
> 25889 [Thread-18] DEBUG org.apache.activemq.ActiveMQSession  - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:3:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:3, destination =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:2, transactionId
= null, expiration = 0, timestamp = 1178809161572, arrival = 0,
correlationId = node2, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter =
0, size = 0, properties =
{working_directory=C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/Proce
ssingEngine/ProcessingEngine/testdata/input,
output_filename=node2worker.txt}, readOnlyProperties = true,
readOnlyBody = true, text = WORKER SAYS - IM DONE}
> 25983 [ActiveMQ Session Task] DEBUG ProcessDetailThread  -  Got My
Response  for node2 from
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:2WORKER SAYS - IM
DONE
> DerbyDBManager starting in embedded mode.
> 25983 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Created
connection
> 25983 [pool-1-thread-1] DEBUG GraphRunner  - >>> Processing for node2
is really done <<<
> 25983 [pool-1-thread-1] DEBUG GraphRunner  - From GraphRunner,
ProcessDetailThread no longer running
> 25983 [pool-1-thread-1] DEBUG GraphRunner  - For Node: node2  --
connectorID: connectorId1  comes from node: node1  goes to node: node2
> 25983 [pool-1-thread-1] DEBUG GraphRunner  - For Node: node2  --
connectorID: connectorId3  comes from node: node2  goes to node: node4
> DerbyDBManager starting in embedded mode.
> 25999 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 25999 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
> 25999 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 25999 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 25999 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 26030 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
> 26030 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 26030 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> 26030 [pool-1-thread-1] DEBUG DerbyDBManager  - Loaded the
EmbeddedDriver.
> 26061 [connectorId3] DEBUG ConnectorDetailThread  - in connector for
connectorId3
> DerbyDBManager starting in embedded mode.
> 26061 [connectorId3] DEBUG DerbyDBManager  - Created connection
> 26437 [ActiveMQ Session Task] DEBUG DerbyDBManager  - executed create
table node2(empNum VARCHAR(254) primary key,sport VARCHAR(254),lastName
VARCHAR(254))
> 26437 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Closed
statement
> 26437 [ActiveMQ Session Task] DEBUG DerbyDBManager  - closed
connection
> 26437 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Supposed to bulk
load these columns: EMPNUM,LASTNAME,SPORT
> DerbyDBManager starting in embedded mode.
> 26515 [connectorId3] DEBUG DerbyDBManager  - executed create table
connectorId3(empNum VARCHAR(254) primary key,sport VARCHAR(254),lastName
VARCHAR(254))
> 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Created
connection
> 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager  - tableName: NODE2
> 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager  - insertColumn:
EMPNUM,LASTNAME,SPORT
> 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager  - columnIndexes:
null
> 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager  - inputFile:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/testdata/input/node2worker.txt
> 27846 [connectorId3] DEBUG DerbyDBManager  - Closed  statement
> 27893 [ActiveMQ Session Task] DEBUG DerbyDBManager  - columnDelimiter:
;
> 27908 [ActiveMQ Session Task] DEBUG DerbyDBManager  - charDelimiter:
null
> 27908 [ActiveMQ Session Task] DEBUG DerbyDBManager  - intReplace: 1
> 27924 [connectorId3] DEBUG DerbyDBManager  - closed connection
> 27924 [connectorId3] DEBUG ConnectorDetailThread  - *** Heres the all
condition: SELECT * FROM ME.NODE2
> DerbyDBManager starting in embedded mode.
> 27924 [connectorId3] DEBUG DerbyDBManager  - Created connection
> 27924 [connectorId3] DEBUG DerbyDBManager  - Insert statement: INSERT
INTO connectorId3 SELECT * FROM ME.NODE2
> 28425 [connectorId3] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 28425 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 28425 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
> 28425 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 28441 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 28441 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 28441 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
> 28441 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 28441 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> 28441 [pool-1-thread-1] DEBUG DerbyDBManager  - Loaded the
EmbeddedDriver.
> Send this process to worker:  node3
>          has this object name:
com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@1347124
> 28691 [Thread-19] DEBUG org.apache.activemq.ActiveMQSession  - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:3,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178809164374, arrival = 0, correlationId = node3, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:3, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"
standalone="yes"?>
> 28863 [Thread-21] DEBUG org.apache.activemq.ActiveMQMessageConsumer  -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:4,
destination = queue://PEToWorker, message = ActiveMQTextMessage
{commandId = 42, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:3, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178817034323, arrival = 0, correlationId = node3, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:3, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activeio.packet.ByteSequence@13d422d, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 0}
> 34576 [Thread-24] DEBUG DummyWorker  - Dummy worker received this
message: <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
> 34905 [Thread-24] DEBUG org.apache.activemq.ActiveMQSession  - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:4:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:4, destination =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:3, transactionId
= null, expiration = 0, timestamp = 1178809170588, arrival = 0,
correlationId = node3, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter =
0, size = 0, properties =
{working_directory=C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/Proce
ssingEngine/ProcessingEngine/testdata/input,
output_filename=node3worker.txt}, readOnlyProperties = true,
readOnlyBody = true, text = WORKER SAYS - IM DONE}
> 34905 [ActiveMQ Session Task] DEBUG ProcessDetailThread  -  Got My
Response  for node3 from
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:3WORKER SAYS - IM
DONE
> DerbyDBManager starting in embedded mode.
> 34905 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Created
connection
> 34921 [pool-1-thread-1] DEBUG GraphRunner  - >>> Processing for node3
is really done <<<
> 34921 [pool-1-thread-1] DEBUG GraphRunner  - From GraphRunner,
ProcessDetailThread no longer running
> 34921 [pool-1-thread-1] DEBUG GraphRunner  - For Node: node3  --
connectorID: connectorId2  comes from node: node1  goes to node: node3
> 34921 [pool-1-thread-1] DEBUG GraphRunner  - For Node: node3  --
connectorID: connectorId4  comes from node: node3  goes to node: node4
> DerbyDBManager starting in embedded mode.
> 34921 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 34936 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
> 34936 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 34936 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 34936 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 34952 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
> 34952 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 34952 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> 34952 [pool-1-thread-1] DEBUG DerbyDBManager  - Loaded the
EmbeddedDriver.
> 34952 [connectorId4] DEBUG ConnectorDetailThread  - in connector for
connectorId4
> DerbyDBManager starting in embedded mode.
> 34968 [connectorId4] DEBUG DerbyDBManager  - Created connection
> 35202 [ActiveMQ Session Task] DEBUG DerbyDBManager  - executed create
table node3(empNum VARCHAR(254) primary key,salary DOUBLE)
> 35202 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Closed
statement
> 35202 [ActiveMQ Session Task] DEBUG DerbyDBManager  - closed
connection
> 35202 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Supposed to bulk
load these columns: EMPNUM,SALARY
> DerbyDBManager starting in embedded mode.
> 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Created
connection
> 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager  - tableName: NODE3
> 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager  - insertColumn:
EMPNUM,SALARY
> 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager  - columnIndexes:
null
> 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager  - inputFile:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/testdata/input/node3worker.txt
> 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager  - columnDelimiter:
;
> 35375 [connectorId4] DEBUG DerbyDBManager  - executed create table
connectorId4(empNum VARCHAR(254) primary key,salary DOUBLE)
> 37096 [ActiveMQ Session Task] DEBUG DerbyDBManager  - charDelimiter:
null
> 37096 [ActiveMQ Session Task] DEBUG DerbyDBManager  - intReplace: 1
> 37096 [connectorId4] DEBUG DerbyDBManager  - Closed  statement
> 37096 [connectorId4] DEBUG DerbyDBManager  - closed connection
> 37096 [connectorId4] DEBUG ConnectorDetailThread  - *** Heres the hit
condition: SELECT * FROM ME.NODE3 WHERE NODE3.SALARY > 10000
> DerbyDBManager starting in embedded mode.
> 37300 [connectorId4] DEBUG DerbyDBManager  - Created connection
> 37300 [connectorId4] DEBUG DerbyDBManager  - Insert statement: INSERT
INTO connectorId4 SELECT * FROM ME.NODE3 WHERE NODE3.SALARY > 10000
> 37441 [connectorId4] DEBUG DerbyDBManager  - exception thrown:
> 37441 [connectorId4] DEBUG DerbyDBManager  - SQL Exception: Container
992 not found.
> 37441 [connectorId4] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 37441 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 37472 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
> 37472 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 37472 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> DerbyDBManager starting in embedded mode.
> 37472 [pool-1-thread-1] DEBUG DerbyDBManager  - Created connection
> 37503 [pool-1-thread-1] DEBUG DerbyDBManager  - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
> 37503 [pool-1-thread-1] DEBUG DerbyDBManager  - Closed  statement
> 37503 [pool-1-thread-1] DEBUG DerbyDBManager  - closed connection
> 37503 [pool-1-thread-1] DEBUG DerbyDBManager  - Loaded the
EmbeddedDriver.
> Send this process to worker:  node4
>          has this object name:
com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@1f02b85
> 37613 [Thread-25] DEBUG org.apache.activemq.ActiveMQSession  - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:4,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178809173296, arrival = 0, correlationId = node4, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:4, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"
standalone="yes"?>
> 37863 [Thread-27] DEBUG org.apache.activemq.ActiveMQMessageConsumer  -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:5,
destination = queue://PEToWorker, message = ActiveMQTextMessage
{commandId = 52, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:4, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178817043222, arrival = 0, correlationId = node4, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:4, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activeio.packet.ByteSequence@b6b2a5, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 0}
> 42653 [Thread-31] DEBUG DummyWorker  - Dummy worker received this
message: <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
> 42888 [Thread-31] DEBUG org.apache.activemq.ActiveMQSession  - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:5:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:5, destination =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:4, transactionId
= null, expiration = 0, timestamp = 1178809178571, arrival = 0,
correlationId = node4, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter =
0, size = 0, properties =
{working_directory=C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/Proce
ssingEngine/ProcessingEngine/testdata/input,
output_filename=node4worker.txt}, readOnlyProperties = true,
readOnlyBody = true, text = WORKER SAYS - IM DONE}
> 42888 [ActiveMQ Session Task] DEBUG ProcessDetailThread  -  Got My
Response  for node4 from
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:4WORKER SAYS - IM
DONE
> DerbyDBManager starting in embedded mode.
> 42903 [pool-1-thread-1] DEBUG GraphRunner  - >>> Processing for node4
is really done <<<
> 42903 [pool-1-thread-1] DEBUG GraphRunner  - From GraphRunner,
ProcessDetailThread no longer running
> 42903 [pool-1-thread-1] DEBUG GraphRunner  - For Node: node4  --
connectorID: connectorId3  comes from node: node2  goes to node: node4
> 42903 [pool-1-thread-1] DEBUG GraphRunner  - For Node: node4  --
connectorID: connectorId4  comes from node: node3  goes to node: node4
> 42903 [pool-1-thread-1] DEBUG ProcessEngineController  - done running
GraphRunner
> 42903 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Created
connection
> XML file name:
C:/bber2cc/parkerpx_OutputProc/BBR2_comps/OutputProcessing/OutputProcess
ingEngine/src/com/lexisnexis/batch/bber2/output/processor/config/new_out
put_instance.xml
> 43029 [Thread-8] DEBUG org.apache.activemq.ActiveMQSession  - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:4:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:4:1, destination =
queue://PEtoOPE, transactionId = null, expiration = 0, timestamp =
1178809178712, arrival = 0, correlationId = null, replyTo = null,
persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"?>
> 43060 [Thread-8] DEBUG ProcessingEngine  - ActiveMQTextMessage
{commandId = 5, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1, destination =
queue://IPCtoPE, transactionId = null, expiration = 0, timestamp =
1178731026972, arrival = 0, correlationId = null, replyTo = null,
persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = org.apache.activeio.packet.ByteSequence@933bcb,
marshalledProperties = org.apache.activeio.packet.ByteSequence@3ac93e,
dataStructure = null, redeliveryCounter = 57, size = 0, properties =
null, readOnlyProperties = true, readOnlyBody = true, text = null}
> 43060 [Thread-8] DEBUG ProcessingEngine  - ** Processor Resumes
Reading
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - executed create
table node4(payday DATE,empNum VARCHAR(254) primary key)
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Closed
statement
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - closed
connection
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Supposed to bulk
load these columns: EMPNUM,PAYDAY
> DerbyDBManager starting in embedded mode.
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - Created
connection
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - tableName: NODE4
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - insertColumn:
EMPNUM,PAYDAY
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - columnIndexes:
null
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - inputFile:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/testdata/input/node4worker.txt
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - columnDelimiter:
;
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - charDelimiter:
null
> 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager  - intReplace: 1
>   


Mime
View raw message