View Issue Details
ID | Project | Category | View Status | Date Submitted | Last Update |
---|---|---|---|---|---|
0001814 | SymmetricDS | Bug | public | 2014-07-16 10:02 | 2014-07-29 20:50 |
Reporter | ErnstErnst | Assigned To | chenson | ||
Priority | normal | ||||
Status | closed | Resolution | fixed | ||
Product Version | 3.6.1 | ||||
Target Version | 3.6.3 | Fixed in Version | 3.6.3 | ||
Summary | 0001814: NullPointerException in AbstractTriggerTemplate.createInitalLoadSql | ||||
Description | I get a NullPointerException when I try to replicate a change to a replicated database table (see more details in the 'Steps To Reproduce' section). | ||||
Steps To Reproduce | This issue can be reproduced by using the attached files and following these steps: create a database sym-corp in the SQL Server 2008 R2 create a database sym-corp in the SQL Server 2008 R2 --> corp and store databases exist ..\bin\dbimport --engine corp-000 --format XML C:\Users\user.name\symmetricds\sym-corp\symmetric-3.6.1\samples\create_sample.xml ..\bin\symadmin --engine corp-000 create-sym-tables ..\bin\dbimport --engine corp-000 C:\Users\user.name\symmetricds\sym-corp\symmetric-3.6.1\samples\insert_sample.sql --> corp node is set up ..\bin\sym --engine corp-000 --port 7070 --> corp node starts ..\bin\sym --engine store-001 --port 9090 --> store node starts ..\bin\symadmin --engine corp-000 open-registration store 001 --> the store node registers at the corp node ..\bin\symadmin reload-node 001 --> tables are created on the store node execute sql "ALTER TABLE dbo.item ADD COMMENT varchar(16)" at the corp node --> new column 'COMMENT' is added to the table ..\bin\symadmin sync-triggers ..\bin\symadmin send-schema --node 001 dbo.item ..\bin\symadmin reload-node 001 --> NullPointerException on corp node, no changes on store node | ||||
Additional Information | 2014-07-16 11:08:34,417 ERROR [corp-000] [DataExtractorService] [qtp1023040-20] Failed to extract batch 001-132 java.lang.NullPointerException at org.jumpmind.symmetric.db.AbstractTriggerTemplate.createInitalLoadSql(AbstractTriggerTemplate.java:134) at org.jumpmind.symmetric.db.AbstractSymmetricDialect.createInitialLoadSqlFor(AbstractSymmetricDialect.java:214) at org.jumpmind.symmetric.service.impl.DataExtractorService$SelectFromTableSource.startNewCursor(DataExtractorService.java:1571) at org.jumpmind.symmetric.service.impl.DataExtractorService$SelectFromTableSource.selectNext(DataExtractorService.java:1542) at org.jumpmind.symmetric.service.impl.DataExtractorService$SelectFromTableSource.next(DataExtractorService.java:1501) at org.jumpmind.symmetric.service.impl.DataExtractorService$SelectFromSymDataSource.next(DataExtractorService.java:1358) at org.jumpmind.symmetric.io.data.reader.ExtractDataReader.nextTable(ExtractDataReader.java:94) at org.jumpmind.symmetric.io.data.DataProcessor.forEachTableInBatch(DataProcessor.java:160) at org.jumpmind.symmetric.io.data.DataProcessor.process(DataProcessor.java:115) at org.jumpmind.symmetric.service.impl.DataExtractorService.extractOutgoingBatch(DataExtractorService.java:703) at org.jumpmind.symmetric.service.impl.DataExtractorService.extract(DataExtractorService.java:513) at org.jumpmind.symmetric.service.impl.DataExtractorService.extract(DataExtractorService.java:422) at org.jumpmind.symmetric.web.PullUriHandler.pull(PullUriHandler.java:117) at org.jumpmind.symmetric.web.PullUriHandler.handleWithCompression(PullUriHandler.java:89) at org.jumpmind.symmetric.web.AbstractCompressionUriHandler.handle(AbstractCompressionUriHandler.java:84) at org.jumpmind.symmetric.web.SymmetricServlet.service(SymmetricServlet.java:98) at javax.servlet.http.HttpServlet.service(HttpServlet.java:820) at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:565) at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:479) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:119) at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:524) at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:227) at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1031) at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:406) at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:186) at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:965) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:117) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:111) at org.eclipse.jetty.server.Server.handle(Server.java:348) at org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:452) at org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:884) at org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:938) at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:630) at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:230) at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:77) at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:606) at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:46) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:603) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:538) at java.lang.Thread.run(Thread.java:662) | ||||
Tags | No tags attached. | ||||
|
|
|
|
|
|
|
|
|
should be create a database sym-corp in the SQL Server 2008 R2 create a database sym-store in the SQL Server 2008 R2 --> corp and store databases exist instead of create a database sym-corp in the SQL Server 2008 R2 create a database sym-corp in the SQL Server 2008 R2 --> corp and store databases exist |
|
Can you test the fix? I had trouble reproducing. http://snapshots.repository.codehaus.org/org/jumpmind/symmetric/symmetric-assemble/3.6.3-SNAPSHOT/symmetric-assemble-3.6.3-20140716.121313-5-server.zip |
|
When I use symmetric-3.6.3-SNAPSHOT, then the exception is: 2014-07-16 15:49:57,855 ERROR [corp-000] [DataExtractorService] [qtp14372770-20] Failed to extract batch 001-20 org.jumpmind.symmetric.SymmetricException: The extracted row data did not have the expected (2) number of columns: "11000001","Yummy Gum" at org.jumpmind.symmetric.service.impl.DataExtractorService$SelectFromTableSource$1.mapRow(DataExtractorService.java:1598) at org.jumpmind.symmetric.service.impl.DataExtractorService$SelectFromTableSource$1.mapRow(DataExtractorService.java:1576) at org.jumpmind.db.sql.JdbcSqlReadCursor.next(JdbcSqlReadCursor.java:115) at org.jumpmind.symmetric.service.impl.DataExtractorService$SelectFromTableSource.selectNext(DataExtractorService.java:1550) at org.jumpmind.symmetric.service.impl.DataExtractorService$SelectFromTableSource.next(DataExtractorService.java:1501) at org.jumpmind.symmetric.service.impl.DataExtractorService$SelectFromSymDataSource.next(DataExtractorService.java:1358) at org.jumpmind.symmetric.io.data.reader.ExtractDataReader.nextTable(ExtractDataReader.java:99) at org.jumpmind.symmetric.io.data.DataProcessor.forEachTableInBatch(DataProcessor.java:160) at org.jumpmind.symmetric.io.data.DataProcessor.process(DataProcessor.java:115) at org.jumpmind.symmetric.service.impl.DataExtractorService.extractOutgoingBatch(DataExtractorService.java:703) at org.jumpmind.symmetric.service.impl.DataExtractorService.extract(DataExtractorService.java:513) at org.jumpmind.symmetric.service.impl.DataExtractorService.extract(DataExtractorService.java:422) at org.jumpmind.symmetric.web.PullUriHandler.pull(PullUriHandler.java:117) at org.jumpmind.symmetric.web.PullUriHandler.handleWithCompression(PullUriHandler.java:89) at org.jumpmind.symmetric.web.AbstractCompressionUriHandler.handle(AbstractCompressionUriHandler.java:84) at org.jumpmind.symmetric.web.SymmetricServlet.service(SymmetricServlet.java:98) at javax.servlet.http.HttpServlet.service(HttpServlet.java:820) at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:565) at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:479) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:119) at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:524) at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:227) at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1031) at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:406) at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:186) at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:965) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:117) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:111) at org.eclipse.jetty.server.Server.handle(Server.java:348) at org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:452) at org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:884) at org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:938) at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:630) at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:230) at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:77) at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:606) at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:46) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:603) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:538) at java.lang.Thread.run(Thread.java:662) |
|
|
|
symmetric.store.symmetric-3.6.3-SNAPSHOT.log (156,457 bytes)
2014-07-16 15:23:01,850 INFO [startup] [AbstractCommandLauncher] [main] Option: name=engine, value={store-001} 2014-07-16 15:23:01,850 INFO [startup] [AbstractCommandLauncher] [main] Option: name=port, value={9090} 2014-07-16 15:23:01,947 INFO [startup] [SymmetricWebServer] [main] About to start SymmetricDS web server on host:port default:9090 2014-07-16 15:23:03,058 INFO [startup] [/] [main] Initializing Spring root WebApplicationContext 2014-07-16 15:23:03,600 INFO [store-001] [JdbcDatabasePlatformFactory] [symmetric-startup] Detected database 'Microsoft SQL Server', version '10', protocol 'jtds' 2014-07-16 15:23:03,639 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] The DbDialect being used is org.jumpmind.symmetric.db.mssql.MsSqlSymmetricDialect 2014-07-16 15:23:03,647 INFO [store-001] [StagingManager] [symmetric-startup] The staging directory was initialized at the following location: C:\Users\user.name\symmetricds\sym-store-fix\symmetric-3.6.3-SNAPSHOT\tmp\store-001 2014-07-16 15:23:03,678 INFO [store-001] [ClusterService] [symmetric-startup] This node picked a server id of T005583.eu.Micros.int 2014-07-16 15:23:03,875 INFO [store-001] [ExtensionPointManager] [symmetric-startup] Found 8 extension points that will be registered 2014-07-16 15:23:03,897 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] Initializing SymmetricDS database 2014-07-16 15:23:03,898 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Checking if SymmetricDS tables need created or altered 2014-07-16 15:23:03,930 INFO [startup] [/] [main] Initializing Spring FrameworkServlet 'rest' 2014-07-16 15:23:04,057 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] There are SymmetricDS tables that needed altered 2014-07-16 15:23:04,076 INFO [startup] [SymmetricWebServer] [main] Starting JMX HTTP console on port 9091 2014-07-16 15:23:04,076 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,076 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,081 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_channel"( "channel_id" VARCHAR(128) NOT NULL, "processing_order" INT DEFAULT 1 NOT NULL, "max_batch_size" INT DEFAULT 1000 NOT NULL, "max_batch_to_send" INT DEFAULT 60 NOT NULL, "max_data_to_route" INT DEFAULT 100000 NOT NULL, "extract_period_millis" INT DEFAULT 0 NOT NULL, "enabled" SMALLINT DEFAULT 1 NOT NULL, "use_old_data_to_route" SMALLINT DEFAULT 1 NOT NULL, "use_row_data_to_route" SMALLINT DEFAULT 1 NOT NULL, "use_pk_data_to_route" SMALLINT DEFAULT 1 NOT NULL, "reload_flag" SMALLINT DEFAULT 0 NOT NULL, "file_sync_flag" SMALLINT DEFAULT 0 NOT NULL, "contains_big_lob" SMALLINT DEFAULT 0 NOT NULL, "batch_algorithm" VARCHAR(50) DEFAULT 'default' NOT NULL, "data_loader_type" VARCHAR(50) DEFAULT 'default' NOT NULL, "description" VARCHAR(255), "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("channel_id") ) 2014-07-16 15:23:04,082 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,084 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_conflict"( "conflict_id" VARCHAR(50) NOT NULL, "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "target_channel_id" VARCHAR(128), "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255), "detect_type" VARCHAR(128) NOT NULL, "detect_expression" TEXT, "resolve_type" VARCHAR(128) NOT NULL, "ping_back" VARCHAR(128) NOT NULL, "resolve_changes_only" SMALLINT DEFAULT 0, "resolve_row_only" SMALLINT DEFAULT 0, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("conflict_id") ) 2014-07-16 15:23:04,085 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,086 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_data"( "data_id" BIGINT NOT NULL IDENTITY (1,1) , "table_name" VARCHAR(255) NOT NULL, "event_type" CHAR(1) NOT NULL, "row_data" TEXT, "pk_data" TEXT, "old_data" TEXT, "trigger_hist_id" INT NOT NULL, "channel_id" VARCHAR(128), "transaction_id" VARCHAR(255), "source_node_id" VARCHAR(50), "external_data" VARCHAR(50), "node_list" VARCHAR(255), "create_time" DATETIME, PRIMARY KEY ("data_id") ) 2014-07-16 15:23:04,087 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_d_channel_id" ON "sym_data" ("data_id", "channel_id") 2014-07-16 15:23:04,087 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,088 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_data_event"( "data_id" BIGINT NOT NULL, "batch_id" BIGINT NOT NULL, "router_id" VARCHAR(50) NOT NULL, "create_time" DATETIME, PRIMARY KEY ("data_id", "batch_id", "router_id") ) 2014-07-16 15:23:04,089 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_de_batchid" ON "sym_data_event" ("batch_id") 2014-07-16 15:23:04,091 INFO [startup] [SymmetricWebServer] [main] Joining the web server main thread 2014-07-16 15:23:04,095 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,096 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_data_gap"( "start_id" BIGINT NOT NULL, "end_id" BIGINT NOT NULL, "status" CHAR(2), "create_time" DATETIME NOT NULL, "last_update_hostname" VARCHAR(255), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("start_id", "end_id") ) 2014-07-16 15:23:04,107 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_dg_status" ON "sym_data_gap" ("status") 2014-07-16 15:23:04,107 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,108 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_extract_request"( "request_id" BIGINT NOT NULL, "node_id" VARCHAR(50) NOT NULL, "status" CHAR(2), "start_batch_id" BIGINT NOT NULL, "end_batch_id" BIGINT NOT NULL, "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "last_update_time" DATETIME, "create_time" DATETIME, PRIMARY KEY ("request_id") ) 2014-07-16 15:23:04,118 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,118 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_file_incoming"( "relative_dir" VARCHAR(255) NOT NULL, "file_name" VARCHAR(128) NOT NULL, "last_event_type" CHAR(1) NOT NULL, "node_id" VARCHAR(50) NOT NULL, "file_modified_time" BIGINT, PRIMARY KEY ("relative_dir", "file_name") ) 2014-07-16 15:23:04,130 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,131 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_file_snapshot"( "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "relative_dir" VARCHAR(255) NOT NULL, "file_name" VARCHAR(128) NOT NULL, "channel_id" VARCHAR(128) DEFAULT 'filesync' NOT NULL, "reload_channel_id" VARCHAR(128) DEFAULT 'filesync_reload' NOT NULL, "last_event_type" CHAR(1) NOT NULL, "crc32_checksum" BIGINT, "file_size" BIGINT, "file_modified_time" BIGINT, "last_update_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "create_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id", "router_id", "relative_dir", "file_name") ) 2014-07-16 15:23:04,142 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_f_snpsht_chid" ON "sym_file_snapshot" ("reload_channel_id") 2014-07-16 15:23:04,142 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,145 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_file_trigger"( "trigger_id" VARCHAR(128) NOT NULL, "channel_id" VARCHAR(128) DEFAULT 'filesync' NOT NULL, "reload_channel_id" VARCHAR(128) DEFAULT 'filesync_reload' NOT NULL, "base_dir" VARCHAR(255) NOT NULL, "recurse" SMALLINT DEFAULT 1 NOT NULL, "includes_files" VARCHAR(255), "excludes_files" VARCHAR(255), "sync_on_create" SMALLINT DEFAULT 1 NOT NULL, "sync_on_modified" SMALLINT DEFAULT 1 NOT NULL, "sync_on_delete" SMALLINT DEFAULT 1 NOT NULL, "sync_on_ctl_file" SMALLINT DEFAULT 0 NOT NULL, "delete_after_sync" SMALLINT DEFAULT 0 NOT NULL, "before_copy_script" TEXT, "after_copy_script" TEXT, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id") ) 2014-07-16 15:23:04,166 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,168 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_file_trigger_router"( "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "enabled" SMALLINT DEFAULT 1 NOT NULL, "initial_load_enabled" SMALLINT DEFAULT 1 NOT NULL, "target_base_dir" VARCHAR(255), "conflict_strategy" VARCHAR(128) DEFAULT 'source_wins' NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id", "router_id") ) 2014-07-16 15:23:04,179 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,180 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_grouplet"( "grouplet_id" VARCHAR(50) NOT NULL, "grouplet_link_policy" CHAR(1) DEFAULT 'I' NOT NULL, "description" VARCHAR(255), "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("grouplet_id") ) 2014-07-16 15:23:04,190 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,191 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_grouplet_link"( "grouplet_id" VARCHAR(50) NOT NULL, "external_id" VARCHAR(50) NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("grouplet_id", "external_id") ) 2014-07-16 15:23:04,202 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,206 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_incoming_batch"( "batch_id" BIGINT NOT NULL, "node_id" VARCHAR(50) NOT NULL, "channel_id" VARCHAR(128), "status" CHAR(2), "error_flag" SMALLINT DEFAULT 0, "network_millis" BIGINT DEFAULT 0 NOT NULL, "filter_millis" BIGINT DEFAULT 0 NOT NULL, "database_millis" BIGINT DEFAULT 0 NOT NULL, "failed_row_number" BIGINT DEFAULT 0 NOT NULL, "failed_line_number" BIGINT DEFAULT 0 NOT NULL, "byte_count" BIGINT DEFAULT 0 NOT NULL, "statement_count" BIGINT DEFAULT 0 NOT NULL, "fallback_insert_count" BIGINT DEFAULT 0 NOT NULL, "fallback_update_count" BIGINT DEFAULT 0 NOT NULL, "ignore_count" BIGINT DEFAULT 0 NOT NULL, "missing_delete_count" BIGINT DEFAULT 0 NOT NULL, "skip_count" BIGINT DEFAULT 0 NOT NULL, "sql_state" VARCHAR(10), "sql_code" INT DEFAULT 0 NOT NULL, "sql_message" TEXT, "last_update_hostname" VARCHAR(255), "last_update_time" DATETIME, "create_time" DATETIME, PRIMARY KEY ("batch_id", "node_id") ) 2014-07-16 15:23:04,227 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ib_time_status" ON "sym_incoming_batch" ("create_time", "status") 2014-07-16 15:23:04,239 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ib_in_error" ON "sym_incoming_batch" ("error_flag") 2014-07-16 15:23:04,240 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,241 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_incoming_error"( "batch_id" BIGINT NOT NULL, "node_id" VARCHAR(50) NOT NULL, "failed_row_number" BIGINT NOT NULL, "failed_line_number" BIGINT DEFAULT 0 NOT NULL, "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255) NOT NULL, "event_type" CHAR(1) NOT NULL, "binary_encoding" VARCHAR(10) DEFAULT 'HEX' NOT NULL, "column_names" TEXT NOT NULL, "pk_column_names" TEXT NOT NULL, "row_data" TEXT, "old_data" TEXT, "cur_data" TEXT, "resolve_data" TEXT, "resolve_ignore" SMALLINT DEFAULT 0, "conflict_id" VARCHAR(50), "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("batch_id", "node_id", "failed_row_number") ) 2014-07-16 15:23:04,263 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,265 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_load_filter"( "load_filter_id" VARCHAR(50) NOT NULL, "load_filter_type" VARCHAR(10) NOT NULL, "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255), "filter_on_update" SMALLINT DEFAULT 1 NOT NULL, "filter_on_insert" SMALLINT DEFAULT 1 NOT NULL, "filter_on_delete" SMALLINT DEFAULT 1 NOT NULL, "before_write_script" TEXT, "after_write_script" TEXT, "batch_complete_script" TEXT, "batch_commit_script" TEXT, "batch_rollback_script" TEXT, "handle_error_script" TEXT, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, "load_filter_order" INT DEFAULT 1 NOT NULL, "fail_on_error" SMALLINT DEFAULT 0 NOT NULL, PRIMARY KEY ("load_filter_id") ) 2014-07-16 15:23:04,288 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,292 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_lock"( "lock_action" VARCHAR(50) NOT NULL, "lock_type" VARCHAR(50) NOT NULL, "locking_server_id" VARCHAR(255), "lock_time" DATETIME, "shared_count" INT DEFAULT 0 NOT NULL, "shared_enable" INT DEFAULT 0 NOT NULL, "last_lock_time" DATETIME, "last_locking_server_id" VARCHAR(255), PRIMARY KEY ("lock_action") ) 2014-07-16 15:23:04,299 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,301 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node"( "node_id" VARCHAR(50) NOT NULL, "node_group_id" VARCHAR(50) NOT NULL, "external_id" VARCHAR(50) NOT NULL, "sync_enabled" SMALLINT DEFAULT 0, "sync_url" VARCHAR(255), "schema_version" VARCHAR(50), "symmetric_version" VARCHAR(50), "database_type" VARCHAR(50), "database_version" VARCHAR(50), "heartbeat_time" DATETIME, "timezone_offset" VARCHAR(6), "batch_to_send_count" INT DEFAULT 0, "batch_in_error_count" INT DEFAULT 0, "created_at_node_id" VARCHAR(50), "deployment_type" VARCHAR(50), PRIMARY KEY ("node_id") ) 2014-07-16 15:23:04,324 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,326 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_communication"( "node_id" VARCHAR(50) NOT NULL, "communication_type" VARCHAR(10) NOT NULL, "lock_time" DATETIME, "locking_server_id" VARCHAR(255), "last_lock_time" DATETIME, "last_lock_millis" BIGINT DEFAULT 0, "success_count" BIGINT DEFAULT 0, "fail_count" BIGINT DEFAULT 0, "total_success_count" BIGINT DEFAULT 0, "total_fail_count" BIGINT DEFAULT 0, "total_success_millis" BIGINT DEFAULT 0, "total_fail_millis" BIGINT DEFAULT 0, PRIMARY KEY ("node_id", "communication_type") ) 2014-07-16 15:23:04,335 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,337 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_channel_ctl"( "node_id" VARCHAR(50) NOT NULL, "channel_id" VARCHAR(128) NOT NULL, "suspend_enabled" SMALLINT DEFAULT 0, "ignore_enabled" SMALLINT DEFAULT 0, "last_extract_time" DATETIME, PRIMARY KEY ("node_id", "channel_id") ) 2014-07-16 15:23:04,348 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,349 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_group"( "node_group_id" VARCHAR(50) NOT NULL, "description" VARCHAR(255), "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("node_group_id") ) 2014-07-16 15:23:04,360 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,361 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_group_channel_wnd"( "node_group_id" VARCHAR(50) NOT NULL, "channel_id" VARCHAR(128) NOT NULL, "start_time" DATETIME NOT NULL, "end_time" DATETIME NOT NULL, "enabled" SMALLINT DEFAULT 0 NOT NULL, PRIMARY KEY ("node_group_id", "channel_id", "start_time", "end_time") ) 2014-07-16 15:23:04,361 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,373 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_group_link"( "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "data_event_action" CHAR(1) DEFAULT 'W' NOT NULL, "sync_config_enabled" SMALLINT DEFAULT 1 NOT NULL, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("source_node_group_id", "target_node_group_id") ) 2014-07-16 15:23:04,374 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,385 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_host"( "node_id" VARCHAR(50) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "ip_address" VARCHAR(50), "os_user" VARCHAR(50), "os_name" VARCHAR(50), "os_arch" VARCHAR(50), "os_version" VARCHAR(50), "available_processors" INT DEFAULT 0, "free_memory_bytes" BIGINT DEFAULT 0, "total_memory_bytes" BIGINT DEFAULT 0, "max_memory_bytes" BIGINT DEFAULT 0, "java_version" VARCHAR(50), "java_vendor" VARCHAR(255), "jdbc_version" VARCHAR(255), "symmetric_version" VARCHAR(50), "timezone_offset" VARCHAR(6), "heartbeat_time" DATETIME, "last_restart_time" DATETIME NOT NULL, "create_time" DATETIME NOT NULL, PRIMARY KEY ("node_id", "host_name") ) 2014-07-16 15:23:04,397 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,411 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_host_channel_stats"( "node_id" VARCHAR(50) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "channel_id" VARCHAR(128) NOT NULL, "start_time" DATETIME NOT NULL, "end_time" DATETIME NOT NULL, "data_routed" BIGINT DEFAULT 0, "data_unrouted" BIGINT DEFAULT 0, "data_event_inserted" BIGINT DEFAULT 0, "data_extracted" BIGINT DEFAULT 0, "data_bytes_extracted" BIGINT DEFAULT 0, "data_extracted_errors" BIGINT DEFAULT 0, "data_bytes_sent" BIGINT DEFAULT 0, "data_sent" BIGINT DEFAULT 0, "data_sent_errors" BIGINT DEFAULT 0, "data_loaded" BIGINT DEFAULT 0, "data_bytes_loaded" BIGINT DEFAULT 0, "data_loaded_errors" BIGINT DEFAULT 0, PRIMARY KEY ("node_id", "host_name", "channel_id", "start_time", "end_time") ) 2014-07-16 15:23:04,422 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_nd_hst_chnl_sts" ON "sym_node_host_channel_stats" ("node_id", "start_time", "end_time") 2014-07-16 15:23:04,433 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,434 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_host_job_stats"( "node_id" VARCHAR(50) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "job_name" VARCHAR(50) NOT NULL, "start_time" DATETIME NOT NULL, "end_time" DATETIME NOT NULL, "processed_count" BIGINT DEFAULT 0, PRIMARY KEY ("node_id", "host_name", "job_name", "start_time", "end_time") ) 2014-07-16 15:23:04,446 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_nd_hst_job" ON "sym_node_host_job_stats" ("node_id", "start_time", "end_time") 2014-07-16 15:23:04,446 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,464 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_host_stats"( "node_id" VARCHAR(50) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "start_time" DATETIME NOT NULL, "end_time" DATETIME NOT NULL, "restarted" BIGINT DEFAULT 0 NOT NULL, "nodes_pulled" BIGINT DEFAULT 0, "total_nodes_pull_time" BIGINT DEFAULT 0, "nodes_pushed" BIGINT DEFAULT 0, "total_nodes_push_time" BIGINT DEFAULT 0, "nodes_rejected" BIGINT DEFAULT 0, "nodes_registered" BIGINT DEFAULT 0, "nodes_loaded" BIGINT DEFAULT 0, "nodes_disabled" BIGINT DEFAULT 0, "purged_data_rows" BIGINT DEFAULT 0, "purged_data_event_rows" BIGINT DEFAULT 0, "purged_batch_outgoing_rows" BIGINT DEFAULT 0, "purged_batch_incoming_rows" BIGINT DEFAULT 0, "triggers_created_count" BIGINT, "triggers_rebuilt_count" BIGINT, "triggers_removed_count" BIGINT, PRIMARY KEY ("node_id", "host_name", "start_time", "end_time") ) 2014-07-16 15:23:04,482 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_nd_hst_sts" ON "sym_node_host_stats" ("node_id", "start_time", "end_time") 2014-07-16 15:23:04,482 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,483 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_identity"( "node_id" VARCHAR(50) NOT NULL, PRIMARY KEY ("node_id") ) 2014-07-16 15:23:04,484 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,485 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_security"( "node_id" VARCHAR(50) NOT NULL, "node_password" VARCHAR(50) NOT NULL, "registration_enabled" SMALLINT DEFAULT 0, "registration_time" DATETIME, "initial_load_enabled" SMALLINT DEFAULT 0, "initial_load_time" DATETIME, "initial_load_id" BIGINT, "initial_load_create_by" VARCHAR(255), "rev_initial_load_enabled" SMALLINT DEFAULT 0, "rev_initial_load_time" DATETIME, "rev_initial_load_id" BIGINT, "rev_initial_load_create_by" VARCHAR(255), "created_at_node_id" VARCHAR(50) NOT NULL, PRIMARY KEY ("node_id") ) 2014-07-16 15:23:04,508 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,513 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_outgoing_batch"( "batch_id" BIGINT NOT NULL, "node_id" VARCHAR(50) NOT NULL, "channel_id" VARCHAR(128), "status" CHAR(2), "load_id" BIGINT, "extract_job_flag" SMALLINT DEFAULT 0, "load_flag" SMALLINT DEFAULT 0, "error_flag" SMALLINT DEFAULT 0, "common_flag" SMALLINT DEFAULT 0, "ignore_count" BIGINT DEFAULT 0 NOT NULL, "byte_count" BIGINT DEFAULT 0 NOT NULL, "extract_count" BIGINT DEFAULT 0 NOT NULL, "sent_count" BIGINT DEFAULT 0 NOT NULL, "load_count" BIGINT DEFAULT 0 NOT NULL, "data_event_count" BIGINT DEFAULT 0 NOT NULL, "reload_event_count" BIGINT DEFAULT 0 NOT NULL, "insert_event_count" BIGINT DEFAULT 0 NOT NULL, "update_event_count" BIGINT DEFAULT 0 NOT NULL, "delete_event_count" BIGINT DEFAULT 0 NOT NULL, "other_event_count" BIGINT DEFAULT 0 NOT NULL, "router_millis" BIGINT DEFAULT 0 NOT NULL, "network_millis" BIGINT DEFAULT 0 NOT NULL, "filter_millis" BIGINT DEFAULT 0 NOT NULL, "load_millis" BIGINT DEFAULT 0 NOT NULL, "extract_millis" BIGINT DEFAULT 0 NOT NULL, "sql_state" VARCHAR(10), "sql_code" INT DEFAULT 0 NOT NULL, "sql_message" TEXT, "failed_data_id" BIGINT DEFAULT 0 NOT NULL, "failed_line_number" BIGINT DEFAULT 0 NOT NULL, "last_update_hostname" VARCHAR(255), "last_update_time" DATETIME, "create_time" DATETIME, "create_by" VARCHAR(255), PRIMARY KEY ("batch_id", "node_id") ) 2014-07-16 15:23:04,545 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ob_node_status" ON "sym_outgoing_batch" ("node_id", "status") 2014-07-16 15:23:04,546 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ob_status" ON "sym_outgoing_batch" ("status") 2014-07-16 15:23:04,546 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ob_in_error" ON "sym_outgoing_batch" ("error_flag") 2014-07-16 15:23:04,547 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,550 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_parameter"( "external_id" VARCHAR(50) NOT NULL, "node_group_id" VARCHAR(50) NOT NULL, "param_key" VARCHAR(80) NOT NULL, "param_value" TEXT, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("external_id", "node_group_id", "param_key") ) 2014-07-16 15:23:04,556 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,557 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_registration_redirect"( "registrant_external_id" VARCHAR(50) NOT NULL, "registration_node_id" VARCHAR(50) NOT NULL, PRIMARY KEY ("registrant_external_id") ) 2014-07-16 15:23:04,559 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,560 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_registration_request"( "node_group_id" VARCHAR(50) NOT NULL, "external_id" VARCHAR(50) NOT NULL, "status" CHAR(2) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "ip_address" VARCHAR(50) NOT NULL, "attempt_count" INT DEFAULT 0, "registered_node_id" VARCHAR(50), "error_message" TEXT, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("node_group_id", "external_id", "create_time") ) 2014-07-16 15:23:04,572 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_reg_req_1" ON "sym_registration_request" ("node_group_id", "external_id", "status", "host_name", "ip_address") 2014-07-16 15:23:04,573 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_reg_req_2" ON "sym_registration_request" ("status") 2014-07-16 15:23:04,583 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,585 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_router"( "router_id" VARCHAR(50) NOT NULL, "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255), "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "router_type" VARCHAR(50), "router_expression" TEXT, "sync_on_update" SMALLINT DEFAULT 1 NOT NULL, "sync_on_insert" SMALLINT DEFAULT 1 NOT NULL, "sync_on_delete" SMALLINT DEFAULT 1 NOT NULL, "use_source_catalog_schema" SMALLINT DEFAULT 1 NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("router_id") ) 2014-07-16 15:23:04,596 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,614 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_sequence"( "sequence_name" VARCHAR(50) NOT NULL, "current_value" BIGINT DEFAULT 0 NOT NULL, "increment_by" INT DEFAULT 1 NOT NULL, "min_value" BIGINT DEFAULT 1 NOT NULL, "max_value" BIGINT DEFAULT 9999999999 NOT NULL, "cycle" SMALLINT DEFAULT 0, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("sequence_name") ) 2014-07-16 15:23:04,620 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,621 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_table_reload_request"( "target_node_id" VARCHAR(50) NOT NULL, "source_node_id" VARCHAR(50) NOT NULL, "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "reload_select" TEXT, "reload_delete_stmt" TEXT, "reload_enabled" SMALLINT DEFAULT 0, "reload_time" DATETIME, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("target_node_id", "source_node_id", "trigger_id", "router_id") ) 2014-07-16 15:23:04,632 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,634 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_transform_table"( "transform_id" VARCHAR(50) NOT NULL, "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "transform_point" VARCHAR(10) NOT NULL, "source_catalog_name" VARCHAR(255), "source_schema_name" VARCHAR(255), "source_table_name" VARCHAR(255) NOT NULL, "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255), "update_first" SMALLINT DEFAULT 0, "delete_action" VARCHAR(10) NOT NULL, "transform_order" INT DEFAULT 1 NOT NULL, "column_policy" VARCHAR(10) DEFAULT 'SPECIFIED' NOT NULL, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("transform_id", "source_node_group_id", "target_node_group_id") ) 2014-07-16 15:23:04,656 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,657 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_transform_column"( "transform_id" VARCHAR(50) NOT NULL, "include_on" CHAR(1) DEFAULT '*' NOT NULL, "target_column_name" VARCHAR(128) NOT NULL, "source_column_name" VARCHAR(128), "pk" SMALLINT DEFAULT 0, "transform_type" VARCHAR(50) DEFAULT 'copy', "transform_expression" TEXT, "transform_order" INT DEFAULT 1 NOT NULL, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("transform_id", "include_on", "target_column_name") ) 2014-07-16 15:23:04,663 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,666 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_trigger"( "trigger_id" VARCHAR(128) NOT NULL, "source_catalog_name" VARCHAR(255), "source_schema_name" VARCHAR(255), "source_table_name" VARCHAR(255) NOT NULL, "channel_id" VARCHAR(128) NOT NULL, "reload_channel_id" VARCHAR(128) DEFAULT 'reload' NOT NULL, "sync_on_update" SMALLINT DEFAULT 1 NOT NULL, "sync_on_insert" SMALLINT DEFAULT 1 NOT NULL, "sync_on_delete" SMALLINT DEFAULT 1 NOT NULL, "sync_on_incoming_batch" SMALLINT DEFAULT 0 NOT NULL, "name_for_update_trigger" VARCHAR(255), "name_for_insert_trigger" VARCHAR(255), "name_for_delete_trigger" VARCHAR(255), "sync_on_update_condition" TEXT, "sync_on_insert_condition" TEXT, "sync_on_delete_condition" TEXT, "custom_on_update_text" TEXT, "custom_on_insert_text" TEXT, "custom_on_delete_text" TEXT, "external_select" TEXT, "tx_id_expression" TEXT, "channel_expression" TEXT, "excluded_column_names" TEXT, "sync_key_names" TEXT, "use_stream_lobs" SMALLINT DEFAULT 0 NOT NULL, "use_capture_lobs" SMALLINT DEFAULT 0 NOT NULL, "use_capture_old_data" SMALLINT DEFAULT 1 NOT NULL, "use_handle_key_updates" SMALLINT DEFAULT 0 NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id") ) 2014-07-16 15:23:04,698 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,700 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_trigger_hist"( "trigger_hist_id" INT NOT NULL, "trigger_id" VARCHAR(128) NOT NULL, "source_table_name" VARCHAR(255) NOT NULL, "source_catalog_name" VARCHAR(255), "source_schema_name" VARCHAR(255), "name_for_update_trigger" VARCHAR(255), "name_for_insert_trigger" VARCHAR(255), "name_for_delete_trigger" VARCHAR(255), "table_hash" BIGINT DEFAULT 0 NOT NULL, "trigger_row_hash" BIGINT DEFAULT 0 NOT NULL, "trigger_template_hash" BIGINT DEFAULT 0 NOT NULL, "column_names" TEXT NOT NULL, "pk_column_names" TEXT NOT NULL, "last_trigger_build_reason" CHAR(1) NOT NULL, "error_message" TEXT, "create_time" DATETIME NOT NULL, "inactive_time" DATETIME, PRIMARY KEY ("trigger_hist_id") ) 2014-07-16 15:23:04,722 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,724 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_trigger_router"( "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "enabled" SMALLINT DEFAULT 1 NOT NULL, "initial_load_order" INT DEFAULT 1 NOT NULL, "initial_load_select" TEXT, "initial_load_delete_stmt" TEXT, "initial_load_batch_count" INT DEFAULT 1, "ping_back_enabled" SMALLINT DEFAULT 0 NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id", "router_id") ) 2014-07-16 15:23:04,734 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:23:04,735 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_trigger_router_grouplet"( "grouplet_id" VARCHAR(50) NOT NULL, "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "applies_when" CHAR(1) NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("grouplet_id", "trigger_id", "router_id", "applies_when") ) 2014-07-16 15:23:04,748 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_conflict" ADD CONSTRAINT "sym_fk_cf_2_grp_lnk" FOREIGN KEY ("source_node_group_id", "target_node_group_id") REFERENCES "sym_node_group_link" ("source_node_group_id", "target_node_group_id") 2014-07-16 15:23:04,751 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_file_trigger_router" ADD CONSTRAINT "sym_fk_ftr_2_ftrg" FOREIGN KEY ("trigger_id") REFERENCES "sym_file_trigger" ("trigger_id") 2014-07-16 15:23:04,752 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_file_trigger_router" ADD CONSTRAINT "sym_fk_ftr_2_rtr" FOREIGN KEY ("router_id") REFERENCES "sym_router" ("router_id") 2014-07-16 15:23:04,753 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_grouplet_link" ADD CONSTRAINT "sym_fk_gpltlnk_2_gplt" FOREIGN KEY ("grouplet_id") REFERENCES "sym_grouplet" ("grouplet_id") 2014-07-16 15:23:04,756 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_node_group_link" ADD CONSTRAINT "sym_fk_lnk_2_grp_src" FOREIGN KEY ("source_node_group_id") REFERENCES "sym_node_group" ("node_group_id") 2014-07-16 15:23:04,757 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_node_group_link" ADD CONSTRAINT "sym_fk_lnk_2_grp_tgt" FOREIGN KEY ("target_node_group_id") REFERENCES "sym_node_group" ("node_group_id") 2014-07-16 15:23:04,758 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_node_identity" ADD CONSTRAINT "sym_fk_ident_2_node" FOREIGN KEY ("node_id") REFERENCES "sym_node" ("node_id") 2014-07-16 15:23:04,761 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_node_security" ADD CONSTRAINT "sym_fk_sec_2_node" FOREIGN KEY ("node_id") REFERENCES "sym_node" ("node_id") 2014-07-16 15:23:04,761 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_router" ADD CONSTRAINT "sym_fk_rt_2_grp_lnk" FOREIGN KEY ("source_node_group_id", "target_node_group_id") REFERENCES "sym_node_group_link" ("source_node_group_id", "target_node_group_id") 2014-07-16 15:23:04,763 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_transform_table" ADD CONSTRAINT "sym_fk_tt_2_grp_lnk" FOREIGN KEY ("source_node_group_id", "target_node_group_id") REFERENCES "sym_node_group_link" ("source_node_group_id", "target_node_group_id") 2014-07-16 15:23:04,765 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger" ADD CONSTRAINT "sym_fk_trg_2_chnl" FOREIGN KEY ("channel_id") REFERENCES "sym_channel" ("channel_id") 2014-07-16 15:23:04,766 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger" ADD CONSTRAINT "sym_fk_trg_2_rld_chnl" FOREIGN KEY ("reload_channel_id") REFERENCES "sym_channel" ("channel_id") 2014-07-16 15:23:04,776 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger_router" ADD CONSTRAINT "sym_fk_tr_2_trg" FOREIGN KEY ("trigger_id") REFERENCES "sym_trigger" ("trigger_id") 2014-07-16 15:23:04,777 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger_router" ADD CONSTRAINT "sym_fk_tr_2_rtr" FOREIGN KEY ("router_id") REFERENCES "sym_router" ("router_id") 2014-07-16 15:23:04,778 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger_router_grouplet" ADD CONSTRAINT "sym_fk_trgplt_2_gplt" FOREIGN KEY ("grouplet_id") REFERENCES "sym_grouplet" ("grouplet_id") 2014-07-16 15:23:04,778 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger_router_grouplet" ADD CONSTRAINT "sym_fk_trgplt_2_tr" FOREIGN KEY ("trigger_id", "router_id") REFERENCES "sym_trigger_router" ("trigger_id", "router_id") 2014-07-16 15:23:04,780 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Done with auto update of SymmetricDS tables 2014-07-16 15:23:04,791 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Updating indexes to prevent lock escalation 2014-07-16 15:23:04,837 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Just installed sym_base64_encode 2014-07-16 15:23:04,840 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Just installed sym_triggers_disabled 2014-07-16 15:23:04,842 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Just installed sym_node_disabled 2014-07-16 15:23:04,844 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring config channel 2014-07-16 15:23:04,852 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring reload channel 2014-07-16 15:23:04,854 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring heartbeat channel 2014-07-16 15:23:04,855 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring default channel 2014-07-16 15:23:04,856 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring dynamic channel 2014-07-16 15:23:04,857 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring filesync channel 2014-07-16 15:23:04,858 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring filesync_reload channel 2014-07-16 15:23:04,876 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] Done initializing SymmetricDS database 2014-07-16 15:23:05,089 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] Starting unregistered node [group=store, externalId=001] 2014-07-16 15:23:05,090 INFO [store-001] [RouterJob] [symmetric-startup] Starting job.routing on periodic schedule: every 5000ms with the first run at Wed Jul 16 15:23:12 CEST 2014 2014-07-16 15:23:05,092 INFO [store-001] [PushJob] [symmetric-startup] Starting job.push on periodic schedule: every 10000ms with the first run at Wed Jul 16 15:23:12 CEST 2014 2014-07-16 15:23:05,093 INFO [store-001] [PullJob] [symmetric-startup] Starting job.pull on periodic schedule: every 10000ms with the first run at Wed Jul 16 15:23:12 CEST 2014 2014-07-16 15:23:05,093 INFO [store-001] [OutgoingPurgeJob] [symmetric-startup] Starting job.purge.outgoing with cron expression: 0 0 0 * * * 2014-07-16 15:23:05,095 INFO [store-001] [IncomingPurgeJob] [symmetric-startup] Starting job.purge.incoming with cron expression: 0 0 0 * * * 2014-07-16 15:23:05,096 INFO [store-001] [DataGapPurgeJob] [symmetric-startup] Starting job.purge.datagaps with cron expression: 0 0 0 * * * 2014-07-16 15:23:05,096 INFO [store-001] [StatisticFlushJob] [symmetric-startup] Starting job.stat.flush with cron expression: 0 0/5 * * * * 2014-07-16 15:23:05,097 INFO [store-001] [SyncTriggersJob] [symmetric-startup] Starting job.synctriggers with cron expression: 0 0 0 * * * 2014-07-16 15:23:05,097 INFO [store-001] [HeartbeatJob] [symmetric-startup] Starting job.heartbeat on periodic schedule: every 900000ms with the first run at Wed Jul 16 15:23:12 CEST 2014 2014-07-16 15:23:05,097 INFO [store-001] [WatchdogJob] [symmetric-startup] Starting job.watchdog on periodic schedule: every 3600000ms with the first run at Wed Jul 16 15:23:12 CEST 2014 2014-07-16 15:23:05,098 INFO [store-001] [StageManagementJob] [symmetric-startup] Starting job.stage.management on periodic schedule: every 15000ms with the first run at Wed Jul 16 15:23:12 CEST 2014 2014-07-16 15:23:05,101 INFO [store-001] [JobManager] [symmetric-startup] Job job.refresh.cache not configured for auto start 2014-07-16 15:23:05,102 INFO [store-001] [FileSyncTrackerJob] [symmetric-startup] Starting job.file.sync.tracker with cron expression: 0 0/5 * * * * 2014-07-16 15:23:05,102 INFO [store-001] [FileSyncPullJob] [symmetric-startup] Starting job.file.sync.pull on periodic schedule: every 60000ms with the first run at Wed Jul 16 15:23:12 CEST 2014 2014-07-16 15:23:05,102 INFO [store-001] [FileSyncPushJob] [symmetric-startup] Starting job.file.sync.push on periodic schedule: every 60000ms with the first run at Wed Jul 16 15:23:12 CEST 2014 2014-07-16 15:23:05,103 INFO [store-001] [InitialLoadExtractorJob] [symmetric-startup] Starting job.initial.load.extract on periodic schedule: every 10000ms with the first run at Wed Jul 16 15:23:12 CEST 2014 2014-07-16 15:23:05,103 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] Started SymmetricDS 2014-07-16 15:23:05,103 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] SymmetricDS: type=server, name=store-001, version=3.6.3-SNAPSHOT, groupId=store, externalId=001, databaseName=Microsoft SQL Server, databaseVersion=10.50, driverName=jTDS Type 4 JDBC Driver for MS SQL Server and Sybase, driverVersion=1.2.4 2014-07-16 15:23:12,460 INFO [store-001] [PushJob] [store-001-job-8] Did not run the job.push job because the engine is not registered. 2014-07-16 15:23:12,460 INFO [store-001] [RouterJob] [store-001-job-12] Did not run the job.routing job because the engine is not registered. 2014-07-16 15:23:12,465 INFO [store-001] [RegistrationService] [store-001-job-8] This node is unregistered. It will attempt to register using the registration.url 2014-07-16 15:23:12,466 INFO [store-001] [StageManagementJob] [store-001-job-6] Did not run the job.stage.management job because the engine is not registered. 2014-07-16 15:23:12,469 INFO [store-001] [FileSyncPushJob] [store-001-job-4] Did not run the job.file.sync.push job because the engine is not registered. 2014-07-16 15:23:12,470 INFO [store-001] [FileSyncPullJob] [store-001-job-4] Did not run the job.file.sync.pull job because the engine is not registered. 2014-07-16 15:23:12,470 INFO [store-001] [InitialLoadExtractorJob] [store-001-job-4] Did not run the job.initial.load.extract job because the engine is not registered. 2014-07-16 15:23:12,477 INFO [store-001] [DataLoaderService] [store-001-job-8] Using registration URL of http://localhost:7070/sync/corp-000/registration?nodeGroupId=store&externalId=001&syncURL=http%3A%2F%2FT005583.eu.Micros.int%3A31415%2Fsync%2Fstore-001&schemaVersion=%3F&databaseType=Microsoft+SQL+Server&databaseVersion=10.50&symmetricVersion=3.6.3-SNAPSHOT&hostName=T005583.eu.Micros.int&ipAddress=fe80%3A0%3A0%3A0%3A0%3A5efe%3Aa00%3Aa%2517 2014-07-16 15:23:13,487 WARN [store-001] [RegistrationService] [store-001-job-8] The request to register failed because the client failed to connect to the server 2014-07-16 15:23:13,489 WARN [store-001] [RegistrationService] [store-001-job-8] Could not register. Sleeping before attempting again. 2014-07-16 15:23:13,489 INFO [store-001] [RegistrationService] [store-001-job-8] Sleeping for 6000ms 2014-07-16 15:23:19,489 INFO [store-001] [RegistrationService] [store-001-job-8] This node is unregistered. It will attempt to register using the registration.url 2014-07-16 15:23:19,496 INFO [store-001] [DataLoaderService] [store-001-job-8] Using registration URL of http://localhost:7070/sync/corp-000/registration?nodeGroupId=store&externalId=001&syncURL=http%3A%2F%2FT005583.eu.Micros.int%3A31415%2Fsync%2Fstore-001&schemaVersion=%3F&databaseType=Microsoft+SQL+Server&databaseVersion=10.50&symmetricVersion=3.6.3-SNAPSHOT&hostName=T005583.eu.Micros.int&ipAddress=fe80%3A0%3A0%3A0%3A0%3A5efe%3Aa00%3Aa%2517 2014-07-16 15:23:19,631 WARN [store-001] [DataLoaderService] [store-001-job-8] Registration attempt failed. Registration was not open 2014-07-16 15:23:19,632 WARN [store-001] [RegistrationService] [store-001-job-8] Could not register. Sleeping before attempting again. 2014-07-16 15:23:19,633 INFO [store-001] [RegistrationService] [store-001-job-8] Sleeping for 17000ms 2014-07-16 15:23:36,635 INFO [store-001] [RegistrationService] [store-001-job-8] This node is unregistered. It will attempt to register using the registration.url 2014-07-16 15:23:36,642 INFO [store-001] [DataLoaderService] [store-001-job-8] Using registration URL of http://localhost:7070/sync/corp-000/registration?nodeGroupId=store&externalId=001&syncURL=http%3A%2F%2FT005583.eu.Micros.int%3A31415%2Fsync%2Fstore-001&schemaVersion=%3F&databaseType=Microsoft+SQL+Server&databaseVersion=10.50&symmetricVersion=3.6.3-SNAPSHOT&hostName=T005583.eu.Micros.int&ipAddress=fe80%3A0%3A0%3A0%3A0%3A5efe%3Aa00%3Aa%2517 2014-07-16 15:23:36,814 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] This database DOES support disabling triggers during a symmetricds data load 2014-07-16 15:23:37,000 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-8] Grouplets flushed because new grouplet config came through the data loader 2014-07-16 15:23:37,000 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-8] Load filters flushed because new filter config came through the data loader 2014-07-16 15:23:37,001 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-8] Channels flushed because new channels came through the data loader 2014-07-16 15:23:37,001 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-8] About to refresh the cache of transformation because new configuration came through the data loader 2014-07-16 15:23:37,001 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-8] About to refresh the cache of conflict settings because new configuration came through the data loader 2014-07-16 15:23:37,001 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-8] About to refresh the cache of parameters because new configuration came through the data loader 2014-07-16 15:23:37,006 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-8] About to syncTriggers because new configuration came through the data loader 2014-07-16 15:23:37,007 INFO [store-001] [TriggerRouterService] [store-001-job-8] Synchronizing triggers 2014-07-16 15:23:37,058 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_LD_FLTR_STR trigger for sym-store.dbo.sym_load_filter 2014-07-16 15:23:37,065 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_LD_FLTR_STR trigger for sym-store.dbo.sym_load_filter 2014-07-16 15:23:37,070 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_LD_FLTR_STR trigger for sym-store.dbo.sym_load_filter 2014-07-16 15:23:37,076 ERROR [store-001] [TriggerRouterService] [store-001-job-8] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:23:37,086 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_FL_SNPSHT_STR trigger for sym-store.dbo.sym_file_snapshot 2014-07-16 15:23:37,090 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_FL_SNPSHT_STR trigger for sym-store.dbo.sym_file_snapshot 2014-07-16 15:23:37,104 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_CNFLCT_STR trigger for sym-store.dbo.sym_conflict 2014-07-16 15:23:37,109 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_CNFLCT_STR trigger for sym-store.dbo.sym_conflict 2014-07-16 15:23:37,113 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_CNFLCT_STR trigger for sym-store.dbo.sym_conflict 2014-07-16 15:23:37,123 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_GRPLT_STR trigger for sym-store.dbo.sym_grouplet 2014-07-16 15:23:37,127 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_GRPLT_STR trigger for sym-store.dbo.sym_grouplet 2014-07-16 15:23:37,131 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_GRPLT_STR trigger for sym-store.dbo.sym_grouplet 2014-07-16 15:23:37,141 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_TRGGR_RTR_GRPLT_STR trigger for sym-store.dbo.sym_trigger_router_grouplet 2014-07-16 15:23:37,145 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_TRGGR_RTR_GRPLT_STR trigger for sym-store.dbo.sym_trigger_router_grouplet 2014-07-16 15:23:37,148 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_TRGGR_RTR_GRPLT_STR trigger for sym-store.dbo.sym_trigger_router_grouplet 2014-07-16 15:23:37,160 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_RTR_STR trigger for sym-store.dbo.sym_router 2014-07-16 15:23:37,165 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_RTR_STR trigger for sym-store.dbo.sym_router 2014-07-16 15:23:37,169 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_RTR_STR trigger for sym-store.dbo.sym_router 2014-07-16 15:23:37,181 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_FL_TRGGR_RTR_STR trigger for sym-store.dbo.sym_file_trigger_router 2014-07-16 15:23:37,184 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_FL_TRGGR_RTR_STR trigger for sym-store.dbo.sym_file_trigger_router 2014-07-16 15:23:37,188 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_FL_TRGGR_RTR_STR trigger for sym-store.dbo.sym_file_trigger_router 2014-07-16 15:23:37,201 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_TRGGR_RTR_STR trigger for sym-store.dbo.sym_trigger_router 2014-07-16 15:23:37,205 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_TRGGR_RTR_STR trigger for sym-store.dbo.sym_trigger_router 2014-07-16 15:23:37,208 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_TRGGR_RTR_STR trigger for sym-store.dbo.sym_trigger_router 2014-07-16 15:23:37,220 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_ND_GRP_CHNNL_WND_STR trigger for sym-store.dbo.sym_node_group_channel_wnd 2014-07-16 15:23:37,223 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_ND_GRP_CHNNL_WND_STR trigger for sym-store.dbo.sym_node_group_channel_wnd 2014-07-16 15:23:37,228 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_ND_GRP_CHNNL_WND_STR trigger for sym-store.dbo.sym_node_group_channel_wnd 2014-07-16 15:23:37,239 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_ND_GRP_LNK_STR trigger for sym-store.dbo.sym_node_group_link 2014-07-16 15:23:37,242 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_ND_GRP_LNK_STR trigger for sym-store.dbo.sym_node_group_link 2014-07-16 15:23:37,245 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_ND_GRP_LNK_STR trigger for sym-store.dbo.sym_node_group_link 2014-07-16 15:23:37,249 ERROR [store-001] [TriggerRouterService] [store-001-job-8] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:23:37,265 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_ND_HST_STR trigger for sym-store.dbo.sym_node_host 2014-07-16 15:23:37,271 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_ND_HST_STR trigger for sym-store.dbo.sym_node_host 2014-07-16 15:23:37,276 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_ND_HST_STR trigger for sym-store.dbo.sym_node_host 2014-07-16 15:23:37,288 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_CHNNL_STR trigger for sym-store.dbo.sym_channel 2014-07-16 15:23:37,293 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_CHNNL_STR trigger for sym-store.dbo.sym_channel 2014-07-16 15:23:37,297 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_CHNNL_STR trigger for sym-store.dbo.sym_channel 2014-07-16 15:23:37,302 ERROR [store-001] [TriggerRouterService] [store-001-job-8] Could not find any database tables matching 'sale_return_line_item' in the datasource that is configured 2014-07-16 15:23:37,310 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_FL_TRGGR_STR trigger for sym-store.dbo.sym_file_trigger 2014-07-16 15:23:37,314 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_FL_TRGGR_STR trigger for sym-store.dbo.sym_file_trigger 2014-07-16 15:23:37,319 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_FL_TRGGR_STR trigger for sym-store.dbo.sym_file_trigger 2014-07-16 15:23:37,329 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_ND_STR trigger for sym-store.dbo.sym_node 2014-07-16 15:23:37,333 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_ND_STR trigger for sym-store.dbo.sym_node 2014-07-16 15:23:37,338 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_ND_STR trigger for sym-store.dbo.sym_node 2014-07-16 15:23:37,342 ERROR [store-001] [TriggerRouterService] [store-001-job-8] Could not find any database tables matching 'sale_tender_line_item' in the datasource that is configured 2014-07-16 15:23:37,350 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_GRPLT_LNK_STR trigger for sym-store.dbo.sym_grouplet_link 2014-07-16 15:23:37,353 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_GRPLT_LNK_STR trigger for sym-store.dbo.sym_grouplet_link 2014-07-16 15:23:37,356 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_GRPLT_LNK_STR trigger for sym-store.dbo.sym_grouplet_link 2014-07-16 15:23:37,367 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_ND_SCRTY_STR trigger for sym-store.dbo.sym_node_security 2014-07-16 15:23:37,370 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_ND_SCRTY_STR trigger for sym-store.dbo.sym_node_security 2014-07-16 15:23:37,375 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_ND_SCRTY_STR trigger for sym-store.dbo.sym_node_security 2014-07-16 15:23:37,388 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_TRGGR_STR trigger for sym-store.dbo.sym_trigger 2014-07-16 15:23:37,393 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_TRGGR_STR trigger for sym-store.dbo.sym_trigger 2014-07-16 15:23:37,399 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_TRGGR_STR trigger for sym-store.dbo.sym_trigger 2014-07-16 15:23:37,411 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_TRNSFRM_CLMN_STR trigger for sym-store.dbo.sym_transform_column 2014-07-16 15:23:37,415 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_TRNSFRM_CLMN_STR trigger for sym-store.dbo.sym_transform_column 2014-07-16 15:23:37,419 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_TRNSFRM_CLMN_STR trigger for sym-store.dbo.sym_transform_column 2014-07-16 15:23:37,430 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_TBL_RLD_RQST_STR trigger for sym-store.dbo.sym_table_reload_request 2014-07-16 15:23:37,434 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_TBL_RLD_RQST_STR trigger for sym-store.dbo.sym_table_reload_request 2014-07-16 15:23:37,438 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_TBL_RLD_RQST_STR trigger for sym-store.dbo.sym_table_reload_request 2014-07-16 15:23:37,449 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_ND_GRP_STR trigger for sym-store.dbo.sym_node_group 2014-07-16 15:23:37,451 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_ND_GRP_STR trigger for sym-store.dbo.sym_node_group 2014-07-16 15:23:37,454 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_ND_GRP_STR trigger for sym-store.dbo.sym_node_group 2014-07-16 15:23:37,465 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_PRMTR_STR trigger for sym-store.dbo.sym_parameter 2014-07-16 15:23:37,468 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_PRMTR_STR trigger for sym-store.dbo.sym_parameter 2014-07-16 15:23:37,473 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_PRMTR_STR trigger for sym-store.dbo.sym_parameter 2014-07-16 15:23:37,485 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_I_FOR_SYM_TRNSFRM_TBL_STR trigger for sym-store.dbo.sym_transform_table 2014-07-16 15:23:37,488 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_U_FOR_SYM_TRNSFRM_TBL_STR trigger for sym-store.dbo.sym_transform_table 2014-07-16 15:23:37,492 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-8] Creating SYM_ON_D_FOR_SYM_TRNSFRM_TBL_STR trigger for sym-store.dbo.sym_transform_table 2014-07-16 15:23:37,495 INFO [store-001] [TriggerRouterService] [store-001-job-8] Done synchronizing triggers 2014-07-16 15:23:37,522 INFO [store-001] [RegistrationService] [store-001-job-8] Successfully registered node [id=001] 2014-07-16 15:23:37,523 INFO [store-001] [PushHeartbeatListener] [store-001-job-8] Some attribute(s) of node changed. Recording changes 2014-07-16 15:23:37,524 INFO [store-001] [PushHeartbeatListener] [store-001-job-8] Updating my node configuration info according to the symmetric properties 2014-07-16 15:23:37,533 INFO [store-001] [RouterService] [store-001-job-11] The 'config' channel is NOT in common batch mode 2014-07-16 15:23:37,593 INFO [store-001] [RouterService] [store-001-job-11] The 'filesync_reload' channel is NOT in common batch mode 2014-07-16 15:23:37,595 INFO [store-001] [RouterService] [store-001-job-11] The 'item' channel is in common batch mode 2014-07-16 15:23:37,596 INFO [store-001] [RouterService] [store-001-job-11] The 'reload' channel is NOT in common batch mode 2014-07-16 15:23:37,597 INFO [store-001] [RouterService] [store-001-job-11] The 'sale_transaction' channel is in common batch mode 2014-07-16 15:23:37,598 INFO [store-001] [RouterService] [store-001-job-11] The 'heartbeat' channel is NOT in common batch mode 2014-07-16 15:23:37,603 INFO [store-001] [RouterService] [store-001-job-11] The 'filesync' channel is NOT in common batch mode 2014-07-16 15:23:37,604 INFO [store-001] [RouterService] [store-001-job-11] The 'default' channel is in common batch mode 2014-07-16 15:23:37,605 INFO [store-001] [RouterService] [store-001-job-11] The 'dynamic' channel is in common batch mode 2014-07-16 15:23:37,606 INFO [store-001] [RouterService] [store-001-job-11] Routed 2 data events in 103 ms 2014-07-16 15:23:42,524 INFO [store-001] [PushService] [store-001-push-1] Push data sent to corp:000:000 2014-07-16 15:23:42,580 INFO [store-001] [PushService] [store-001-push-1] Pushed data to corp:000:000. 2 data and 2 batches were processed 2014-07-16 15:23:47,659 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 1 rows and 1 batches were processed 2014-07-16 15:23:52,657 INFO [store-001] [RouterService] [store-001-job-14] Routed 1 data events in 13 ms 2014-07-16 15:25:57,702 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 1 rows and 1 batches were processed 2014-07-16 15:25:57,703 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:25:57,727 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-pull-1] About to syncTriggers because new configuration came through the data loader 2014-07-16 15:25:57,727 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Synchronizing triggers 2014-07-16 15:25:57,854 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:25:57,867 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:25:57,871 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_return_line_item' in the datasource that is configured 2014-07-16 15:25:57,875 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_tender_line_item' in the datasource that is configured 2014-07-16 15:25:57,886 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Done synchronizing triggers 2014-07-16 15:25:57,895 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 2 rows and 2 batches were processed 2014-07-16 15:25:57,896 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:25:57,923 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="name" type="VARCHAR" size="100"> <platform-column name="mssql2008" type="varchar" size="100"/> </column> </table> </database> 2014-07-16 15:25:57,926 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Running alter sql: SET quoted_identifier on; SET quoted_identifier on; CREATE TABLE "item"( "item_id" int NOT NULL, "name" varchar(100), PRIMARY KEY ("item_id") ); 2014-07-16 15:25:57,949 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 3 rows and 3 batches were processed 2014-07-16 15:25:57,949 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:25:57,964 INFO [store-001] [RouterService] [store-001-job-15] Routed 1 data events in 19 ms 2014-07-16 15:25:57,970 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item_selling_price"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="store_id" primaryKey="true" required="true" type="VARCHAR" size="5"> <platform-column name="mssql2008" type="varchar" size="5"/> </column> <column name="price" required="true" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <column name="cost" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <foreign-key name="fk_price_item_id" foreignTable="item"> <reference local="item_id" foreign="item_id"/> </foreign-key> </table> </database> 2014-07-16 15:25:57,972 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Running alter sql: SET quoted_identifier on; SET quoted_identifier on; CREATE TABLE "item_selling_price"( "item_id" int NOT NULL, "store_id" varchar(5) NOT NULL, "price" decimal(10,2) NOT NULL, "cost" decimal(10,2), PRIMARY KEY ("item_id", "store_id") ); ALTER TABLE "item_selling_price" ADD CONSTRAINT "fk_price_item_id" FOREIGN KEY ("item_id") REFERENCES "item" ("item_id"); 2014-07-16 15:25:57,996 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 4 rows and 4 batches were processed 2014-07-16 15:25:57,996 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:25:58,028 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 4 rows and 4 batches were processed 2014-07-16 15:27:07,732 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 1 rows and 1 batches were processed 2014-07-16 15:27:07,733 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:27:07,761 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-pull-1] About to syncTriggers because new configuration came through the data loader 2014-07-16 15:27:07,761 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Synchronizing triggers 2014-07-16 15:27:07,876 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:27:07,888 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:27:07,892 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_return_line_item' in the datasource that is configured 2014-07-16 15:27:07,895 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_tender_line_item' in the datasource that is configured 2014-07-16 15:27:07,906 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Done synchronizing triggers 2014-07-16 15:27:07,916 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 2 rows and 2 batches were processed 2014-07-16 15:27:07,917 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:27:07,937 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="name" type="VARCHAR" size="100"> <platform-column name="mssql2008" type="varchar" size="100"/> </column> </table> </database> 2014-07-16 15:27:07,941 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Tables up to date. No alters found for item 2014-07-16 15:27:07,959 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 3 rows and 3 batches were processed 2014-07-16 15:27:07,959 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:27:07,980 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item_selling_price"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="store_id" primaryKey="true" required="true" type="VARCHAR" size="5"> <platform-column name="mssql2008" type="varchar" size="5"/> </column> <column name="price" required="true" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <column name="cost" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <foreign-key name="fk_price_item_id" foreignTable="item"> <reference local="item_id" foreign="item_id"/> </foreign-key> </table> </database> 2014-07-16 15:27:07,986 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Tables up to date. No alters found for item_selling_price 2014-07-16 15:27:08,005 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 4 rows and 4 batches were processed 2014-07-16 15:27:08,006 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:27:08,037 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 4 rows and 4 batches were processed 2014-07-16 15:27:08,127 INFO [store-001] [RouterService] [store-001-job-12] Routed 1 data events in 16 ms 2014-07-16 15:28:37,770 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 1 rows and 1 batches were processed 2014-07-16 15:28:37,771 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:28:37,798 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-pull-1] About to syncTriggers because new configuration came through the data loader 2014-07-16 15:28:37,798 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Synchronizing triggers 2014-07-16 15:28:37,983 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:28:37,995 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:28:37,999 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_return_line_item' in the datasource that is configured 2014-07-16 15:28:38,003 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_tender_line_item' in the datasource that is configured 2014-07-16 15:28:38,012 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Done synchronizing triggers 2014-07-16 15:28:38,021 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 2 rows and 2 batches were processed 2014-07-16 15:28:38,022 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:28:38,041 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="name" type="VARCHAR" size="100"> <platform-column name="mssql2008" type="varchar" size="100"/> </column> </table> </database> 2014-07-16 15:28:38,045 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Tables up to date. No alters found for item 2014-07-16 15:28:38,064 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 3 rows and 3 batches were processed 2014-07-16 15:28:38,064 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:28:38,085 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item_selling_price"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="store_id" primaryKey="true" required="true" type="VARCHAR" size="5"> <platform-column name="mssql2008" type="varchar" size="5"/> </column> <column name="price" required="true" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <column name="cost" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <foreign-key name="fk_price_item_id" foreignTable="item"> <reference local="item_id" foreign="item_id"/> </foreign-key> </table> </database> 2014-07-16 15:28:38,090 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Tables up to date. No alters found for item_selling_price 2014-07-16 15:28:38,107 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 4 rows and 4 batches were processed 2014-07-16 15:28:38,108 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:28:38,130 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 4 rows and 4 batches were processed 2014-07-16 15:28:38,332 INFO [store-001] [RouterService] [store-001-job-7] Routed 1 data events in 18 ms 2014-07-16 15:30:29,325 INFO [] [AbstractCommandLauncher] [main] Option: name=engine, value={store-001} 2014-07-16 15:30:29,326 INFO [] [AbstractCommandLauncher] [main] Option: name=format, value={XML} 2014-07-16 15:31:05,455 INFO [] [AbstractCommandLauncher] [main] Option: name=engine, value={store-001} 2014-07-16 15:31:05,456 INFO [] [AbstractCommandLauncher] [main] Option: name=format, value={XML} 2014-07-16 15:31:05,616 INFO [] [JdbcDatabasePlatformFactory] [main] Detected database 'Microsoft SQL Server', version '10', protocol 'jtds' 2014-07-16 15:31:05,755 WARN [] [AbstractDatabaseWriter] [main] Did not find the item table in the target database 2014-07-16 15:31:05,761 INFO [] [DefaultDatabaseWriter] [main] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dbimport"> <table name="item"> <column name="item_id" primaryKey="true" required="true" type="INTEGER"/> <column name="name" type="VARCHAR" size="100"/> </table> </database> 2014-07-16 15:31:05,769 WARN [] [AbstractDatabaseWriter] [main] Did not find the item_selling_price table in the target database 2014-07-16 15:31:05,771 INFO [] [DefaultDatabaseWriter] [main] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dbimport"> <table name="item_selling_price"> <column name="item_id" primaryKey="true" required="true" type="INTEGER"/> <column name="store_id" primaryKey="true" required="true" type="VARCHAR" size="5"/> <column name="price" required="true" type="DECIMAL" size="10,2"/> <column name="cost" type="DECIMAL" size="10,2"/> <foreign-key name="fk_price_item_id" foreignTable="item"> <reference local="item_id" foreign="item_id"/> </foreign-key> </table> </database> 2014-07-16 15:31:05,778 WARN [] [AbstractDatabaseWriter] [main] Did not find the sale_transaction table in the target database 2014-07-16 15:31:05,781 INFO [] [DefaultDatabaseWriter] [main] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dbimport"> <table name="sale_transaction"> <column name="tran_id" primaryKey="true" required="true" type="INTEGER"/> <column name="store_id" required="true" type="VARCHAR" size="5"/> <column name="workstation" required="true" type="VARCHAR" size="3"/> <column name="day" required="true" type="VARCHAR" size="10"/> <column name="seq" required="true" type="INTEGER"/> </table> </database> 2014-07-16 15:31:05,785 WARN [] [AbstractDatabaseWriter] [main] Did not find the sale_return_line_item table in the target database 2014-07-16 15:31:05,788 INFO [] [DefaultDatabaseWriter] [main] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dbimport"> <table name="sale_return_line_item"> <column name="tran_id" primaryKey="true" required="true" type="INTEGER"/> <column name="item_id" required="true" type="INTEGER"/> <column name="price" required="true" type="DECIMAL" size="10,2"/> <column name="quantity" required="true" type="INTEGER"/> <column name="returned_quantity" type="INTEGER"/> <foreign-key name="fk_srli_tran_id" foreignTable="sale_transaction"> <reference local="tran_id" foreign="tran_id"/> </foreign-key> <foreign-key name="fk_srli_item_id" foreignTable="item"> <reference local="item_id" foreign="item_id"/> </foreign-key> </table> </database> 2014-07-16 15:43:10,322 INFO [startup] [AbstractCommandLauncher] [main] Option: name=engine, value={store-001} 2014-07-16 15:43:10,322 INFO [startup] [AbstractCommandLauncher] [main] Option: name=port, value={9090} 2014-07-16 15:43:10,420 INFO [startup] [SymmetricWebServer] [main] About to start SymmetricDS web server on host:port default:9090 2014-07-16 15:43:11,522 INFO [startup] [/] [main] Initializing Spring root WebApplicationContext 2014-07-16 15:43:12,055 INFO [store-001] [JdbcDatabasePlatformFactory] [symmetric-startup] Detected database 'Microsoft SQL Server', version '10', protocol 'jtds' 2014-07-16 15:43:12,094 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] The DbDialect being used is org.jumpmind.symmetric.db.mssql.MsSqlSymmetricDialect 2014-07-16 15:43:12,100 INFO [store-001] [StagingManager] [symmetric-startup] The staging directory was initialized at the following location: C:\Users\user.name\symmetricds\sym-store-fix\symmetric-3.6.3-SNAPSHOT\tmp\store-001 2014-07-16 15:43:12,131 INFO [store-001] [ClusterService] [symmetric-startup] This node picked a server id of T005583.eu.Micros.int 2014-07-16 15:43:12,309 INFO [store-001] [ExtensionPointManager] [symmetric-startup] Found 8 extension points that will be registered 2014-07-16 15:43:12,329 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] Initializing SymmetricDS database 2014-07-16 15:43:12,329 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Checking if SymmetricDS tables need created or altered 2014-07-16 15:43:12,398 INFO [startup] [/] [main] Initializing Spring FrameworkServlet 'rest' 2014-07-16 15:43:12,491 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] There are SymmetricDS tables that needed altered 2014-07-16 15:43:12,507 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,507 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,512 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_channel"( "channel_id" VARCHAR(128) NOT NULL, "processing_order" INT DEFAULT 1 NOT NULL, "max_batch_size" INT DEFAULT 1000 NOT NULL, "max_batch_to_send" INT DEFAULT 60 NOT NULL, "max_data_to_route" INT DEFAULT 100000 NOT NULL, "extract_period_millis" INT DEFAULT 0 NOT NULL, "enabled" SMALLINT DEFAULT 1 NOT NULL, "use_old_data_to_route" SMALLINT DEFAULT 1 NOT NULL, "use_row_data_to_route" SMALLINT DEFAULT 1 NOT NULL, "use_pk_data_to_route" SMALLINT DEFAULT 1 NOT NULL, "reload_flag" SMALLINT DEFAULT 0 NOT NULL, "file_sync_flag" SMALLINT DEFAULT 0 NOT NULL, "contains_big_lob" SMALLINT DEFAULT 0 NOT NULL, "batch_algorithm" VARCHAR(50) DEFAULT 'default' NOT NULL, "data_loader_type" VARCHAR(50) DEFAULT 'default' NOT NULL, "description" VARCHAR(255), "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("channel_id") ) 2014-07-16 15:43:12,513 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,515 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_conflict"( "conflict_id" VARCHAR(50) NOT NULL, "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "target_channel_id" VARCHAR(128), "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255), "detect_type" VARCHAR(128) NOT NULL, "detect_expression" TEXT, "resolve_type" VARCHAR(128) NOT NULL, "ping_back" VARCHAR(128) NOT NULL, "resolve_changes_only" SMALLINT DEFAULT 0, "resolve_row_only" SMALLINT DEFAULT 0, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("conflict_id") ) 2014-07-16 15:43:12,516 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,517 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_data"( "data_id" BIGINT NOT NULL IDENTITY (1,1) , "table_name" VARCHAR(255) NOT NULL, "event_type" CHAR(1) NOT NULL, "row_data" TEXT, "pk_data" TEXT, "old_data" TEXT, "trigger_hist_id" INT NOT NULL, "channel_id" VARCHAR(128), "transaction_id" VARCHAR(255), "source_node_id" VARCHAR(50), "external_data" VARCHAR(50), "node_list" VARCHAR(255), "create_time" DATETIME, PRIMARY KEY ("data_id") ) 2014-07-16 15:43:12,518 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_d_channel_id" ON "sym_data" ("data_id", "channel_id") 2014-07-16 15:43:12,518 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,519 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_data_event"( "data_id" BIGINT NOT NULL, "batch_id" BIGINT NOT NULL, "router_id" VARCHAR(50) NOT NULL, "create_time" DATETIME, PRIMARY KEY ("data_id", "batch_id", "router_id") ) 2014-07-16 15:43:12,536 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_de_batchid" ON "sym_data_event" ("batch_id") 2014-07-16 15:43:12,536 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,537 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_data_gap"( "start_id" BIGINT NOT NULL, "end_id" BIGINT NOT NULL, "status" CHAR(2), "create_time" DATETIME NOT NULL, "last_update_hostname" VARCHAR(255), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("start_id", "end_id") ) 2014-07-16 15:43:12,538 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_dg_status" ON "sym_data_gap" ("status") 2014-07-16 15:43:12,538 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,539 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_extract_request"( "request_id" BIGINT NOT NULL, "node_id" VARCHAR(50) NOT NULL, "status" CHAR(2), "start_batch_id" BIGINT NOT NULL, "end_batch_id" BIGINT NOT NULL, "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "last_update_time" DATETIME, "create_time" DATETIME, PRIMARY KEY ("request_id") ) 2014-07-16 15:43:12,547 INFO [startup] [SymmetricWebServer] [main] Starting JMX HTTP console on port 9091 2014-07-16 15:43:12,548 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,549 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_file_incoming"( "relative_dir" VARCHAR(255) NOT NULL, "file_name" VARCHAR(128) NOT NULL, "last_event_type" CHAR(1) NOT NULL, "node_id" VARCHAR(50) NOT NULL, "file_modified_time" BIGINT, PRIMARY KEY ("relative_dir", "file_name") ) 2014-07-16 15:43:12,556 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,558 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_file_snapshot"( "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "relative_dir" VARCHAR(255) NOT NULL, "file_name" VARCHAR(128) NOT NULL, "channel_id" VARCHAR(128) DEFAULT 'filesync' NOT NULL, "reload_channel_id" VARCHAR(128) DEFAULT 'filesync_reload' NOT NULL, "last_event_type" CHAR(1) NOT NULL, "crc32_checksum" BIGINT, "file_size" BIGINT, "file_modified_time" BIGINT, "last_update_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "create_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id", "router_id", "relative_dir", "file_name") ) 2014-07-16 15:43:12,562 INFO [startup] [SymmetricWebServer] [main] Joining the web server main thread 2014-07-16 15:43:12,581 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_f_snpsht_chid" ON "sym_file_snapshot" ("reload_channel_id") 2014-07-16 15:43:12,581 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,583 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_file_trigger"( "trigger_id" VARCHAR(128) NOT NULL, "channel_id" VARCHAR(128) DEFAULT 'filesync' NOT NULL, "reload_channel_id" VARCHAR(128) DEFAULT 'filesync_reload' NOT NULL, "base_dir" VARCHAR(255) NOT NULL, "recurse" SMALLINT DEFAULT 1 NOT NULL, "includes_files" VARCHAR(255), "excludes_files" VARCHAR(255), "sync_on_create" SMALLINT DEFAULT 1 NOT NULL, "sync_on_modified" SMALLINT DEFAULT 1 NOT NULL, "sync_on_delete" SMALLINT DEFAULT 1 NOT NULL, "sync_on_ctl_file" SMALLINT DEFAULT 0 NOT NULL, "delete_after_sync" SMALLINT DEFAULT 0 NOT NULL, "before_copy_script" TEXT, "after_copy_script" TEXT, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id") ) 2014-07-16 15:43:12,591 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,592 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_file_trigger_router"( "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "enabled" SMALLINT DEFAULT 1 NOT NULL, "initial_load_enabled" SMALLINT DEFAULT 1 NOT NULL, "target_base_dir" VARCHAR(255), "conflict_strategy" VARCHAR(128) DEFAULT 'source_wins' NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id", "router_id") ) 2014-07-16 15:43:12,596 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,597 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_grouplet"( "grouplet_id" VARCHAR(50) NOT NULL, "grouplet_link_policy" CHAR(1) DEFAULT 'I' NOT NULL, "description" VARCHAR(255), "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("grouplet_id") ) 2014-07-16 15:43:12,600 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,601 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_grouplet_link"( "grouplet_id" VARCHAR(50) NOT NULL, "external_id" VARCHAR(50) NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("grouplet_id", "external_id") ) 2014-07-16 15:43:12,604 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,608 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_incoming_batch"( "batch_id" BIGINT NOT NULL, "node_id" VARCHAR(50) NOT NULL, "channel_id" VARCHAR(128), "status" CHAR(2), "error_flag" SMALLINT DEFAULT 0, "network_millis" BIGINT DEFAULT 0 NOT NULL, "filter_millis" BIGINT DEFAULT 0 NOT NULL, "database_millis" BIGINT DEFAULT 0 NOT NULL, "failed_row_number" BIGINT DEFAULT 0 NOT NULL, "failed_line_number" BIGINT DEFAULT 0 NOT NULL, "byte_count" BIGINT DEFAULT 0 NOT NULL, "statement_count" BIGINT DEFAULT 0 NOT NULL, "fallback_insert_count" BIGINT DEFAULT 0 NOT NULL, "fallback_update_count" BIGINT DEFAULT 0 NOT NULL, "ignore_count" BIGINT DEFAULT 0 NOT NULL, "missing_delete_count" BIGINT DEFAULT 0 NOT NULL, "skip_count" BIGINT DEFAULT 0 NOT NULL, "sql_state" VARCHAR(10), "sql_code" INT DEFAULT 0 NOT NULL, "sql_message" TEXT, "last_update_hostname" VARCHAR(255), "last_update_time" DATETIME, "create_time" DATETIME, PRIMARY KEY ("batch_id", "node_id") ) 2014-07-16 15:43:12,614 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ib_time_status" ON "sym_incoming_batch" ("create_time", "status") 2014-07-16 15:43:12,615 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ib_in_error" ON "sym_incoming_batch" ("error_flag") 2014-07-16 15:43:12,615 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,617 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_incoming_error"( "batch_id" BIGINT NOT NULL, "node_id" VARCHAR(50) NOT NULL, "failed_row_number" BIGINT NOT NULL, "failed_line_number" BIGINT DEFAULT 0 NOT NULL, "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255) NOT NULL, "event_type" CHAR(1) NOT NULL, "binary_encoding" VARCHAR(10) DEFAULT 'HEX' NOT NULL, "column_names" TEXT NOT NULL, "pk_column_names" TEXT NOT NULL, "row_data" TEXT, "old_data" TEXT, "cur_data" TEXT, "resolve_data" TEXT, "resolve_ignore" SMALLINT DEFAULT 0, "conflict_id" VARCHAR(50), "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("batch_id", "node_id", "failed_row_number") ) 2014-07-16 15:43:12,623 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,625 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_load_filter"( "load_filter_id" VARCHAR(50) NOT NULL, "load_filter_type" VARCHAR(10) NOT NULL, "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255), "filter_on_update" SMALLINT DEFAULT 1 NOT NULL, "filter_on_insert" SMALLINT DEFAULT 1 NOT NULL, "filter_on_delete" SMALLINT DEFAULT 1 NOT NULL, "before_write_script" TEXT, "after_write_script" TEXT, "batch_complete_script" TEXT, "batch_commit_script" TEXT, "batch_rollback_script" TEXT, "handle_error_script" TEXT, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, "load_filter_order" INT DEFAULT 1 NOT NULL, "fail_on_error" SMALLINT DEFAULT 0 NOT NULL, PRIMARY KEY ("load_filter_id") ) 2014-07-16 15:43:12,633 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,639 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_lock"( "lock_action" VARCHAR(50) NOT NULL, "lock_type" VARCHAR(50) NOT NULL, "locking_server_id" VARCHAR(255), "lock_time" DATETIME, "shared_count" INT DEFAULT 0 NOT NULL, "shared_enable" INT DEFAULT 0 NOT NULL, "last_lock_time" DATETIME, "last_locking_server_id" VARCHAR(255), PRIMARY KEY ("lock_action") ) 2014-07-16 15:43:12,640 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,643 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node"( "node_id" VARCHAR(50) NOT NULL, "node_group_id" VARCHAR(50) NOT NULL, "external_id" VARCHAR(50) NOT NULL, "sync_enabled" SMALLINT DEFAULT 0, "sync_url" VARCHAR(255), "schema_version" VARCHAR(50), "symmetric_version" VARCHAR(50), "database_type" VARCHAR(50), "database_version" VARCHAR(50), "heartbeat_time" DATETIME, "timezone_offset" VARCHAR(6), "batch_to_send_count" INT DEFAULT 0, "batch_in_error_count" INT DEFAULT 0, "created_at_node_id" VARCHAR(50), "deployment_type" VARCHAR(50), PRIMARY KEY ("node_id") ) 2014-07-16 15:43:12,647 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,649 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_communication"( "node_id" VARCHAR(50) NOT NULL, "communication_type" VARCHAR(10) NOT NULL, "lock_time" DATETIME, "locking_server_id" VARCHAR(255), "last_lock_time" DATETIME, "last_lock_millis" BIGINT DEFAULT 0, "success_count" BIGINT DEFAULT 0, "fail_count" BIGINT DEFAULT 0, "total_success_count" BIGINT DEFAULT 0, "total_fail_count" BIGINT DEFAULT 0, "total_success_millis" BIGINT DEFAULT 0, "total_fail_millis" BIGINT DEFAULT 0, PRIMARY KEY ("node_id", "communication_type") ) 2014-07-16 15:43:12,652 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,657 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_channel_ctl"( "node_id" VARCHAR(50) NOT NULL, "channel_id" VARCHAR(128) NOT NULL, "suspend_enabled" SMALLINT DEFAULT 0, "ignore_enabled" SMALLINT DEFAULT 0, "last_extract_time" DATETIME, PRIMARY KEY ("node_id", "channel_id") ) 2014-07-16 15:43:12,657 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,658 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_group"( "node_group_id" VARCHAR(50) NOT NULL, "description" VARCHAR(255), "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("node_group_id") ) 2014-07-16 15:43:12,661 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,662 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_group_channel_wnd"( "node_group_id" VARCHAR(50) NOT NULL, "channel_id" VARCHAR(128) NOT NULL, "start_time" DATETIME NOT NULL, "end_time" DATETIME NOT NULL, "enabled" SMALLINT DEFAULT 0 NOT NULL, PRIMARY KEY ("node_group_id", "channel_id", "start_time", "end_time") ) 2014-07-16 15:43:12,666 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,667 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_group_link"( "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "data_event_action" CHAR(1) DEFAULT 'W' NOT NULL, "sync_config_enabled" SMALLINT DEFAULT 1 NOT NULL, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("source_node_group_id", "target_node_group_id") ) 2014-07-16 15:43:12,670 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,672 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_host"( "node_id" VARCHAR(50) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "ip_address" VARCHAR(50), "os_user" VARCHAR(50), "os_name" VARCHAR(50), "os_arch" VARCHAR(50), "os_version" VARCHAR(50), "available_processors" INT DEFAULT 0, "free_memory_bytes" BIGINT DEFAULT 0, "total_memory_bytes" BIGINT DEFAULT 0, "max_memory_bytes" BIGINT DEFAULT 0, "java_version" VARCHAR(50), "java_vendor" VARCHAR(255), "jdbc_version" VARCHAR(255), "symmetric_version" VARCHAR(50), "timezone_offset" VARCHAR(6), "heartbeat_time" DATETIME, "last_restart_time" DATETIME NOT NULL, "create_time" DATETIME NOT NULL, PRIMARY KEY ("node_id", "host_name") ) 2014-07-16 15:43:12,679 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,682 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_host_channel_stats"( "node_id" VARCHAR(50) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "channel_id" VARCHAR(128) NOT NULL, "start_time" DATETIME NOT NULL, "end_time" DATETIME NOT NULL, "data_routed" BIGINT DEFAULT 0, "data_unrouted" BIGINT DEFAULT 0, "data_event_inserted" BIGINT DEFAULT 0, "data_extracted" BIGINT DEFAULT 0, "data_bytes_extracted" BIGINT DEFAULT 0, "data_extracted_errors" BIGINT DEFAULT 0, "data_bytes_sent" BIGINT DEFAULT 0, "data_sent" BIGINT DEFAULT 0, "data_sent_errors" BIGINT DEFAULT 0, "data_loaded" BIGINT DEFAULT 0, "data_bytes_loaded" BIGINT DEFAULT 0, "data_loaded_errors" BIGINT DEFAULT 0, PRIMARY KEY ("node_id", "host_name", "channel_id", "start_time", "end_time") ) 2014-07-16 15:43:12,688 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_nd_hst_chnl_sts" ON "sym_node_host_channel_stats" ("node_id", "start_time", "end_time") 2014-07-16 15:43:12,689 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,690 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_host_job_stats"( "node_id" VARCHAR(50) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "job_name" VARCHAR(50) NOT NULL, "start_time" DATETIME NOT NULL, "end_time" DATETIME NOT NULL, "processed_count" BIGINT DEFAULT 0, PRIMARY KEY ("node_id", "host_name", "job_name", "start_time", "end_time") ) 2014-07-16 15:43:12,693 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_nd_hst_job" ON "sym_node_host_job_stats" ("node_id", "start_time", "end_time") 2014-07-16 15:43:12,694 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,703 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_host_stats"( "node_id" VARCHAR(50) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "start_time" DATETIME NOT NULL, "end_time" DATETIME NOT NULL, "restarted" BIGINT DEFAULT 0 NOT NULL, "nodes_pulled" BIGINT DEFAULT 0, "total_nodes_pull_time" BIGINT DEFAULT 0, "nodes_pushed" BIGINT DEFAULT 0, "total_nodes_push_time" BIGINT DEFAULT 0, "nodes_rejected" BIGINT DEFAULT 0, "nodes_registered" BIGINT DEFAULT 0, "nodes_loaded" BIGINT DEFAULT 0, "nodes_disabled" BIGINT DEFAULT 0, "purged_data_rows" BIGINT DEFAULT 0, "purged_data_event_rows" BIGINT DEFAULT 0, "purged_batch_outgoing_rows" BIGINT DEFAULT 0, "purged_batch_incoming_rows" BIGINT DEFAULT 0, "triggers_created_count" BIGINT, "triggers_rebuilt_count" BIGINT, "triggers_removed_count" BIGINT, PRIMARY KEY ("node_id", "host_name", "start_time", "end_time") ) 2014-07-16 15:43:12,707 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_nd_hst_sts" ON "sym_node_host_stats" ("node_id", "start_time", "end_time") 2014-07-16 15:43:12,707 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,708 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_identity"( "node_id" VARCHAR(50) NOT NULL, PRIMARY KEY ("node_id") ) 2014-07-16 15:43:12,709 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,710 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_node_security"( "node_id" VARCHAR(50) NOT NULL, "node_password" VARCHAR(50) NOT NULL, "registration_enabled" SMALLINT DEFAULT 0, "registration_time" DATETIME, "initial_load_enabled" SMALLINT DEFAULT 0, "initial_load_time" DATETIME, "initial_load_id" BIGINT, "initial_load_create_by" VARCHAR(255), "rev_initial_load_enabled" SMALLINT DEFAULT 0, "rev_initial_load_time" DATETIME, "rev_initial_load_id" BIGINT, "rev_initial_load_create_by" VARCHAR(255), "created_at_node_id" VARCHAR(50) NOT NULL, PRIMARY KEY ("node_id") ) 2014-07-16 15:43:12,716 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,721 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_outgoing_batch"( "batch_id" BIGINT NOT NULL, "node_id" VARCHAR(50) NOT NULL, "channel_id" VARCHAR(128), "status" CHAR(2), "load_id" BIGINT, "extract_job_flag" SMALLINT DEFAULT 0, "load_flag" SMALLINT DEFAULT 0, "error_flag" SMALLINT DEFAULT 0, "common_flag" SMALLINT DEFAULT 0, "ignore_count" BIGINT DEFAULT 0 NOT NULL, "byte_count" BIGINT DEFAULT 0 NOT NULL, "extract_count" BIGINT DEFAULT 0 NOT NULL, "sent_count" BIGINT DEFAULT 0 NOT NULL, "load_count" BIGINT DEFAULT 0 NOT NULL, "data_event_count" BIGINT DEFAULT 0 NOT NULL, "reload_event_count" BIGINT DEFAULT 0 NOT NULL, "insert_event_count" BIGINT DEFAULT 0 NOT NULL, "update_event_count" BIGINT DEFAULT 0 NOT NULL, "delete_event_count" BIGINT DEFAULT 0 NOT NULL, "other_event_count" BIGINT DEFAULT 0 NOT NULL, "router_millis" BIGINT DEFAULT 0 NOT NULL, "network_millis" BIGINT DEFAULT 0 NOT NULL, "filter_millis" BIGINT DEFAULT 0 NOT NULL, "load_millis" BIGINT DEFAULT 0 NOT NULL, "extract_millis" BIGINT DEFAULT 0 NOT NULL, "sql_state" VARCHAR(10), "sql_code" INT DEFAULT 0 NOT NULL, "sql_message" TEXT, "failed_data_id" BIGINT DEFAULT 0 NOT NULL, "failed_line_number" BIGINT DEFAULT 0 NOT NULL, "last_update_hostname" VARCHAR(255), "last_update_time" DATETIME, "create_time" DATETIME, "create_by" VARCHAR(255), PRIMARY KEY ("batch_id", "node_id") ) 2014-07-16 15:43:12,730 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ob_node_status" ON "sym_outgoing_batch" ("node_id", "status") 2014-07-16 15:43:12,730 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ob_status" ON "sym_outgoing_batch" ("status") 2014-07-16 15:43:12,731 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_ob_in_error" ON "sym_outgoing_batch" ("error_flag") 2014-07-16 15:43:12,731 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,735 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_parameter"( "external_id" VARCHAR(50) NOT NULL, "node_group_id" VARCHAR(50) NOT NULL, "param_key" VARCHAR(80) NOT NULL, "param_value" TEXT, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("external_id", "node_group_id", "param_key") ) 2014-07-16 15:43:12,736 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,739 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_registration_redirect"( "registrant_external_id" VARCHAR(50) NOT NULL, "registration_node_id" VARCHAR(50) NOT NULL, PRIMARY KEY ("registrant_external_id") ) 2014-07-16 15:43:12,739 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,740 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_registration_request"( "node_group_id" VARCHAR(50) NOT NULL, "external_id" VARCHAR(50) NOT NULL, "status" CHAR(2) NOT NULL, "host_name" VARCHAR(60) NOT NULL, "ip_address" VARCHAR(50) NOT NULL, "attempt_count" INT DEFAULT 0, "registered_node_id" VARCHAR(50), "error_message" TEXT, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("node_group_id", "external_id", "create_time") ) 2014-07-16 15:43:12,744 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_reg_req_1" ON "sym_registration_request" ("node_group_id", "external_id", "status", "host_name", "ip_address") 2014-07-16 15:43:12,748 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE INDEX "sym_idx_reg_req_2" ON "sym_registration_request" ("status") 2014-07-16 15:43:12,748 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,750 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_router"( "router_id" VARCHAR(50) NOT NULL, "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255), "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "router_type" VARCHAR(50), "router_expression" TEXT, "sync_on_update" SMALLINT DEFAULT 1 NOT NULL, "sync_on_insert" SMALLINT DEFAULT 1 NOT NULL, "sync_on_delete" SMALLINT DEFAULT 1 NOT NULL, "use_source_catalog_schema" SMALLINT DEFAULT 1 NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("router_id") ) 2014-07-16 15:43:12,757 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,775 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_sequence"( "sequence_name" VARCHAR(50) NOT NULL, "current_value" BIGINT DEFAULT 0 NOT NULL, "increment_by" INT DEFAULT 1 NOT NULL, "min_value" BIGINT DEFAULT 1 NOT NULL, "max_value" BIGINT DEFAULT 9999999999 NOT NULL, "cycle" SMALLINT DEFAULT 0, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("sequence_name") ) 2014-07-16 15:43:12,776 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,777 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_table_reload_request"( "target_node_id" VARCHAR(50) NOT NULL, "source_node_id" VARCHAR(50) NOT NULL, "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "reload_select" TEXT, "reload_delete_stmt" TEXT, "reload_enabled" SMALLINT DEFAULT 0, "reload_time" DATETIME, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("target_node_id", "source_node_id", "trigger_id", "router_id") ) 2014-07-16 15:43:12,778 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,780 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_transform_table"( "transform_id" VARCHAR(50) NOT NULL, "source_node_group_id" VARCHAR(50) NOT NULL, "target_node_group_id" VARCHAR(50) NOT NULL, "transform_point" VARCHAR(10) NOT NULL, "source_catalog_name" VARCHAR(255), "source_schema_name" VARCHAR(255), "source_table_name" VARCHAR(255) NOT NULL, "target_catalog_name" VARCHAR(255), "target_schema_name" VARCHAR(255), "target_table_name" VARCHAR(255), "update_first" SMALLINT DEFAULT 0, "delete_action" VARCHAR(10) NOT NULL, "transform_order" INT DEFAULT 1 NOT NULL, "column_policy" VARCHAR(10) DEFAULT 'SPECIFIED' NOT NULL, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("transform_id", "source_node_group_id", "target_node_group_id") ) 2014-07-16 15:43:12,781 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,782 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_transform_column"( "transform_id" VARCHAR(50) NOT NULL, "include_on" CHAR(1) DEFAULT '*' NOT NULL, "target_column_name" VARCHAR(128) NOT NULL, "source_column_name" VARCHAR(128), "pk" SMALLINT DEFAULT 0, "transform_type" VARCHAR(50) DEFAULT 'copy', "transform_expression" TEXT, "transform_order" INT DEFAULT 1 NOT NULL, "create_time" DATETIME, "last_update_by" VARCHAR(50), "last_update_time" DATETIME, PRIMARY KEY ("transform_id", "include_on", "target_column_name") ) 2014-07-16 15:43:12,783 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,785 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_trigger"( "trigger_id" VARCHAR(128) NOT NULL, "source_catalog_name" VARCHAR(255), "source_schema_name" VARCHAR(255), "source_table_name" VARCHAR(255) NOT NULL, "channel_id" VARCHAR(128) NOT NULL, "reload_channel_id" VARCHAR(128) DEFAULT 'reload' NOT NULL, "sync_on_update" SMALLINT DEFAULT 1 NOT NULL, "sync_on_insert" SMALLINT DEFAULT 1 NOT NULL, "sync_on_delete" SMALLINT DEFAULT 1 NOT NULL, "sync_on_incoming_batch" SMALLINT DEFAULT 0 NOT NULL, "name_for_update_trigger" VARCHAR(255), "name_for_insert_trigger" VARCHAR(255), "name_for_delete_trigger" VARCHAR(255), "sync_on_update_condition" TEXT, "sync_on_insert_condition" TEXT, "sync_on_delete_condition" TEXT, "custom_on_update_text" TEXT, "custom_on_insert_text" TEXT, "custom_on_delete_text" TEXT, "external_select" TEXT, "tx_id_expression" TEXT, "channel_expression" TEXT, "excluded_column_names" TEXT, "sync_key_names" TEXT, "use_stream_lobs" SMALLINT DEFAULT 0 NOT NULL, "use_capture_lobs" SMALLINT DEFAULT 0 NOT NULL, "use_capture_old_data" SMALLINT DEFAULT 1 NOT NULL, "use_handle_key_updates" SMALLINT DEFAULT 0 NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id") ) 2014-07-16 15:43:12,794 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,796 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_trigger_hist"( "trigger_hist_id" INT NOT NULL, "trigger_id" VARCHAR(128) NOT NULL, "source_table_name" VARCHAR(255) NOT NULL, "source_catalog_name" VARCHAR(255), "source_schema_name" VARCHAR(255), "name_for_update_trigger" VARCHAR(255), "name_for_insert_trigger" VARCHAR(255), "name_for_delete_trigger" VARCHAR(255), "table_hash" BIGINT DEFAULT 0 NOT NULL, "trigger_row_hash" BIGINT DEFAULT 0 NOT NULL, "trigger_template_hash" BIGINT DEFAULT 0 NOT NULL, "column_names" TEXT NOT NULL, "pk_column_names" TEXT NOT NULL, "last_trigger_build_reason" CHAR(1) NOT NULL, "error_message" TEXT, "create_time" DATETIME NOT NULL, "inactive_time" DATETIME, PRIMARY KEY ("trigger_hist_id") ) 2014-07-16 15:43:12,803 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,804 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_trigger_router"( "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "enabled" SMALLINT DEFAULT 1 NOT NULL, "initial_load_order" INT DEFAULT 1 NOT NULL, "initial_load_select" TEXT, "initial_load_delete_stmt" TEXT, "initial_load_batch_count" INT DEFAULT 1, "ping_back_enabled" SMALLINT DEFAULT 0 NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("trigger_id", "router_id") ) 2014-07-16 15:43:12,808 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: SET quoted_identifier on 2014-07-16 15:43:12,808 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: CREATE TABLE "sym_trigger_router_grouplet"( "grouplet_id" VARCHAR(50) NOT NULL, "trigger_id" VARCHAR(128) NOT NULL, "router_id" VARCHAR(50) NOT NULL, "applies_when" CHAR(1) NOT NULL, "create_time" DATETIME NOT NULL, "last_update_by" VARCHAR(50), "last_update_time" DATETIME NOT NULL, PRIMARY KEY ("grouplet_id", "trigger_id", "router_id", "applies_when") ) 2014-07-16 15:43:12,814 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_conflict" ADD CONSTRAINT "sym_fk_cf_2_grp_lnk" FOREIGN KEY ("source_node_group_id", "target_node_group_id") REFERENCES "sym_node_group_link" ("source_node_group_id", "target_node_group_id") 2014-07-16 15:43:12,817 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_file_trigger_router" ADD CONSTRAINT "sym_fk_ftr_2_ftrg" FOREIGN KEY ("trigger_id") REFERENCES "sym_file_trigger" ("trigger_id") 2014-07-16 15:43:12,818 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_file_trigger_router" ADD CONSTRAINT "sym_fk_ftr_2_rtr" FOREIGN KEY ("router_id") REFERENCES "sym_router" ("router_id") 2014-07-16 15:43:12,819 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_grouplet_link" ADD CONSTRAINT "sym_fk_gpltlnk_2_gplt" FOREIGN KEY ("grouplet_id") REFERENCES "sym_grouplet" ("grouplet_id") 2014-07-16 15:43:12,822 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_node_group_link" ADD CONSTRAINT "sym_fk_lnk_2_grp_src" FOREIGN KEY ("source_node_group_id") REFERENCES "sym_node_group" ("node_group_id") 2014-07-16 15:43:12,823 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_node_group_link" ADD CONSTRAINT "sym_fk_lnk_2_grp_tgt" FOREIGN KEY ("target_node_group_id") REFERENCES "sym_node_group" ("node_group_id") 2014-07-16 15:43:12,823 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_node_identity" ADD CONSTRAINT "sym_fk_ident_2_node" FOREIGN KEY ("node_id") REFERENCES "sym_node" ("node_id") 2014-07-16 15:43:12,827 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_node_security" ADD CONSTRAINT "sym_fk_sec_2_node" FOREIGN KEY ("node_id") REFERENCES "sym_node" ("node_id") 2014-07-16 15:43:12,828 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_router" ADD CONSTRAINT "sym_fk_rt_2_grp_lnk" FOREIGN KEY ("source_node_group_id", "target_node_group_id") REFERENCES "sym_node_group_link" ("source_node_group_id", "target_node_group_id") 2014-07-16 15:43:12,829 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_transform_table" ADD CONSTRAINT "sym_fk_tt_2_grp_lnk" FOREIGN KEY ("source_node_group_id", "target_node_group_id") REFERENCES "sym_node_group_link" ("source_node_group_id", "target_node_group_id") 2014-07-16 15:43:12,831 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger" ADD CONSTRAINT "sym_fk_trg_2_chnl" FOREIGN KEY ("channel_id") REFERENCES "sym_channel" ("channel_id") 2014-07-16 15:43:12,832 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger" ADD CONSTRAINT "sym_fk_trg_2_rld_chnl" FOREIGN KEY ("reload_channel_id") REFERENCES "sym_channel" ("channel_id") 2014-07-16 15:43:12,846 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger_router" ADD CONSTRAINT "sym_fk_tr_2_trg" FOREIGN KEY ("trigger_id") REFERENCES "sym_trigger" ("trigger_id") 2014-07-16 15:43:12,847 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger_router" ADD CONSTRAINT "sym_fk_tr_2_rtr" FOREIGN KEY ("router_id") REFERENCES "sym_router" ("router_id") 2014-07-16 15:43:12,848 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger_router_grouplet" ADD CONSTRAINT "sym_fk_trgplt_2_gplt" FOREIGN KEY ("grouplet_id") REFERENCES "sym_grouplet" ("grouplet_id") 2014-07-16 15:43:12,849 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] DDL applied: ALTER TABLE "sym_trigger_router_grouplet" ADD CONSTRAINT "sym_fk_trgplt_2_tr" FOREIGN KEY ("trigger_id", "router_id") REFERENCES "sym_trigger_router" ("trigger_id", "router_id") 2014-07-16 15:43:12,850 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Done with auto update of SymmetricDS tables 2014-07-16 15:43:12,861 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Updating indexes to prevent lock escalation 2014-07-16 15:43:12,909 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Just installed sym_base64_encode 2014-07-16 15:43:12,911 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Just installed sym_triggers_disabled 2014-07-16 15:43:12,913 INFO [store-001] [MsSqlSymmetricDialect] [symmetric-startup] Just installed sym_node_disabled 2014-07-16 15:43:12,916 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring config channel 2014-07-16 15:43:12,924 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring reload channel 2014-07-16 15:43:12,926 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring heartbeat channel 2014-07-16 15:43:12,927 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring default channel 2014-07-16 15:43:12,929 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring dynamic channel 2014-07-16 15:43:12,930 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring filesync channel 2014-07-16 15:43:12,931 INFO [store-001] [ConfigurationService] [symmetric-startup] Auto-configuring filesync_reload channel 2014-07-16 15:43:12,950 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] Done initializing SymmetricDS database 2014-07-16 15:43:13,163 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] Starting unregistered node [group=store, externalId=001] 2014-07-16 15:43:13,164 INFO [store-001] [RouterJob] [symmetric-startup] Starting job.routing on periodic schedule: every 5000ms with the first run at Wed Jul 16 15:43:20 CEST 2014 2014-07-16 15:43:13,166 INFO [store-001] [PushJob] [symmetric-startup] Starting job.push on periodic schedule: every 10000ms with the first run at Wed Jul 16 15:43:20 CEST 2014 2014-07-16 15:43:13,166 INFO [store-001] [PullJob] [symmetric-startup] Starting job.pull on periodic schedule: every 10000ms with the first run at Wed Jul 16 15:43:20 CEST 2014 2014-07-16 15:43:13,167 INFO [store-001] [OutgoingPurgeJob] [symmetric-startup] Starting job.purge.outgoing with cron expression: 0 0 0 * * * 2014-07-16 15:43:13,169 INFO [store-001] [IncomingPurgeJob] [symmetric-startup] Starting job.purge.incoming with cron expression: 0 0 0 * * * 2014-07-16 15:43:13,169 INFO [store-001] [DataGapPurgeJob] [symmetric-startup] Starting job.purge.datagaps with cron expression: 0 0 0 * * * 2014-07-16 15:43:13,170 INFO [store-001] [StatisticFlushJob] [symmetric-startup] Starting job.stat.flush with cron expression: 0 0/5 * * * * 2014-07-16 15:43:13,170 INFO [store-001] [SyncTriggersJob] [symmetric-startup] Starting job.synctriggers with cron expression: 0 0 0 * * * 2014-07-16 15:43:13,171 INFO [store-001] [HeartbeatJob] [symmetric-startup] Starting job.heartbeat on periodic schedule: every 900000ms with the first run at Wed Jul 16 15:43:20 CEST 2014 2014-07-16 15:43:13,171 INFO [store-001] [WatchdogJob] [symmetric-startup] Starting job.watchdog on periodic schedule: every 3600000ms with the first run at Wed Jul 16 15:43:20 CEST 2014 2014-07-16 15:43:13,171 INFO [store-001] [StageManagementJob] [symmetric-startup] Starting job.stage.management on periodic schedule: every 15000ms with the first run at Wed Jul 16 15:43:20 CEST 2014 2014-07-16 15:43:13,171 INFO [store-001] [JobManager] [symmetric-startup] Job job.refresh.cache not configured for auto start 2014-07-16 15:43:13,171 INFO [store-001] [FileSyncTrackerJob] [symmetric-startup] Starting job.file.sync.tracker with cron expression: 0 0/5 * * * * 2014-07-16 15:43:13,172 INFO [store-001] [FileSyncPullJob] [symmetric-startup] Starting job.file.sync.pull on periodic schedule: every 60000ms with the first run at Wed Jul 16 15:43:20 CEST 2014 2014-07-16 15:43:13,172 INFO [store-001] [FileSyncPushJob] [symmetric-startup] Starting job.file.sync.push on periodic schedule: every 60000ms with the first run at Wed Jul 16 15:43:20 CEST 2014 2014-07-16 15:43:13,172 INFO [store-001] [InitialLoadExtractorJob] [symmetric-startup] Starting job.initial.load.extract on periodic schedule: every 10000ms with the first run at Wed Jul 16 15:43:20 CEST 2014 2014-07-16 15:43:13,172 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] Started SymmetricDS 2014-07-16 15:43:13,172 INFO [store-001] [AbstractSymmetricEngine] [symmetric-startup] SymmetricDS: type=server, name=store-001, version=3.6.3-SNAPSHOT, groupId=store, externalId=001, databaseName=Microsoft SQL Server, databaseVersion=10.50, driverName=jTDS Type 4 JDBC Driver for MS SQL Server and Sybase, driverVersion=1.2.4 2014-07-16 15:43:20,533 INFO [store-001] [RouterJob] [store-001-job-13] Did not run the job.routing job because the engine is not registered. 2014-07-16 15:43:20,533 INFO [store-001] [PushJob] [store-001-job-1] Did not run the job.push job because the engine is not registered. 2014-07-16 15:43:20,537 INFO [store-001] [RegistrationService] [store-001-job-9] This node is unregistered. It will attempt to register using the registration.url 2014-07-16 15:43:20,538 INFO [store-001] [StageManagementJob] [store-001-job-13] Did not run the job.stage.management job because the engine is not registered. 2014-07-16 15:43:20,538 INFO [store-001] [FileSyncPullJob] [store-001-job-6] Did not run the job.file.sync.pull job because the engine is not registered. 2014-07-16 15:43:20,539 INFO [store-001] [FileSyncPushJob] [store-001-job-15] Did not run the job.file.sync.push job because the engine is not registered. 2014-07-16 15:43:20,539 INFO [store-001] [InitialLoadExtractorJob] [store-001-job-1] Did not run the job.initial.load.extract job because the engine is not registered. 2014-07-16 15:43:20,551 INFO [store-001] [DataLoaderService] [store-001-job-9] Using registration URL of http://localhost:7070/sync/corp-000/registration?nodeGroupId=store&externalId=001&syncURL=http%3A%2F%2FT005583.eu.Micros.int%3A31415%2Fsync%2Fstore-001&schemaVersion=%3F&databaseType=Microsoft+SQL+Server&databaseVersion=10.50&symmetricVersion=3.6.3-SNAPSHOT&hostName=T005583.eu.Micros.int&ipAddress=fe80%3A0%3A0%3A0%3A0%3A5efe%3Aa00%3Aa%2517 2014-07-16 15:43:20,691 WARN [store-001] [DataLoaderService] [store-001-job-9] Registration attempt failed. Registration was not open 2014-07-16 15:43:20,693 WARN [store-001] [RegistrationService] [store-001-job-9] Could not register. Sleeping before attempting again. 2014-07-16 15:43:20,693 INFO [store-001] [RegistrationService] [store-001-job-9] Sleeping for 6000ms 2014-07-16 15:43:26,694 INFO [store-001] [RegistrationService] [store-001-job-9] This node is unregistered. It will attempt to register using the registration.url 2014-07-16 15:43:26,701 INFO [store-001] [DataLoaderService] [store-001-job-9] Using registration URL of http://localhost:7070/sync/corp-000/registration?nodeGroupId=store&externalId=001&syncURL=http%3A%2F%2FT005583.eu.Micros.int%3A31415%2Fsync%2Fstore-001&schemaVersion=%3F&databaseType=Microsoft+SQL+Server&databaseVersion=10.50&symmetricVersion=3.6.3-SNAPSHOT&hostName=T005583.eu.Micros.int&ipAddress=fe80%3A0%3A0%3A0%3A0%3A5efe%3Aa00%3Aa%2517 2014-07-16 15:43:26,871 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] This database DOES support disabling triggers during a symmetricds data load 2014-07-16 15:43:27,061 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-9] Grouplets flushed because new grouplet config came through the data loader 2014-07-16 15:43:27,061 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-9] Load filters flushed because new filter config came through the data loader 2014-07-16 15:43:27,061 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-9] Channels flushed because new channels came through the data loader 2014-07-16 15:43:27,061 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-9] About to refresh the cache of transformation because new configuration came through the data loader 2014-07-16 15:43:27,062 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-9] About to refresh the cache of conflict settings because new configuration came through the data loader 2014-07-16 15:43:27,062 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-9] About to refresh the cache of parameters because new configuration came through the data loader 2014-07-16 15:43:27,067 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-job-9] About to syncTriggers because new configuration came through the data loader 2014-07-16 15:43:27,067 INFO [store-001] [TriggerRouterService] [store-001-job-9] Synchronizing triggers 2014-07-16 15:43:27,118 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_LD_FLTR_STR trigger for sym-store.dbo.sym_load_filter 2014-07-16 15:43:27,125 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_LD_FLTR_STR trigger for sym-store.dbo.sym_load_filter 2014-07-16 15:43:27,130 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_LD_FLTR_STR trigger for sym-store.dbo.sym_load_filter 2014-07-16 15:43:27,136 ERROR [store-001] [TriggerRouterService] [store-001-job-9] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:43:27,146 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_FL_SNPSHT_STR trigger for sym-store.dbo.sym_file_snapshot 2014-07-16 15:43:27,150 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_FL_SNPSHT_STR trigger for sym-store.dbo.sym_file_snapshot 2014-07-16 15:43:27,164 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_CNFLCT_STR trigger for sym-store.dbo.sym_conflict 2014-07-16 15:43:27,169 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_CNFLCT_STR trigger for sym-store.dbo.sym_conflict 2014-07-16 15:43:27,174 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_CNFLCT_STR trigger for sym-store.dbo.sym_conflict 2014-07-16 15:43:27,184 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_GRPLT_STR trigger for sym-store.dbo.sym_grouplet 2014-07-16 15:43:27,187 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_GRPLT_STR trigger for sym-store.dbo.sym_grouplet 2014-07-16 15:43:27,191 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_GRPLT_STR trigger for sym-store.dbo.sym_grouplet 2014-07-16 15:43:27,202 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_TRGGR_RTR_GRPLT_STR trigger for sym-store.dbo.sym_trigger_router_grouplet 2014-07-16 15:43:27,206 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_TRGGR_RTR_GRPLT_STR trigger for sym-store.dbo.sym_trigger_router_grouplet 2014-07-16 15:43:27,209 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_TRGGR_RTR_GRPLT_STR trigger for sym-store.dbo.sym_trigger_router_grouplet 2014-07-16 15:43:27,221 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_RTR_STR trigger for sym-store.dbo.sym_router 2014-07-16 15:43:27,226 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_RTR_STR trigger for sym-store.dbo.sym_router 2014-07-16 15:43:27,230 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_RTR_STR trigger for sym-store.dbo.sym_router 2014-07-16 15:43:27,241 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_FL_TRGGR_RTR_STR trigger for sym-store.dbo.sym_file_trigger_router 2014-07-16 15:43:27,245 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_FL_TRGGR_RTR_STR trigger for sym-store.dbo.sym_file_trigger_router 2014-07-16 15:43:27,248 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_FL_TRGGR_RTR_STR trigger for sym-store.dbo.sym_file_trigger_router 2014-07-16 15:43:27,261 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_TRGGR_RTR_STR trigger for sym-store.dbo.sym_trigger_router 2014-07-16 15:43:27,264 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_TRGGR_RTR_STR trigger for sym-store.dbo.sym_trigger_router 2014-07-16 15:43:27,268 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_TRGGR_RTR_STR trigger for sym-store.dbo.sym_trigger_router 2014-07-16 15:43:27,279 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_ND_GRP_CHNNL_WND_STR trigger for sym-store.dbo.sym_node_group_channel_wnd 2014-07-16 15:43:27,282 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_ND_GRP_CHNNL_WND_STR trigger for sym-store.dbo.sym_node_group_channel_wnd 2014-07-16 15:43:27,287 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_ND_GRP_CHNNL_WND_STR trigger for sym-store.dbo.sym_node_group_channel_wnd 2014-07-16 15:43:27,299 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_ND_GRP_LNK_STR trigger for sym-store.dbo.sym_node_group_link 2014-07-16 15:43:27,302 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_ND_GRP_LNK_STR trigger for sym-store.dbo.sym_node_group_link 2014-07-16 15:43:27,306 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_ND_GRP_LNK_STR trigger for sym-store.dbo.sym_node_group_link 2014-07-16 15:43:27,310 ERROR [store-001] [TriggerRouterService] [store-001-job-9] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:43:27,326 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_ND_HST_STR trigger for sym-store.dbo.sym_node_host 2014-07-16 15:43:27,331 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_ND_HST_STR trigger for sym-store.dbo.sym_node_host 2014-07-16 15:43:27,335 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_ND_HST_STR trigger for sym-store.dbo.sym_node_host 2014-07-16 15:43:27,347 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_CHNNL_STR trigger for sym-store.dbo.sym_channel 2014-07-16 15:43:27,352 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_CHNNL_STR trigger for sym-store.dbo.sym_channel 2014-07-16 15:43:27,356 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_CHNNL_STR trigger for sym-store.dbo.sym_channel 2014-07-16 15:43:27,360 ERROR [store-001] [TriggerRouterService] [store-001-job-9] Could not find any database tables matching 'sale_return_line_item' in the datasource that is configured 2014-07-16 15:43:27,369 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_FL_TRGGR_STR trigger for sym-store.dbo.sym_file_trigger 2014-07-16 15:43:27,372 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_FL_TRGGR_STR trigger for sym-store.dbo.sym_file_trigger 2014-07-16 15:43:27,378 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_FL_TRGGR_STR trigger for sym-store.dbo.sym_file_trigger 2014-07-16 15:43:27,388 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_ND_STR trigger for sym-store.dbo.sym_node 2014-07-16 15:43:27,392 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_ND_STR trigger for sym-store.dbo.sym_node 2014-07-16 15:43:27,396 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_ND_STR trigger for sym-store.dbo.sym_node 2014-07-16 15:43:27,401 ERROR [store-001] [TriggerRouterService] [store-001-job-9] Could not find any database tables matching 'sale_tender_line_item' in the datasource that is configured 2014-07-16 15:43:27,409 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_GRPLT_LNK_STR trigger for sym-store.dbo.sym_grouplet_link 2014-07-16 15:43:27,411 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_GRPLT_LNK_STR trigger for sym-store.dbo.sym_grouplet_link 2014-07-16 15:43:27,414 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_GRPLT_LNK_STR trigger for sym-store.dbo.sym_grouplet_link 2014-07-16 15:43:27,425 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_ND_SCRTY_STR trigger for sym-store.dbo.sym_node_security 2014-07-16 15:43:27,428 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_ND_SCRTY_STR trigger for sym-store.dbo.sym_node_security 2014-07-16 15:43:27,433 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_ND_SCRTY_STR trigger for sym-store.dbo.sym_node_security 2014-07-16 15:43:27,446 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_TRGGR_STR trigger for sym-store.dbo.sym_trigger 2014-07-16 15:43:27,451 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_TRGGR_STR trigger for sym-store.dbo.sym_trigger 2014-07-16 15:43:27,458 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_TRGGR_STR trigger for sym-store.dbo.sym_trigger 2014-07-16 15:43:27,470 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_TRNSFRM_CLMN_STR trigger for sym-store.dbo.sym_transform_column 2014-07-16 15:43:27,474 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_TRNSFRM_CLMN_STR trigger for sym-store.dbo.sym_transform_column 2014-07-16 15:43:27,478 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_TRNSFRM_CLMN_STR trigger for sym-store.dbo.sym_transform_column 2014-07-16 15:43:27,489 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_TBL_RLD_RQST_STR trigger for sym-store.dbo.sym_table_reload_request 2014-07-16 15:43:27,493 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_TBL_RLD_RQST_STR trigger for sym-store.dbo.sym_table_reload_request 2014-07-16 15:43:27,497 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_TBL_RLD_RQST_STR trigger for sym-store.dbo.sym_table_reload_request 2014-07-16 15:43:27,508 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_ND_GRP_STR trigger for sym-store.dbo.sym_node_group 2014-07-16 15:43:27,511 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_ND_GRP_STR trigger for sym-store.dbo.sym_node_group 2014-07-16 15:43:27,514 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_ND_GRP_STR trigger for sym-store.dbo.sym_node_group 2014-07-16 15:43:27,523 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_PRMTR_STR trigger for sym-store.dbo.sym_parameter 2014-07-16 15:43:27,526 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_PRMTR_STR trigger for sym-store.dbo.sym_parameter 2014-07-16 15:43:27,530 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_PRMTR_STR trigger for sym-store.dbo.sym_parameter 2014-07-16 15:43:27,542 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_I_FOR_SYM_TRNSFRM_TBL_STR trigger for sym-store.dbo.sym_transform_table 2014-07-16 15:43:27,546 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_U_FOR_SYM_TRNSFRM_TBL_STR trigger for sym-store.dbo.sym_transform_table 2014-07-16 15:43:27,550 INFO [store-001] [MsSqlSymmetricDialect] [store-001-job-9] Creating SYM_ON_D_FOR_SYM_TRNSFRM_TBL_STR trigger for sym-store.dbo.sym_transform_table 2014-07-16 15:43:27,553 INFO [store-001] [TriggerRouterService] [store-001-job-9] Done synchronizing triggers 2014-07-16 15:43:27,576 INFO [store-001] [RegistrationService] [store-001-job-9] Successfully registered node [id=001] 2014-07-16 15:43:27,577 INFO [store-001] [PushHeartbeatListener] [store-001-job-9] Some attribute(s) of node changed. Recording changes 2014-07-16 15:43:27,578 INFO [store-001] [PushHeartbeatListener] [store-001-job-9] Updating my node configuration info according to the symmetric properties 2014-07-16 15:43:30,558 INFO [store-001] [RouterService] [store-001-job-15] The 'config' channel is NOT in common batch mode 2014-07-16 15:43:30,591 INFO [store-001] [RouterService] [store-001-job-15] The 'filesync_reload' channel is NOT in common batch mode 2014-07-16 15:43:30,593 INFO [store-001] [RouterService] [store-001-job-15] The 'item' channel is in common batch mode 2014-07-16 15:43:30,594 INFO [store-001] [RouterService] [store-001-job-15] The 'reload' channel is NOT in common batch mode 2014-07-16 15:43:30,595 INFO [store-001] [RouterService] [store-001-job-15] The 'sale_transaction' channel is in common batch mode 2014-07-16 15:43:30,596 INFO [store-001] [RouterService] [store-001-job-15] The 'heartbeat' channel is NOT in common batch mode 2014-07-16 15:43:30,601 INFO [store-001] [RouterService] [store-001-job-15] The 'filesync' channel is NOT in common batch mode 2014-07-16 15:43:30,602 INFO [store-001] [RouterService] [store-001-job-15] The 'default' channel is in common batch mode 2014-07-16 15:43:30,603 INFO [store-001] [RouterService] [store-001-job-15] The 'dynamic' channel is in common batch mode 2014-07-16 15:43:30,603 INFO [store-001] [RouterService] [store-001-job-15] Routed 2 data events in 59 ms 2014-07-16 15:43:37,724 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 1 rows and 1 batches were processed 2014-07-16 15:43:40,587 INFO [store-001] [PushService] [store-001-push-1] Push data sent to corp:000:000 2014-07-16 15:43:40,636 INFO [store-001] [PushService] [store-001-push-1] Pushed data to corp:000:000. 2 data and 2 batches were processed 2014-07-16 15:43:40,642 INFO [store-001] [RouterService] [store-001-job-1] Routed 1 data events in 12 ms 2014-07-16 15:43:47,700 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 1 rows and 1 batches were processed 2014-07-16 15:43:47,701 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:43:47,727 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-pull-1] About to syncTriggers because new configuration came through the data loader 2014-07-16 15:43:47,728 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Synchronizing triggers 2014-07-16 15:43:47,862 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:43:47,876 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:43:47,881 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_return_line_item' in the datasource that is configured 2014-07-16 15:43:47,885 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_tender_line_item' in the datasource that is configured 2014-07-16 15:43:47,897 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Done synchronizing triggers 2014-07-16 15:43:47,908 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 2 rows and 2 batches were processed 2014-07-16 15:43:47,908 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:43:47,936 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="name" type="VARCHAR" size="100"> <platform-column name="mssql2008" type="varchar" size="100"/> </column> </table> </database> 2014-07-16 15:43:47,939 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Running alter sql: SET quoted_identifier on; SET quoted_identifier on; CREATE TABLE "item"( "item_id" int NOT NULL, "name" varchar(100), PRIMARY KEY ("item_id") ); 2014-07-16 15:43:47,963 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 3 rows and 3 batches were processed 2014-07-16 15:43:47,964 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:43:47,986 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item_selling_price"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="store_id" primaryKey="true" required="true" type="VARCHAR" size="5"> <platform-column name="mssql2008" type="varchar" size="5"/> </column> <column name="price" required="true" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <column name="cost" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <foreign-key name="fk_price_item_id" foreignTable="item"> <reference local="item_id" foreign="item_id"/> </foreign-key> </table> </database> 2014-07-16 15:43:47,988 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Running alter sql: SET quoted_identifier on; SET quoted_identifier on; CREATE TABLE "item_selling_price"( "item_id" int NOT NULL, "store_id" varchar(5) NOT NULL, "price" decimal(10,2) NOT NULL, "cost" decimal(10,2), PRIMARY KEY ("item_id", "store_id") ); ALTER TABLE "item_selling_price" ADD CONSTRAINT "fk_price_item_id" FOREIGN KEY ("item_id") REFERENCES "item" ("item_id"); 2014-07-16 15:43:48,011 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 4 rows and 4 batches were processed 2014-07-16 15:43:48,012 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:43:48,045 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 5 rows and 5 batches were processed 2014-07-16 15:43:48,046 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:43:48,079 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 6 rows and 6 batches were processed 2014-07-16 15:43:48,080 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:43:48,116 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 7 rows and 7 batches were processed 2014-07-16 15:43:50,674 INFO [store-001] [RouterService] [store-001-job-1] Routed 2 data events in 15 ms 2014-07-16 15:47:17,792 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 1 rows and 1 batches were processed 2014-07-16 15:47:17,792 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:47:17,819 INFO [store-001] [ConfigurationChangedDatabaseWriterFilter] [store-001-pull-1] About to syncTriggers because new configuration came through the data loader 2014-07-16 15:47:17,819 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Synchronizing triggers 2014-07-16 15:47:17,937 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:47:17,949 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_transaction' in the datasource that is configured 2014-07-16 15:47:17,953 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_return_line_item' in the datasource that is configured 2014-07-16 15:47:17,956 ERROR [store-001] [TriggerRouterService] [store-001-pull-1] Could not find any database tables matching 'sale_tender_line_item' in the datasource that is configured 2014-07-16 15:47:17,968 INFO [store-001] [TriggerRouterService] [store-001-pull-1] Done synchronizing triggers 2014-07-16 15:47:17,978 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 2 rows and 2 batches were processed 2014-07-16 15:47:17,978 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:47:17,997 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="name" type="VARCHAR" size="100"> <platform-column name="mssql2008" type="varchar" size="100"/> </column> </table> </database> 2014-07-16 15:47:18,001 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Tables up to date. No alters found for item 2014-07-16 15:47:18,018 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 3 rows and 3 batches were processed 2014-07-16 15:47:18,018 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:47:18,039 INFO [store-001] [DefaultDatabaseWriter] [store-001-pull-1] About to create table using the following definition: <?xml version="1.0"?> <!DOCTYPE database SYSTEM "http://db.apache.org/torque/dtd/database"> <database name="dataextractor"> <table name="item_selling_price"> <column name="item_id" primaryKey="true" required="true" type="INTEGER" size="10"> <platform-column name="mssql2008" type="int" size="10"/> </column> <column name="store_id" primaryKey="true" required="true" type="VARCHAR" size="5"> <platform-column name="mssql2008" type="varchar" size="5"/> </column> <column name="price" required="true" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <column name="cost" type="DECIMAL" size="10,2"> <platform-column name="mssql2008" type="decimal" size="10" decimalDigits="2"/> </column> <foreign-key name="fk_price_item_id" foreignTable="item"> <reference local="item_id" foreign="item_id"/> </foreign-key> </table> </database> 2014-07-16 15:47:18,045 INFO [store-001] [MsSql2008DatabasePlatform] [store-001-pull-1] Tables up to date. No alters found for item_selling_price 2014-07-16 15:47:18,064 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 4 rows and 4 batches were processed 2014-07-16 15:47:18,064 INFO [store-001] [PullService] [store-001-pull-1] Immediate pull requested while in reload mode 2014-07-16 15:47:18,095 INFO [store-001] [PullService] [store-001-pull-1] Pull data received from corp:000:000. 4 rows and 4 batches were processed 2014-07-16 15:47:21,161 INFO [store-001] [RouterService] [store-001-job-1] Routed 1 data events in 18 ms |
|
Thanks. I'll spend more time trying to reproduce. |
|
I can't reproduce this. It is like the physical database table has had the comment column removed as a last step. |
|
I was able to reproduce by dropping a column. I was not able to reproduce by adding a column. |
|
I just realized that this probably happens because you are running the sync triggers utility which runs outside the server. The table is cached and doesn't have the same number of columns as the most current trigger hist. That should be fixable. |
|
I added a check to re-read the table metadata from the database if the trigger hist column count is > than the cached metadata column count. I think that will solve this specific issue. |
SymmetricDS: master 836b7b37 2014-07-16 08:02:09 Details Diff |
0001814: NullPointerException in AbstractTriggerTemplate.createInitalLoadSql |
Affected Issues 0001814 |
|
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractTriggerTemplate.java | Diff File | ||
SymmetricDS: master 3662a4e4 2014-07-20 18:51:02 Details Diff |
0001814: NullPointerException in AbstractTriggerTemplate.createInitalLoadSql |
Affected Issues 0001814 |
|
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java | Diff File |
Date Modified | Username | Field | Change |
---|---|---|---|
2014-07-16 10:02 | ErnstErnst | New Issue | |
2014-07-16 10:02 | ErnstErnst | File Added: symmetric.upload.log | |
2014-07-16 10:03 | ErnstErnst | File Added: symmetric.store.upload.log | |
2014-07-16 10:04 | ErnstErnst | File Added: store-001.properties | |
2014-07-16 10:04 | ErnstErnst | File Added: corp-000.properties | |
2014-07-16 10:05 | ErnstErnst | Note Added: 0000544 | |
2014-07-16 12:05 | chenson | Target Version | => 3.6.3 |
2014-07-16 12:05 | chenson | Assigned To | => chenson |
2014-07-16 12:05 | chenson | Status | new => assigned |
2014-07-16 12:50 | chenson | Note Added: 0000545 | |
2014-07-16 13:00 | chenson | Changeset attached | => SymmetricDS trunk r8479 |
2014-07-16 13:53 | ErnstErnst | Note Added: 0000546 | |
2014-07-16 13:54 | ErnstErnst | File Added: symmetric.corp.symmetric-3.6.3-SNAPSHOT.log | |
2014-07-16 13:54 | ErnstErnst | File Added: symmetric.store.symmetric-3.6.3-SNAPSHOT.log | |
2014-07-16 15:31 | chenson | Note Added: 0000547 | |
2014-07-16 18:31 | chenson | Note Added: 0000548 | |
2014-07-16 18:48 | chenson | Note Added: 0000549 | |
2014-07-17 11:10 | chenson | Note Added: 0000550 | |
2014-07-20 22:52 | chenson | Note Added: 0000555 | |
2014-07-20 22:52 | chenson | Status | assigned => resolved |
2014-07-20 22:52 | chenson | Fixed in Version | => 3.6.3 |
2014-07-20 22:52 | chenson | Resolution | open => fixed |
2014-07-20 23:00 | chenson | Changeset attached | => SymmetricDS trunk r8487 |
2014-07-29 20:50 | chenson | Status | resolved => closed |
2015-07-31 01:49 | chenson | Changeset attached | => SymmetricDS master 3662a4e4 |
2015-07-31 01:49 | chenson | Changeset attached | => SymmetricDS master 836b7b37 |