Hi Mike, I am using different connections to do my load and select. I do my bulk load into an empty table.
Thanks Patty -----Original Message----- From: Mike Matrigali [mailto:[EMAIL PROTECTED] Sent: Friday, May 11, 2007 8:06 PM To: Derby Discussion Subject: Re: SQL Exception: Container xxx not found Are the two threads sharing the same Connection object (and thus the same transaction)? If not I also would have expected a lock wait call. There may be a problem with dependency management. Are you using bulk load to load an empty table? /mikem Parker, Patricia (LNG-CON) wrote: > 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:[EMAIL PROTECTED] > 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 > >>[EMAIL PROTECTED]> >> >>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:[EMAIL PROTECTED] >>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 = [EMAIL PROTECTED], > marshalledProperties = [EMAIL PROTECTED], > 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 = [EMAIL PROTECTED], > marshalledProperties = [EMAIL PROTECTED], > 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: > [EMAIL PROTECTED] > >>2505 [Thread-8] DEBUG ProcessingEngine - Processor id: > > [EMAIL PROTECTED] > >>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: > > ([EMAIL PROTECTED], > [EMAIL PROTECTED], > [EMAIL PROTECTED], > [EMAIL PROTECTED], > [EMAIL PROTECTED](com.l > [EMAIL PROTECTED],com.lexisnexi > [EMAIL PROTECTED]), > [EMAIL PROTECTED](com.l > [EMAIL PROTECTED],com.lexisnexi > [EMAIL PROTECTED]), > [EMAIL PROTECTED](com.le > [EMAIL PROTECTED],com.lexisnexis > [EMAIL PROTECTED]), > [EMAIL PROTECTED](com.le > [EMAIL PROTECTED],com.lexisnexis > [EMAIL PROTECTED])]) > >>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: > > [EMAIL PROTECTED] > >>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 = > [EMAIL PROTECTED], 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: > > [EMAIL PROTECTED] > >>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 = > [EMAIL PROTECTED], 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: > > [EMAIL PROTECTED] > >>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 = > [EMAIL PROTECTED], 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: > > [EMAIL PROTECTED] > >>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 = > [EMAIL PROTECTED], 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 = [EMAIL PROTECTED], > marshalledProperties = [EMAIL PROTECTED], > 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 >> > > > >
