2016-05-18 05:36:53,407 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 05:36:53,420 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.flow.hadoop.BuildJobsHadoopPlatformTest, with platform: hadoop
2016-05-18 05:36:53,455 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-18 05:36:53,711 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 05:36:53,808 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:53,810 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:53,942 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 38032672DB924902B06D7F5C1ADA35A8
2016-05-18 05:36:54,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [source20*source101*sou...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.230
2016-05-18 05:36:54,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [source20*source101*sou...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 05:36:54,220 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [source20*source101*sou...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:54,412 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:54,413 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:54,445 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:54,446 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:54,477 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:54,478 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:54,546 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-05-18 05:36:54,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:54,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:54,602 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:54,603 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:54,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [a*b] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-18 05:36:54,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [a*b] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:54,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [a*b] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:54,705 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:54,706 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:54,768 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [a*b] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-18 05:36:54,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [a*b] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:54,770 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [a*b] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:54,810 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:54,810 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:54,862 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [a*b] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-05-18 05:36:54,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [a*b] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:54,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [a*b] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:54,901 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:54,901 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:54,908 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.003
2016-05-18 05:36:54,908 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:36:54,926 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:54,927 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:55,004 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [source20*source101*sou...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.073
2016-05-18 05:36:55,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [source20*source101*sou...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 05:36:55,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [source20*source101*sou...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:55,059 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:55,060 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:55,111 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-18 05:36:55,112 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:55,112 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:55,151 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:55,152 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:55,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-05-18 05:36:55,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 05:36:55,227 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:55,287 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:55,288 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:55,375 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [splitmiddle] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-05-18 05:36:55,376 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [splitmiddle] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 05:36:55,376 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [splitmiddle] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:55,425 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:55,425 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:55,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-18 05:36:55,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:55,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:55,507 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:55,507 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:55,551 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-18 05:36:55,552 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 05:36:55,553 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:55,588 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:55,588 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:55,682 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [splitmiddle] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.089
2016-05-18 05:36:55,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [splitmiddle] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 05:36:55,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [splitmiddle] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:55,778 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:55,779 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:55,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.134
2016-05-18 05:36:55,934 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 05:36:55,935 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:56,017 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,018 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-18 05:36:56,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 05:36:56,095 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:56,138 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,139 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,188 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 05:36:56,189 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:56,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:56,226 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,227 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,246 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-05-18 05:36:56,247 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:36:56,262 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,263 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-18 05:36:56,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:56,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:56,343 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,344 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,408 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-18 05:36:56,409 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 05:36:56,409 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:56,452 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,452 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2*lo...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.126
2016-05-18 05:36:56,585 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2*lo...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 10
2016-05-18 05:36:56,585 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2*lo...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:56,796 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,796 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 05:36:56,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:56,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:56,840 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,840 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [splitmiddle] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-18 05:36:56,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [splitmiddle] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 05:36:56,895 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [splitmiddle] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:56,928 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,929 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,941 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,942 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 05:36:56,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:36:56,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:56,974 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:56,974 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:56,991 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [source20*source101*sou...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-05-18 05:36:56,992 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [source20*source101*sou...] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:36:57,001 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,002 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 05:36:57,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:36:57,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,038 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,039 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,050 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,050 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroup] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 05:36:57,074 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroup] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:57,074 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroup] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,088 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,088 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
exception.getMessage() = not all tail pipes bound to sink taps, remaining tail pipe names: ['split'], remaining sink tap names: ['left', 'right']
2016-05-18 05:36:57,099 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,099 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [join] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.001
2016-05-18 05:36:57,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [join] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:36:57,111 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,111 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.001
2016-05-18 05:36:57,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:36:57,122 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,122 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 05:36:57,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 05:36:57,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,176 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,177 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 05:36:57,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:57,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,230 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,230 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,237 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.002
2016-05-18 05:36:57,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:36:57,251 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,252 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-05-18 05:36:57,342 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 9
2016-05-18 05:36:57,343 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,402 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,402 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,442 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 05:36:57,443 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 05:36:57,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,464 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,464 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,488 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 05:36:57,489 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 05:36:57,489 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,513 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,514 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,569 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 05:36:57,570 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 6
2016-05-18 05:36:57,570 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,602 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,602 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 05:36:57,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:57,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,633 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,633 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 05:36:57,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:57,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,673 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,673 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,704 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 05:36:57,705 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 05:36:57,705 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,728 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,729 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,732 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.001
2016-05-18 05:36:57,732 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:36:57,739 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,740 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroup] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.004
2016-05-18 05:36:57,747 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroup] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:36:57,758 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,758 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,768 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroup] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 05:36:57,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [cogroup] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:36:57,778 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,779 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 05:36:57,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 4
2016-05-18 05:36:57,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,841 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,841 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:36:57,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-05-18 05:36:57,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 9
2016-05-18 05:36:57,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:57,923 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:57,923 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar