jesterj Different worker threads work on the same data in a scanner

Different worker threads work on the same data in a scanner

Open dgoldenberg1234 opened this issue 8 years ago • 1 comments

This can be seen in e.g. JdbcScannerTester (to be checked in).

In the output below, notice how the same document data is processed by multiple threads. Due to scan frequency or something else? We shouldn't be reprocessing the same data over and over...

2016-03-30T09:32:21,871 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,871 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,871 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,871 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,871 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,873 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,873 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,873 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,893 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'} 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,893 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,893 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,893 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,893 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,893 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,895 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,895 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,895 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,895 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,896 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,897 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,898 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,898 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,898 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,898 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,899 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,900 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,900 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,900 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,900 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,901 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,902 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001

2016-03-30T09:32:21,902 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

2016-03-30T09:32:21,919 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002

2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,919 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,920 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,920 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false'

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,920 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,920 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,922 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,923 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,923 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,923 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,923 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,925 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,925 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,926 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,926 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,926 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,928 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,928 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,928 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,928 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,928 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,930 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,930 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001

2016-03-30T09:32:21,930 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,946 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,947 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,946 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002

2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,946 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

2016-03-30T09:32:21,946 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,946 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,946 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,947 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,947 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,947 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,949 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,950 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,950 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,950 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,950 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,952 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,952 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,952 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,952 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,953 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,954 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,954 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,954 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,954 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,955 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,956 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,956 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001

2016-03-30T09:32:21,956 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,975 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,975 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,975 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,975 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,975 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:21,976 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:21,976 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,976 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:21,976 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,976 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:21,977 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,978 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,978 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,978 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,978 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,979 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,980 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,980 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,980 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,980 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,982 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,982 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:21,982 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:21,983 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:21,983 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,985 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:21,985 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001

2016-03-30T09:32:21,985 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,003 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:22,003 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:22,004 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,004 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,003 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,004 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:22,004 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,004 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,004 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,004 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,006 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,007 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:22,007 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:22,007 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:22,007 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,009 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,010 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:22,010 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:22,010 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:22,010 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,012 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,012 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:22,012 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:22,012 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:22,012 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,015 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,015 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001

2016-03-30T09:32:22,015 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,030 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:22,030 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,030 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,030 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,030 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,030 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,032 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,032 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:22,032 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:22,032 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:22,033 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,034 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,034 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:22,034 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:22,034 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:22,035 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,036 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,036 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:22,036 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:22,036 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:22,037 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,038 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,039 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001

2016-03-30T09:32:22,039 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,058 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003

2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,058 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,058 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

2016-03-30T09:32:22,058 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:22,059 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,059 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:22,059 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:22,059 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,059 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:22,060 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:22,061 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:22,061 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:22,061 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003

2016-03-30T09:32:22,061 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false'

DOC: DocumentImpl{delegate={firstname=[Georgi], birthdate=[1953-09-02T04:00:00Z], gender=[M], empno=[10001], hiredate=[1986-06-26T04:00:00Z], lastname=[Facello]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Bezalel], birthdate=[1964-06-02T04:00:00Z], gender=[F], empno=[10002], hiredate=[1985-11-21T05:00:00Z], lastname=[Simmel]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

DOC: DocumentImpl{delegate={firstname=[Parto], birthdate=[1959-12-03T05:00:00Z], gender=[M], empno=[10003], hiredate=[1986-08-28T04:00:00Z], lastname=[Bamford]}, status=PROCESSING, statusMessage='', plan=org.jesterj.ingest.model.impl.PlanImpl@45602820, operation=NEW, sourceScannerName='JDBC Scanner', idField='empno'}

2016-03-30T09:32:24,458 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001 2016-03-30T09:32:24,458 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002 2016-03-30T09:32:24,458 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003 2016-03-30T09:32:24,458 INFO ForkJoinPool.commonPool-worker-4 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:24,458 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:24,459 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test 2016-03-30T09:32:24,463 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:24,464 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:24,464 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:24,464 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:24,464 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:24,468 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:24,468 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:24,468 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:24,468 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:24,469 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:24,470 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:24,470 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:24,470 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002 2016-03-30T09:32:24,470 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10003 2016-03-30T09:32:24,470 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:24,472 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Successfully established JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false' 2016-03-30T09:32:24,472 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10001 2016-03-30T09:32:24,472 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

Mar 30 '16 13:03 dgoldenberg1234

Can you perhaps pare down the log to a minimal example and provide steps to reproduce?

Jun 12 '17 22:06 nsoft

Many things have changed, this doesn't seem to have presented a problem or if it did I may have fixed it without appreciating this ticket.

Feb 21 '23 18:02 nsoft

jesterj jesterj copied to clipboard

Different worker threads work on the same data in a scanner

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,893 INFO ForkJoinPool.commonPool-worker-3 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,902 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002

2016-03-30T09:32:21,919 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,920 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,920 DEBUG pool-4-thread-1 org.jesterj.ingest.utils.SqlUtils Establishing JDBC connection to 'jdbc:mysql://localhost/employees?autoReconnect=true&useSSL=false'

2016-03-30T09:32:21,930 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

2016-03-30T09:32:21,946 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002

2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-5 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

2016-03-30T09:32:21,947 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,956 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl test finished processing 10002

2016-03-30T09:32:21,975 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:21,985 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

2016-03-30T09:32:22,003 INFO Thread-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10001

2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-1 org.jesterj.ingest.model.impl.StepImpl test finished processing 10003

2016-03-30T09:32:22,003 INFO ForkJoinPool.commonPool-worker-7 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:22,015 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-2 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:22,030 INFO ForkJoinPool.commonPool-worker-6 org.jesterj.ingest.model.impl.StepImpl No qualifying next step found by org.jesterj.ingest.model.impl.DefaultStepNameRouter@268ca5a6 in test

2016-03-30T09:32:22,039 INFO pool-4-thread-1 org.jesterj.ingest.model.impl.StepImpl JDBC Scanner finished processing 10002

jesterj
jesterj copied to clipboard