Return-Path: Delivered-To: apmail-db-derby-user-archive@www.apache.org Received: (qmail 13475 invoked from network); 10 May 2007 19:19:32 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 10 May 2007 19:19:32 -0000 Received: (qmail 40478 invoked by uid 500); 10 May 2007 19:19:36 -0000 Delivered-To: apmail-db-derby-user-archive@db.apache.org Received: (qmail 40360 invoked by uid 500); 10 May 2007 19:19:36 -0000 Mailing-List: contact derby-user-help@db.apache.org; run by ezmlm Precedence: bulk list-help: list-unsubscribe: List-Post: List-Id: Reply-To: "Derby Discussion" Delivered-To: mailing list derby-user@db.apache.org Received: (qmail 40343 invoked by uid 99); 10 May 2007 19:19:35 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 10 May 2007 12:19:35 -0700 X-ASF-Spam-Status: No, hits=1.4 required=10.0 tests=SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (herse.apache.org: 32.97.110.151 is neither permitted nor denied by domain of Stan.Bradbury@gmail.com) Received: from [32.97.110.151] (HELO e33.co.us.ibm.com) (32.97.110.151) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 10 May 2007 12:19:27 -0700 Received: from d03relay04.boulder.ibm.com (d03relay04.boulder.ibm.com [9.17.195.106]) by e33.co.us.ibm.com (8.13.8/8.13.8) with ESMTP id l4AJJ6E2011210 for ; Thu, 10 May 2007 15:19:06 -0400 Received: from d03av01.boulder.ibm.com (d03av01.boulder.ibm.com [9.17.195.167]) by d03relay04.boulder.ibm.com (8.13.8/8.13.8/NCO v8.3) with ESMTP id l4AJJ5YU193072 for ; Thu, 10 May 2007 13:19:05 -0600 Received: from d03av01.boulder.ibm.com (loopback [127.0.0.1]) by d03av01.boulder.ibm.com (8.12.11.20060308/8.13.3) with ESMTP id l4AJJ59v029241 for ; Thu, 10 May 2007 13:19:05 -0600 Received: from [127.0.0.1] (bradbury-lt1.usca.ibm.com [9.72.133.177]) by d03av01.boulder.ibm.com (8.12.11.20060308/8.12.11) with ESMTP id l4AJIxPm028396 for ; Thu, 10 May 2007 13:19:05 -0600 Message-ID: <46436FFC.3090706@gmail.com> Date: Thu, 10 May 2007 12:18:20 -0700 From: Stanley Bradbury User-Agent: Thunderbird 1.5.0.10 (Windows/20070221) MIME-Version: 1.0 To: Derby Discussion Subject: Re: SQL Exception: Container xxx not found References: <9EED580D3663414F82602B9664AE02713BA170@LNGDAYEXCP01VB.legal.regn.net> <4642603B.6080908@gmail.com> <9EED580D3663414F82602B9664AE02713BA173@LNGDAYEXCP01VB.legal.regn.net> In-Reply-To: <9EED580D3663414F82602B9664AE02713BA173@LNGDAYEXCP01VB.legal.regn.net> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: quoted-printable X-Virus-Checked: Checked by ClamAV on apache.org Hi Patty - I fear this will be a hard one to solve without a reproducible test=20 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.=20 The oddest thing is that the Exception is not in the derby.log along=20 with the SQLState and stack trace. Missing data (be it exceptions=20 information or data containers) could be caused by in-memory problems or = possibly I/O caching. Windows write caching is enabled by default and=20 can cause problems in I/O intensive applications. Please disable this=20 and see if the problem persists. This can be disabled on XP from the=20 disk drive/properties/hardware tab/policy tab - more information can be=20 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=20 JVM and/or machine to see if this corrects or effects the problem. If=20 none of these actions resolve the problem then please post the problem=20 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... > 5DBA554.10809@gmail.com%3E> > > The response to the above mail seemed to imply that Derby may lose trac= k > of tables, so I have been trying different timings of when I define my > tables in relation to when I do the inserts.=20 > > 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 som= e > 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 performin= g > an INSERT INTO SELECT * FROM node> WHERE . 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 t= o > 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. =20 > > Patty > > Below are my methods for bulk load and insert, and for getting a > connection: > > Here is my method for doing the bulk load: =20 > > public void importData(String tableName, List columnList,= > List columnIndexList, String inputFile, > String columnDelimiter, String charDelimiter, boolean > replace) > { > StringBuffer sb =3D new StringBuffer(); > for (FieldType field : columnList) > { > sb.append(field.getName().toUpperCase()); > sb.append(","); > } > sb.deleteCharAt(sb.length() - 1); > > String insertColumns =3D sb.toString(); > log.debug("Supposed to bulk load these columns: " + > insertColumns); > > String columnIndexes =3D null; > > Connection conn =3D getConnection(); > > // convert the boolean 'replace' flag to an integer; > int intReplace =3D replace ? 1 : 0; > > PreparedStatement ps =3D null; > try > { > ps =3D 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); > } > }=20 > catch (SQLException e) > { > // TODO Auto-generated catch block > e.printStackTrace(); > }=20 > 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 =3D getConnection(); > Statement s =3D null; > > String insertStatement =3D ("INSERT INTO " + tableName + " " + > selectStatement); > log.debug("Insert statement: " + insertStatement); > try > { > s =3D conn.createStatement(); > s.execute(insertStatement); > }=20 > catch (Throwable e) > { > log.debug("exception thrown:"); > > if (e instanceof SQLException) > { > printSQLError((SQLException) e); > } > else > { > e.printStackTrace(); > } > }=20 > finally > { > > /* > * We end the transaction and the connection. > */ > > try > { > s.close(); > > //conn.commit(); > conn.close(); > log.debug("closed connection"); > }=20 > 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); > } > }=20 > 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 =3D null; > try > { > > > Properties props =3D new Properties(); > props.put("user", username); > props.put("password", "mine"); > > > /* > * The connection specifies create=3Dtrue 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 director= y > if > * derby.system.home is not set. > */ > conn =3D > DriverManager.getConnection("jdbc:derby:C:/Derby881;create=3Dtrue", > props); > > log.debug("Created connection"); > > conn.setAutoCommit(true); > > =09 > conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED); > }=20 > 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]=20 > Sent: Wednesday, May 09, 2007 7:59 PM > To: Derby Discussion > Subject: Re: SQL Exception: Container xxx not found > > Parker, Patricia (LNG-CON) wrote: > =20 >> Hi, >> >> I am developing an application that does bulk loading and inserting=20 >> into tables that are created on-the-fly. I create four tables and=20 >> bulk-load data into them. Then I run a process that creates four=20 >> tables and selectively inserts data from the bulk-loaded tables into=20 >> the newly created tables. The bulk loads seem to go fine, but during=20 >> the insert process, I am randomly getting the error "SQL Exception:=20 >> 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=20 >> the process yet. Can you provide some guidance? >> >> Thanks >> >> Patty >> >> =20 > 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=20 > 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=20 > help in knowing the version and if other issues are being reported.=20 > Also, please describe how the processes (two?) that perform 1) the bulk= =20 > load and 2) the inserts are initiated and synchronized. > =20 > -----------------------------------------------------------------------= - > > configFilename: C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/Process= ingEngine/ProcessingEngine/src/com/lexisnexis/batch/bber2/pe/config/confi= g_pe_pooling.xml > log4j:WARN No appenders could be found for logger (com.lexisnexis.batch= =2Ebber2.pe.ProcessingEngine). > log4j:WARN Please initialize the log4j system properly. > Loading Pools in PoolManager:=20 > GenericObjectPool member type com.lexisnexis.batch.bber2.pe.ProcessEng= ineController is : maxIdle =3D 76 | minIdle =3D 0 | maxActive =3D 30= 0 | maxWait =3D -1 | testOnBorrow =3D false | testOnReturn =3D fals= e | testWhileIdle =3D false | timeBetweenEvictionRunsMillis =3D -1 | = numTestsPerEvictionRun =3D 3 | minEvictableIdleTimeMillis =3D 180000= 0 | softMinEvictableIdleTimeMillis =3D -1 | whenExhaustedAction =3D 1 = |=20 > 1268 [Thread-0] DEBUG com.lexisnexis.batch.bber2.pe.ProcessingEngineJMS= Client - Attempting to create a JMS Connection to: tcp://b10dhcp18147.le= xis-nexis.com:61616 > 1660 [Thread-0] DEBUG org.apache.activemq.transport.WireFormatNegotiato= r - Sending: WireFormatInfo { version=3D1, properties=3D{TightEncodingEn= abled=3Dtrue, TcpNoDelayEnabled=3Dtrue, SizePrefixDisabled=3Dfalse, Stack= TraceEnabled=3Dtrue, MaxInactivityDuration=3D30000, CacheEnabled=3Dtrue},= magic=3D[A,c,t,i,v,e,M,Q]} > 1675 [ActiveMQ Transport: tcp://b10dhcp18147.lexis-nexis.com/138.12.248= =2E147:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator -= Received WireFormat: WireFormatInfo { version=3D2, properties=3D{TightEn= codingEnabled=3Dtrue, CacheSize=3D1024, TcpNoDelayEnabled=3Dtrue, SizePre= fixDisabled=3Dfalse, StackTraceEnabled=3Dtrue, MaxInactivityDuration=3D30= 000, CacheEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > 1675 [ActiveMQ Transport: tcp://b10dhcp18147.lexis-nexis.com/138.12.248= =2E147:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator -= tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616 before negotiati= on: OpenWireFormat{version=3D1, cacheEnabled=3Dfalse, stackTraceEnabled=3D= false, tightEncodingEnabled=3Dfalse, sizePrefixDisabled=3Dfalse} > 1691 [ActiveMQ Transport: tcp://b10dhcp18147.lexis-nexis.com/138.12.248= =2E147:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator -= tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616 after negotiatio= n: OpenWireFormat{version=3D1, cacheEnabled=3Dtrue, stackTraceEnabled=3Dt= rue, tightEncodingEnabled=3Dtrue, sizePrefixDisabled=3Dfalse} > 1722 [Thread-0] DEBUG com.lexisnexis.batch.bber2.pe.ProcessingEngineJMS= Client - JMS Init is filling Consumer collection=20 > 2020 [Thread-0] DEBUG com.lexisnexis.batch.bber2.pe.ProcessingEngineJMS= Client - JMS Init is filling Producer collection=20 > 2020 [Thread-0] DEBUG com.lexisnexis.batch.bber2.pe.ProcessingEngineJMS= Client - JMS Init is firing the Initialize Event: init is valid =3D true= > 2020 [Thread-0] DEBUG com.lexisnexis.batch.bber2.pe.ProcessingEngineJMS= Client - 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 - Re= ceived message: MessageDispatch {commandId =3D 0, responseRequired =3D fa= lse, consumerId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:1:2, destin= ation =3D queue://IPCtoPE, message =3D ActiveMQTextMessage {commandId =3D= 5, responseRequired =3D true, messageId =3D ID:LNGDAYD-4133151-1560-1178= 723147277-0:0:1:1:1, originalDestination =3D null, originalTransactionId = =3D null, producerId =3D ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1, d= estination =3D queue://IPCtoPE, transactionId =3D null, expiration =3D 0,= timestamp =3D 1178731026972, arrival =3D 0, correlationId =3D null, repl= yTo =3D null, persistent =3D true, type =3D null, priority =3D 4, groupID= =3D null, groupSequence =3D 0, targetConsumerId =3D null, compressed =3D= false, userID =3D null, content =3D org.apache.activeio.packet.ByteSeque= nce@933bcb, marshalledProperties =3D org.apache.activeio.packet.ByteSeque= nce@3ac93e, dataStructure =3D null, redeliveryCounter =3D 57, size =3D 0,= properties =3D null, readOnlyProperties =3D true, readOnlyBody =3D true,= text =3D null}, redeliveryCounter =3D 57} > 2239 [Thread-8] DEBUG ProcessingEngine - Received message: ActiveMQTex= tMessage {commandId =3D 5, responseRequired =3D true, messageId =3D ID:LN= GDAYD-4133151-1560-1178723147277-0:0:1:1:1, originalDestination =3D null,= originalTransactionId =3D null, producerId =3D ID:LNGDAYD-4133151-1560-1= 178723147277-0:0:1:1, destination =3D queue://IPCtoPE, transactionId =3D = null, expiration =3D 0, timestamp =3D 1178731026972, arrival =3D 0, corre= lationId =3D null, replyTo =3D null, persistent =3D true, type =3D null, = priority =3D 4, groupID =3D null, groupSequence =3D 0, targetConsumerId =3D= null, compressed =3D false, userID =3D null, content =3D org.apache.acti= veio.packet.ByteSequence@933bcb, marshalledProperties =3D org.apache.acti= veio.packet.ByteSequence@3ac93e, dataStructure =3D null, redeliveryCounte= r =3D 57, size =3D 0, properties =3D null, readOnlyProperties =3D true, r= eadOnlyBody =3D true, text =3D null} > 2505 [Thread-8] DEBUG ProcessEngineController - In ProcessEngineContro= ller > In ProcessEngineControllerObjectFactory, activateObject has been called= for com.lexisnexis.batch.bber2.pe.ProcessEngineController > 2505 [Thread-8] DEBUG ProcessingEngine - Borrowed ProcessEngineControl= ler contents: com.lexisnexis.batch.bber2.pe.ProcessEngineController@114b= 82b > 2505 [Thread-8] DEBUG ProcessingEngine - Processor id: com.lexisnexis.= batch.bber2.pe.ProcessEngineController@114b82b > 2505 [pool-1-thread-1] DEBUG ProcessEngineController - Creating new Li= stenableSimpleDirectedGraph > 2583 [pool-1-thread-1] DEBUG GraphBuilder - In Graph Builder > XML file name: C:\bber2cc\parkerpx_ProcessingEngine\BBR2_comps\Processi= ngEngine\ProcessingEngine/src/com/lexisnexis/batch/bber2/pe/config/produc= t.xml > 2708 [pool-1-thread-1] DEBUG GraphBuilder - adding edge to graph - fro= mNode: node1 ; toNode: node2 > 2724 [pool-1-thread-1] DEBUG GraphBuilder - Node: node2 Has this Inpu= t File: node1out1 > 2724 [pool-1-thread-1] DEBUG GraphBuilder - adding edge to graph - fro= mNode: node1 ; toNode: node3 > 2724 [pool-1-thread-1] DEBUG GraphBuilder - Node: node3 Has this Inpu= t File: node1out1 > 2724 [pool-1-thread-1] DEBUG GraphBuilder - adding edge to graph - fro= mNode: node2 ; toNode: node4 > 2724 [pool-1-thread-1] DEBUG GraphBuilder - Node: node4 Has this Inpu= t File: node2out1 > 2724 [pool-1-thread-1] DEBUG GraphBuilder - adding edge to graph - fro= mNode: node3 ; toNode: node4 > 2724 [pool-1-thread-1] DEBUG GraphBuilder - Node: node4 Has this Inpu= t File: node3out1 > graph object toString #1: ([com.lexisnexis.batch.bber2.pe.config.Proces= sDetailsType@1d32e45, com.lexisnexis.batch.bber2.pe.config.ProcessDetails= Type@182ef6b, com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@134= 7124, com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@1f02b85], [= com.lexisnexis.batch.bber2.pe.config.ConnectorDetailsType@b957ea=3D(com.l= exisnexis.batch.bber2.pe.config.ProcessDetailsType@1d32e45,com.lexisnexis= =2Ebatch.bber2.pe.config.ProcessDetailsType@182ef6b), com.lexisnexis.batc= h.bber2.pe.config.ConnectorDetailsType@1f0b7d3=3D(com.lexisnexis.batch.bb= er2.pe.config.ProcessDetailsType@1d32e45,com.lexisnexis.batch.bber2.pe.co= nfig.ProcessDetailsType@1347124), com.lexisnexis.batch.bber2.pe.config.Co= nnectorDetailsType@b4be3d=3D(com.lexisnexis.batch.bber2.pe.config.Process= DetailsType@182ef6b,com.lexisnexis.batch.bber2.pe.config.ProcessDetailsTy= pe@1f02b85), com.lexisnexis.batch.bber2.pe.config.ConnectorDetailsType@35= bb0f=3D(com.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@1347124,c= om.lexisnexis.batch.bber2.pe.config.ProcessDetailsType@1f02b85)]) > 3585 [pool-1-thread-1] DEBUG GraphRunner - Running graph in GraphRunne= r > 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= =2ESYSCS_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= =2ESYSCS_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 EmbeddedDrive= r. > Send this process to worker: node1 > has this object name: com.lexisnexis.batch.bber2.pe.config.P= rocessDetailsType@1d32e45 > 5651 [Thread-10] DEBUG org.apache.activemq.ActiveMQSession - Sending m= essage: ActiveMQTextMessage {commandId =3D 0, responseRequired =3D false,= messageId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:1, originalD= estination =3D null, originalTransactionId =3D null, producerId =3D ID:LN= GDAYD-4133151-1744-1178809137076-1:0:6:1, destination =3D queue://PEToWor= ker, transactionId =3D null, expiration =3D 0, timestamp =3D 117880914131= 8, arrival =3D 0, correlationId =3D node1, replyTo =3D temp-queue://ID:LN= GDAYD-4133151-1744-1178809137076-1:0:1, persistent =3D true, type =3D nul= l, priority =3D 4, groupID =3D null, groupSequence =3D 0, targetConsumerI= d =3D null, compressed =3D false, userID =3D null, content =3D null, mars= halledProperties =3D null, dataStructure =3D null, redeliveryCounter =3D = 0, size =3D 0, properties =3D null, readOnlyProperties =3D true, readOnly= Body =3D true, text =3D > 5870 [Thread-12] DEBUG org.apache.activemq.ActiveMQMessageConsumer - R= eceived message: MessageDispatch {commandId =3D 0, responseRequired =3D f= alse, consumerId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:2, desti= nation =3D queue://PEToWorker, message =3D ActiveMQTextMessage {commandId= =3D 22, responseRequired =3D true, messageId =3D ID:LNGDAYD-4133151-1744= -1178809137076-1:0:6:1:1, originalDestination =3D null, originalTransacti= onId =3D null, producerId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:6= :1, destination =3D queue://PEToWorker, transactionId =3D null, expiratio= n =3D 0, timestamp =3D 1178817011309, arrival =3D 0, correlationId =3D no= de1, replyTo =3D temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:1= , persistent =3D true, type =3D null, priority =3D 4, groupID =3D null, g= roupSequence =3D 0, targetConsumerId =3D null, compressed =3D false, user= ID =3D null, content =3D org.apache.activeio.packet.ByteSequence@13af084,= marshalledProperties =3D null, dataStructure =3D null, redeliveryCounter= =3D 0, size =3D 0, properties =3D null, readOnlyProperties =3D true, rea= dOnlyBody =3D true, text =3D null}, redeliveryCounter =3D 0} > 10472 [Thread-13] DEBUG DummyWorker - Dummy worker received this messa= ge: > 10613 [Thread-13] DEBUG org.apache.activemq.ActiveMQSession - Sending = message: ActiveMQTextMessage {commandId =3D 0, responseRequired =3D false= , messageId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:2:1, original= Destination =3D null, originalTransactionId =3D null, producerId =3D ID:L= NGDAYD-4133151-1744-1178809137076-1:0:6:2, destination =3D temp-queue://I= D:LNGDAYD-4133151-1744-1178809137076-1:0:1, transactionId =3D null, expir= ation =3D 0, timestamp =3D 1178809146296, arrival =3D 0, correlationId =3D= node1, replyTo =3D null, persistent =3D true, type =3D null, priority =3D= 4, groupID =3D null, groupSequence =3D 0, targetConsumerId =3D null, com= pressed =3D false, userID =3D null, content =3D null, marshalledPropertie= s =3D null, dataStructure =3D null, redeliveryCounter =3D 0, size =3D 0, = properties =3D {working_directory=3DC:/bber2cc/parkerpx_ProcessingEngine/= BBR2_comps/ProcessingEngine/ProcessingEngine/testdata/input, output_filen= ame=3Dnode1worker.txt}, readOnlyProperties =3D true, readOnlyBody =3D tru= e, text =3D WORKER SAYS - IM DONE} > 10707 [ActiveMQ Session Task] DEBUG ProcessDetailThread - Got My Resp= onse 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 i= s really done <<< > 10722 [pool-1-thread-1] DEBUG GraphRunner - From GraphRunner, ProcessD= etailThread no longer running > 10722 [pool-1-thread-1] DEBUG GraphRunner - For Node: node1 -- connec= torID: 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 connectio= n > 10957 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL SYSCS_UTI= L.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_UTI= L.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 EmbeddedDriv= er. > 10988 [pool-1-thread-1] DEBUG GraphRunner - For Node: node1 -- connec= torID: 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 co= nnectorId1 > DerbyDBManager starting in embedded mode. > 11004 [connectorId1] DEBUG DerbyDBManager - Created connection > 11020 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL SYSCS_UTI= L.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_UTI= L.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 EmbeddedDriv= er. > 11067 [connectorId2] DEBUG ConnectorDetailThread - in connector for co= nnectorId2 > DerbyDBManager starting in embedded mode. > 11067 [connectorId2] DEBUG DerbyDBManager - Created connection > 11677 [ActiveMQ Session Task] DEBUG DerbyDBManager - executed create t= able node1(phone INTEGER,personNum INTEGER primary key,address VARCHAR(25= 4),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 connectio= n > 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - tableName: NODE1 > 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - insertColumn: PER= SONNUM,FIRSTNAME,ADDRESS,PHONE > 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnIndexes: nu= ll > 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - inputFile: C:/bbe= r2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/ProcessingEngi= ne/testdata/input/node1worker.txt > 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnDelimiter: = ; > 11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - charDelimiter: nu= ll > 11896 [ActiveMQ Session Task] DEBUG DerbyDBManager - intReplace: 1 > 12460 [connectorId2] DEBUG DerbyDBManager - executed create table conn= ectorId2(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 PERSONN= UM FROM ME.NODE1 WHERE NODE1.PERSONNUM > 100) > DerbyDBManager starting in embedded mode. > 12491 [connectorId1] DEBUG DerbyDBManager - executed create table conn= ectorId1(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 I= NTO connectorId2 SELECT * FROM ME.NODE1 WHERE PERSONNUM NOT IN (SELECT PE= RSONNUM 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 c= ondition: 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 I= NTO 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_UTI= L.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_UTI= L.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 EmbeddedDriv= er. > Send this process to worker: node2 > has this object name: com.lexisnexis.batch.bber2.pe.config.P= rocessDetailsType@182ef6b > 16780 [Thread-14] DEBUG org.apache.activemq.ActiveMQSession - Sending = message: ActiveMQTextMessage {commandId =3D 0, responseRequired =3D false= , messageId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:2, original= Destination =3D null, originalTransactionId =3D null, producerId =3D ID:L= NGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =3D queue://PEToWo= rker, transactionId =3D null, expiration =3D 0, timestamp =3D 11788091524= 63, arrival =3D 0, correlationId =3D node2, replyTo =3D temp-queue://ID:L= NGDAYD-4133151-1744-1178809137076-1:0:2, persistent =3D true, type =3D nu= ll, priority =3D 4, groupID =3D null, groupSequence =3D 0, targetConsumer= Id =3D null, compressed =3D false, userID =3D null, content =3D null, mar= shalledProperties =3D null, dataStructure =3D null, redeliveryCounter =3D= 0, size =3D 0, properties =3D null, readOnlyProperties =3D true, readOnl= yBody =3D true, text =3D > 17061 [Thread-16] DEBUG org.apache.activemq.ActiveMQMessageConsumer - = Received message: MessageDispatch {commandId =3D 0, responseRequired =3D = false, consumerId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:3, dest= ination =3D queue://PEToWorker, message =3D ActiveMQTextMessage {commandI= d =3D 32, responseRequired =3D true, messageId =3D ID:LNGDAYD-4133151-174= 4-1178809137076-1:0:6:1:2, originalDestination =3D null, originalTransact= ionId =3D null, producerId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:= 6:1, destination =3D queue://PEToWorker, transactionId =3D null, expirati= on =3D 0, timestamp =3D 1178817022432, arrival =3D 0, correlationId =3D n= ode2, replyTo =3D temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:= 2, persistent =3D true, type =3D null, priority =3D 4, groupID =3D null, = groupSequence =3D 0, targetConsumerId =3D null, compressed =3D false, use= rID =3D null, content =3D org.apache.activeio.packet.ByteSequence@1033450= , marshalledProperties =3D null, dataStructure =3D null, redeliveryCounte= r =3D 0, size =3D 0, properties =3D null, readOnlyProperties =3D true, re= adOnlyBody =3D true, text =3D null}, redeliveryCounter =3D 0} > 25545 [Thread-18] DEBUG DummyWorker - Dummy worker received this messa= ge: > 25889 [Thread-18] DEBUG org.apache.activemq.ActiveMQSession - Sending = message: ActiveMQTextMessage {commandId =3D 0, responseRequired =3D false= , messageId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:3:1, original= Destination =3D null, originalTransactionId =3D null, producerId =3D ID:L= NGDAYD-4133151-1744-1178809137076-1:0:6:3, destination =3D temp-queue://I= D:LNGDAYD-4133151-1744-1178809137076-1:0:2, transactionId =3D null, expir= ation =3D 0, timestamp =3D 1178809161572, arrival =3D 0, correlationId =3D= node2, replyTo =3D null, persistent =3D true, type =3D null, priority =3D= 4, groupID =3D null, groupSequence =3D 0, targetConsumerId =3D null, com= pressed =3D false, userID =3D null, content =3D null, marshalledPropertie= s =3D null, dataStructure =3D null, redeliveryCounter =3D 0, size =3D 0, = properties =3D {working_directory=3DC:/bber2cc/parkerpx_ProcessingEngine/= BBR2_comps/ProcessingEngine/ProcessingEngine/testdata/input, output_filen= ame=3Dnode2worker.txt}, readOnlyProperties =3D true, readOnlyBody =3D tru= e, text =3D WORKER SAYS - IM DONE} > 25983 [ActiveMQ Session Task] DEBUG ProcessDetailThread - Got My Resp= onse 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 connectio= n > 25983 [pool-1-thread-1] DEBUG GraphRunner - >>> Processing for node2 i= s really done <<< > 25983 [pool-1-thread-1] DEBUG GraphRunner - From GraphRunner, ProcessD= etailThread no longer running > 25983 [pool-1-thread-1] DEBUG GraphRunner - For Node: node2 -- connec= torID: connectorId1 comes from node: node1 goes to node: node2 > 25983 [pool-1-thread-1] DEBUG GraphRunner - For Node: node2 -- connec= torID: 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_UTI= L.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_UTI= L.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 EmbeddedDriv= er. > 26061 [connectorId3] DEBUG ConnectorDetailThread - in connector for co= nnectorId3 > DerbyDBManager starting in embedded mode. > 26061 [connectorId3] DEBUG DerbyDBManager - Created connection > 26437 [ActiveMQ Session Task] DEBUG DerbyDBManager - executed create t= able node2(empNum VARCHAR(254) primary key,sport VARCHAR(254),lastName VA= RCHAR(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 conn= ectorId3(empNum VARCHAR(254) primary key,sport VARCHAR(254),lastName VARC= HAR(254)) > 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created connectio= n > 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - tableName: NODE2 > 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - insertColumn: EMP= NUM,LASTNAME,SPORT > 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnIndexes: nu= ll > 27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - inputFile: C:/bbe= r2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/ProcessingEngi= ne/testdata/input/node2worker.txt > 27846 [connectorId3] DEBUG DerbyDBManager - Closed statement > 27893 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnDelimiter: = ; > 27908 [ActiveMQ Session Task] DEBUG DerbyDBManager - charDelimiter: nu= ll > 27908 [ActiveMQ Session Task] DEBUG DerbyDBManager - intReplace: 1 > 27924 [connectorId3] DEBUG DerbyDBManager - closed connection > 27924 [connectorId3] DEBUG ConnectorDetailThread - *** Heres the all c= ondition: SELECT * FROM ME.NODE2 > DerbyDBManager starting in embedded mode. > 27924 [connectorId3] DEBUG DerbyDBManager - Created connection > 27924 [connectorId3] DEBUG DerbyDBManager - Insert statement: INSERT I= NTO 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_UTI= L.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_UTI= L.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 EmbeddedDriv= er. > Send this process to worker: node3 > has this object name: com.lexisnexis.batch.bber2.pe.config.P= rocessDetailsType@1347124 > 28691 [Thread-19] DEBUG org.apache.activemq.ActiveMQSession - Sending = message: ActiveMQTextMessage {commandId =3D 0, responseRequired =3D false= , messageId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:3, original= Destination =3D null, originalTransactionId =3D null, producerId =3D ID:L= NGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =3D queue://PEToWo= rker, transactionId =3D null, expiration =3D 0, timestamp =3D 11788091643= 74, arrival =3D 0, correlationId =3D node3, replyTo =3D temp-queue://ID:L= NGDAYD-4133151-1744-1178809137076-1:0:3, persistent =3D true, type =3D nu= ll, priority =3D 4, groupID =3D null, groupSequence =3D 0, targetConsumer= Id =3D null, compressed =3D false, userID =3D null, content =3D null, mar= shalledProperties =3D null, dataStructure =3D null, redeliveryCounter =3D= 0, size =3D 0, properties =3D null, readOnlyProperties =3D true, readOnl= yBody =3D true, text =3D > 28863 [Thread-21] DEBUG org.apache.activemq.ActiveMQMessageConsumer - = Received message: MessageDispatch {commandId =3D 0, responseRequired =3D = false, consumerId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:4, dest= ination =3D queue://PEToWorker, message =3D ActiveMQTextMessage {commandI= d =3D 42, responseRequired =3D true, messageId =3D ID:LNGDAYD-4133151-174= 4-1178809137076-1:0:6:1:3, originalDestination =3D null, originalTransact= ionId =3D null, producerId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:= 6:1, destination =3D queue://PEToWorker, transactionId =3D null, expirati= on =3D 0, timestamp =3D 1178817034323, arrival =3D 0, correlationId =3D n= ode3, replyTo =3D temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:= 3, persistent =3D true, type =3D null, priority =3D 4, groupID =3D null, = groupSequence =3D 0, targetConsumerId =3D null, compressed =3D false, use= rID =3D null, content =3D org.apache.activeio.packet.ByteSequence@13d422d= , marshalledProperties =3D null, dataStructure =3D null, redeliveryCounte= r =3D 0, size =3D 0, properties =3D null, readOnlyProperties =3D true, re= adOnlyBody =3D true, text =3D null}, redeliveryCounter =3D 0} > 34576 [Thread-24] DEBUG DummyWorker - Dummy worker received this messa= ge: > 34905 [Thread-24] DEBUG org.apache.activemq.ActiveMQSession - Sending = message: ActiveMQTextMessage {commandId =3D 0, responseRequired =3D false= , messageId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:4:1, original= Destination =3D null, originalTransactionId =3D null, producerId =3D ID:L= NGDAYD-4133151-1744-1178809137076-1:0:6:4, destination =3D temp-queue://I= D:LNGDAYD-4133151-1744-1178809137076-1:0:3, transactionId =3D null, expir= ation =3D 0, timestamp =3D 1178809170588, arrival =3D 0, correlationId =3D= node3, replyTo =3D null, persistent =3D true, type =3D null, priority =3D= 4, groupID =3D null, groupSequence =3D 0, targetConsumerId =3D null, com= pressed =3D false, userID =3D null, content =3D null, marshalledPropertie= s =3D null, dataStructure =3D null, redeliveryCounter =3D 0, size =3D 0, = properties =3D {working_directory=3DC:/bber2cc/parkerpx_ProcessingEngine/= BBR2_comps/ProcessingEngine/ProcessingEngine/testdata/input, output_filen= ame=3Dnode3worker.txt}, readOnlyProperties =3D true, readOnlyBody =3D tru= e, text =3D WORKER SAYS - IM DONE} > 34905 [ActiveMQ Session Task] DEBUG ProcessDetailThread - Got My Resp= onse 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 connectio= n > 34921 [pool-1-thread-1] DEBUG GraphRunner - >>> Processing for node3 i= s really done <<< > 34921 [pool-1-thread-1] DEBUG GraphRunner - From GraphRunner, ProcessD= etailThread no longer running > 34921 [pool-1-thread-1] DEBUG GraphRunner - For Node: node3 -- connec= torID: connectorId2 comes from node: node1 goes to node: node3 > 34921 [pool-1-thread-1] DEBUG GraphRunner - For Node: node3 -- connec= torID: 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_UTI= L.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_UTI= L.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 EmbeddedDriv= er. > 34952 [connectorId4] DEBUG ConnectorDetailThread - in connector for co= nnectorId4 > DerbyDBManager starting in embedded mode. > 34968 [connectorId4] DEBUG DerbyDBManager - Created connection > 35202 [ActiveMQ Session Task] DEBUG DerbyDBManager - executed create t= able 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 connectio= n > 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - tableName: NODE3 > 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - insertColumn: EMP= NUM,SALARY > 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnIndexes: nu= ll > 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - inputFile: C:/bbe= r2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/ProcessingEngi= ne/testdata/input/node3worker.txt > 35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnDelimiter: = ; > 35375 [connectorId4] DEBUG DerbyDBManager - executed create table conn= ectorId4(empNum VARCHAR(254) primary key,salary DOUBLE) > 37096 [ActiveMQ Session Task] DEBUG DerbyDBManager - charDelimiter: nu= ll > 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 c= ondition: 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 I= NTO connectorId4 SELECT * FROM ME.NODE3 WHERE NODE3.SALARY > 10000 > 37441 [connectorId4] DEBUG DerbyDBManager - exception thrown: > 37441 [connectorId4] DEBUG DerbyDBManager - SQL Exception: Container 9= 92 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_UTI= L.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_UTI= L.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 EmbeddedDriv= er. > Send this process to worker: node4 > has this object name: com.lexisnexis.batch.bber2.pe.config.P= rocessDetailsType@1f02b85 > 37613 [Thread-25] DEBUG org.apache.activemq.ActiveMQSession - Sending = message: ActiveMQTextMessage {commandId =3D 0, responseRequired =3D false= , messageId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:4, original= Destination =3D null, originalTransactionId =3D null, producerId =3D ID:L= NGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =3D queue://PEToWo= rker, transactionId =3D null, expiration =3D 0, timestamp =3D 11788091732= 96, arrival =3D 0, correlationId =3D node4, replyTo =3D temp-queue://ID:L= NGDAYD-4133151-1744-1178809137076-1:0:4, persistent =3D true, type =3D nu= ll, priority =3D 4, groupID =3D null, groupSequence =3D 0, targetConsumer= Id =3D null, compressed =3D false, userID =3D null, content =3D null, mar= shalledProperties =3D null, dataStructure =3D null, redeliveryCounter =3D= 0, size =3D 0, properties =3D null, readOnlyProperties =3D true, readOnl= yBody =3D true, text =3D > 37863 [Thread-27] DEBUG org.apache.activemq.ActiveMQMessageConsumer - = Received message: MessageDispatch {commandId =3D 0, responseRequired =3D = false, consumerId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:5, dest= ination =3D queue://PEToWorker, message =3D ActiveMQTextMessage {commandI= d =3D 52, responseRequired =3D true, messageId =3D ID:LNGDAYD-4133151-174= 4-1178809137076-1:0:6:1:4, originalDestination =3D null, originalTransact= ionId =3D null, producerId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:= 6:1, destination =3D queue://PEToWorker, transactionId =3D null, expirati= on =3D 0, timestamp =3D 1178817043222, arrival =3D 0, correlationId =3D n= ode4, replyTo =3D temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:= 4, persistent =3D true, type =3D null, priority =3D 4, groupID =3D null, = groupSequence =3D 0, targetConsumerId =3D null, compressed =3D false, use= rID =3D null, content =3D org.apache.activeio.packet.ByteSequence@b6b2a5,= marshalledProperties =3D null, dataStructure =3D null, redeliveryCounter= =3D 0, size =3D 0, properties =3D null, readOnlyProperties =3D true, rea= dOnlyBody =3D true, text =3D null}, redeliveryCounter =3D 0} > 42653 [Thread-31] DEBUG DummyWorker - Dummy worker received this messa= ge: > 42888 [Thread-31] DEBUG org.apache.activemq.ActiveMQSession - Sending = message: ActiveMQTextMessage {commandId =3D 0, responseRequired =3D false= , messageId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:5:1, original= Destination =3D null, originalTransactionId =3D null, producerId =3D ID:L= NGDAYD-4133151-1744-1178809137076-1:0:6:5, destination =3D temp-queue://I= D:LNGDAYD-4133151-1744-1178809137076-1:0:4, transactionId =3D null, expir= ation =3D 0, timestamp =3D 1178809178571, arrival =3D 0, correlationId =3D= node4, replyTo =3D null, persistent =3D true, type =3D null, priority =3D= 4, groupID =3D null, groupSequence =3D 0, targetConsumerId =3D null, com= pressed =3D false, userID =3D null, content =3D null, marshalledPropertie= s =3D null, dataStructure =3D null, redeliveryCounter =3D 0, size =3D 0, = properties =3D {working_directory=3DC:/bber2cc/parkerpx_ProcessingEngine/= BBR2_comps/ProcessingEngine/ProcessingEngine/testdata/input, output_filen= ame=3Dnode4worker.txt}, readOnlyProperties =3D true, readOnlyBody =3D tru= e, text =3D WORKER SAYS - IM DONE} > 42888 [ActiveMQ Session Task] DEBUG ProcessDetailThread - Got My Resp= onse 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 i= s really done <<< > 42903 [pool-1-thread-1] DEBUG GraphRunner - From GraphRunner, ProcessD= etailThread no longer running > 42903 [pool-1-thread-1] DEBUG GraphRunner - For Node: node4 -- connec= torID: connectorId3 comes from node: node2 goes to node: node4 > 42903 [pool-1-thread-1] DEBUG GraphRunner - For Node: node4 -- connec= torID: connectorId4 comes from node: node3 goes to node: node4 > 42903 [pool-1-thread-1] DEBUG ProcessEngineController - done running G= raphRunner > 42903 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created connectio= n > XML file name: C:/bber2cc/parkerpx_OutputProc/BBR2_comps/OutputProcessi= ng/OutputProcessingEngine/src/com/lexisnexis/batch/bber2/output/processor= /config/new_output_instance.xml > 43029 [Thread-8] DEBUG org.apache.activemq.ActiveMQSession - Sending m= essage: ActiveMQTextMessage {commandId =3D 0, responseRequired =3D false,= messageId =3D ID:LNGDAYD-4133151-1744-1178809137076-1:0:4:1:1, originalD= estination =3D null, originalTransactionId =3D null, producerId =3D ID:LN= GDAYD-4133151-1744-1178809137076-1:0:4:1, destination =3D queue://PEtoOPE= , transactionId =3D null, expiration =3D 0, timestamp =3D 1178809178712, = arrival =3D 0, correlationId =3D null, replyTo =3D null, persistent =3D t= rue, type =3D null, priority =3D 4, groupID =3D null, groupSequence =3D 0= , targetConsumerId =3D null, compressed =3D false, userID =3D null, conte= nt =3D null, marshalledProperties =3D null, dataStructure =3D null, redel= iveryCounter =3D 0, size =3D 0, properties =3D null, readOnlyProperties =3D= true, readOnlyBody =3D true, text =3D > 43060 [Thread-8] DEBUG ProcessingEngine - ActiveMQTextMessage {command= Id =3D 5, responseRequired =3D true, messageId =3D ID:LNGDAYD-4133151-156= 0-1178723147277-0:0:1:1:1, originalDestination =3D null, originalTransact= ionId =3D null, producerId =3D ID:LNGDAYD-4133151-1560-1178723147277-0:0:= 1:1, destination =3D queue://IPCtoPE, transactionId =3D null, expiration = =3D 0, timestamp =3D 1178731026972, arrival =3D 0, correlationId =3D null= , replyTo =3D null, persistent =3D true, type =3D null, priority =3D 4, g= roupID =3D null, groupSequence =3D 0, targetConsumerId =3D null, compress= ed =3D false, userID =3D null, content =3D org.apache.activeio.packet.Byt= eSequence@933bcb, marshalledProperties =3D org.apache.activeio.packet.Byt= eSequence@3ac93e, dataStructure =3D null, redeliveryCounter =3D 57, size = =3D 0, properties =3D null, readOnlyProperties =3D true, readOnlyBody =3D= true, text =3D null} > 43060 [Thread-8] DEBUG ProcessingEngine - ** Processor Resumes Reading= > 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - executed create t= able 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 connectio= n > 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - tableName: NODE4 > 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - insertColumn: EMP= NUM,PAYDAY > 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnIndexes: nu= ll > 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - inputFile: C:/bbe= r2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/ProcessingEngi= ne/testdata/input/node4worker.txt > 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnDelimiter: = ; > 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - charDelimiter: nu= ll > 43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - intReplace: 1 > =20