Class cascading.JoinFieldedPipesPlatformTest

39

tests

0

failures

0

ignored

38m8.10s

duration

100%

successful

Tests

Test Duration Result
testCross 30.496s passed
testGroupBySplitGroupByJoin 2m2.16s passed
testGroupBySplitJoins 1m27.31s passed
testJoin 33.351s passed
testJoinAfterEvery 1m48.37s passed
testJoinAroundJoinLeftMost 1m53.30s passed
testJoinAroundJoinRightMost 36.762s passed
testJoinAroundJoinRightMostSwapped 1m9.02s passed
testJoinDiffFields 36.296s passed
testJoinFilteredBranch 1m16.83s passed
testJoinGroupBy 43.500s passed
testJoinGroupByJoin 1m2.63s passed
testJoinInner 52.970s passed
testJoinInnerOuter 36.443s passed
testJoinInnerSingleField 1m3.76s passed
testJoinMergeGroupBy 0.145s passed
testJoinMixed 0.001s passed
testJoinNone 35.120s passed
testJoinOuter 0s passed
testJoinOuterInner 0s passed
testJoinSamePipe 37.802s passed
testJoinSamePipe2 34.253s passed
testJoinSamePipe3 39.575s passed
testJoinSamePipeAroundGroupBy 1m30.84s passed
testJoinSamePipeName 34.223s passed
testJoinSameSourceIntoJoin 1m41.59s passed
testJoinSameSourceIntoJoinSimple 1m8.60s passed
testJoinSameSourceOverGroupByIntoJoinSimple 1m38.50s passed
testJoinSelf 1m6.22s passed
testJoinSplit 1m17.19s passed
testJoinSplitBeforeJoin 1m49.94s passed
testJoinWithHasher 44.593s passed
testJoinWithUnknowns 32.825s passed
testJoinsIntoCoGroup 49.012s passed
testJoinsIntoCoGroupLhs 1m42.71s passed
testJoinsIntoCoGroupLhsSwappedJoin 40.947s passed
testJoinsIntoCoGroupRhs 1m54.92s passed
testJoinsIntoGroupBy 48.675s passed
testSameSourceJoinSplitIntoJoin 1m27.22s passed

Standard output

2015-08-12 17:34:19,751 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 17:34:19,815 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.JoinFieldedPipesPlatformTest, with platform: hadoop2-mr1
2015-08-12 17:34:19,851 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-08-12 17:34:21,027 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-08-12 17:34:21,707 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-12 17:34:27,908 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 17:34:28,325 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 17:34:28,543 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 17:34:28,729 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 17:34:45,936 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-08-12 17:34:46,144 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:34:46,156 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:34:46,289 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 7326A1B7120543B8A7888CF60E664F14
2015-08-12 17:34:46,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.103
2015-08-12 17:34:46,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:34:46,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:34:46,628 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 17:34:46,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 17:34:46,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:34:46,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 17:34:46,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle"]
2015-08-12 17:34:46,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 17:34:46,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-08-12 17:34:46,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-08-12 17:34:46,637 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ngleField/joininnersingle
2015-08-12 17:34:47,595 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0001
2015-08-12 17:34:47,595 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0001/
2015-08-12 17:35:21,891 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0001_01_000002 is : 143
2015-08-12 17:35:23,406 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle/_temporary
2015-08-12 17:35:23,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:36.760, using cpu time: 00:05.640
2015-08-12 17:35:23,570 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle
2015-08-12 17:35:23,644 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:35:23,645 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:35:23,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.087
2015-08-12 17:35:23,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-08-12 17:35:23,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:35:23,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting
2015-08-12 17:35:23,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:35:23,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:35:23,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple"]
2015-08-12 17:35:23,798 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  parallel execution of steps is enabled: true
2015-08-12 17:35:23,798 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  executing total steps: 2
2015-08-12 17:35:23,798 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  allocating management threads: 2
2015-08-12 17:35:23,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (1/2)
2015-08-12 17:35:24,097 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1439426080426_0002
2015-08-12 17:35:24,098 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0002/
2015-08-12 17:35:54,338 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0002_01_000002 is : 143
2015-08-12 17:35:55,213 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0002_01_000004 is : 143
2015-08-12 17:35:56,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (2/2) ...nsamesourceintojoinsimple
2015-08-12 17:35:57,127 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1439426080426_0003
2015-08-12 17:35:57,127 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0003/
2015-08-12 17:36:29,662 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0003_01_000004 is : 143
2015-08-12 17:36:30,293 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0003_01_000003 is : 143
2015-08-12 17:36:30,563 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0003_01_000002 is : 143
2015-08-12 17:36:30,689 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0003_01_000005 is : 143
2015-08-12 17:36:32,055 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple/_temporary
2015-08-12 17:36:32,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  completed in: 01:08.250, using cpu time: 00:12.220
2015-08-12 17:36:32,169 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple
2015-08-12 17:36:32,264 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:36:32,266 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:36:32,426 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.143
2015-08-12 17:36:32,431 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-08-12 17:36:32,432 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:36:32,513 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting
2015-08-12 17:36:32,514 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:36:32,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:36:32,518 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:36:32,520 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost"]
2015-08-12 17:36:32,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  parallel execution of steps is enabled: true
2015-08-12 17:36:32,523 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  executing total steps: 2
2015-08-12 17:36:32,524 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  allocating management threads: 2
2015-08-12 17:36:32,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting step: (1/2)
2015-08-12 17:36:32,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] submitted hadoop job: job_1439426080426_0004
2015-08-12 17:36:32,753 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0004/
2015-08-12 17:37:18,637 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0004_01_000006 is : 143
2015-08-12 17:37:19,032 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0004_01_000003 is : 143
2015-08-12 17:37:21,555 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting step: (2/2) ...st/joinaroundjoinleftmost
2015-08-12 17:37:22,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] submitted hadoop job: job_1439426080426_0005
2015-08-12 17:37:22,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0005/
2015-08-12 17:37:40,168 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0005_01_000001 is : 1
2015-08-12 17:37:40,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(229)) - Exception from container-launch with container ID: container_1439426080426_0005_01_000001 and exit code: 1
ExitCodeException exitCode=1: 
	at org.apache.hadoop.util.Shell.runCommand(Shell.java:538)
	at org.apache.hadoop.util.Shell.run(Shell.java:455)
	at org.apache.hadoop.util.Shell$ShellCommandExecutor.execute(Shell.java:715)
	at org.apache.hadoop.yarn.server.nodemanager.DefaultContainerExecutor.launchContainer(DefaultContainerExecutor.java:211)
	at org.apache.hadoop.yarn.server.nodemanager.containermanager.launcher.ContainerLaunch.call(ContainerLaunch.java:302)
	at org.apache.hadoop.yarn.server.nodemanager.containermanager.launcher.ContainerLaunch.call(ContainerLaunch.java:82)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 17:37:40,181 WARN  launcher.ContainerLaunch (ContainerLaunch.java:call(338)) - Container exited with a non-zero exit code 1
2015-08-12 17:37:40,209 WARN  nodemanager.NMAuditLogger (NMAuditLogger.java:logFailure(150)) - USER=root	OPERATION=Container Finished - Failed	TARGET=ContainerImpl	RESULT=FAILURE	DESCRIPTION=Container failed with state: EXITED_WITH_FAILURE	APPID=application_1439426080426_0005	CONTAINERID=container_1439426080426_0005_01_000001
2015-08-12 17:38:18,930 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0005_02_000006 is : 143
2015-08-12 17:38:22,515 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0005_02_000003 is : 143
2015-08-12 17:38:22,951 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0005_02_000005 is : 143
2015-08-12 17:38:24,036 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0005_02_000004 is : 143
2015-08-12 17:38:25,377 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost/_temporary
2015-08-12 17:38:25,383 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  completed in: 01:52.857, using cpu time: 00:17.780
2015-08-12 17:38:25,477 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost
2015-08-12 17:38:25,563 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:38:25,564 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:38:25,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2015-08-12 17:38:25,616 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:38:25,617 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:38:25,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting
2015-08-12 17:38:25,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:38:25,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:38:25,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes"]
2015-08-12 17:38:25,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  parallel execution of steps is enabled: true
2015-08-12 17:38:25,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  executing total steps: 1
2015-08-12 17:38:25,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  allocating management threads: 1
2015-08-12 17:38:25,637 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2015-08-12 17:38:25,830 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] submitted hadoop job: job_1439426080426_0006
2015-08-12 17:38:25,831 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0006/
2015-08-12 17:38:56,820 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0006_01_000005 is : 143
2015-08-12 17:38:58,155 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0006_01_000002 is : 143
2015-08-12 17:38:59,538 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes/_temporary
2015-08-12 17:38:59,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  completed in: 00:33.903, using cpu time: 00:05.780
2015-08-12 17:38:59,699 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes
2015-08-12 17:38:59,817 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:38:59,819 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:39:00,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.198
2015-08-12 17:39:00,058 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2015-08-12 17:39:00,058 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:39:00,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 17:39:00,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:39:00,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:39:00,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery"]
2015-08-12 17:39:00,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 17:39:00,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 3
2015-08-12 17:39:00,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 3
2015-08-12 17:39:00,209 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-08-12 17:39:00,209 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-08-12 17:39:00,692 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0007
2015-08-12 17:39:00,693 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0007/
2015-08-12 17:39:00,899 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0008
2015-08-12 17:39:00,899 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0008/
2015-08-12 17:40:01,433 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0007_01_000006 is : 143
2015-08-12 17:40:03,891 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0007_01_000002 is : 143
2015-08-12 17:40:21,313 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0008_01_000003 is : 143
2015-08-12 17:40:21,536 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0008_01_000002 is : 143
2015-08-12 17:40:26,292 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0007_01_000007 is : 143
2015-08-12 17:40:31,389 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0008_01_000007 is : 143
2015-08-12 17:40:32,630 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...JoinAfterEvery/afterevery
2015-08-12 17:40:32,904 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0009
2015-08-12 17:40:32,905 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0009/
2015-08-12 17:40:33,090 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1439426080426_0007_01_000001
2015-08-12 17:40:38,941 WARN  jobhistory.FileNameIndexUtils (FileNameIndexUtils.java:getIndexInfo(178)) - Unable to parse start time from job history file job_1439426080426_0005-1439426241876-root-%5B5608153824664493A8895E40C943EB36%2FF965EE6B6E864CA1-1439426304149-5-0-SUCCEEDED-default--1.jhist : java.lang.NumberFormatException: For input string: ""
2015-08-12 17:40:46,591 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0009_01_000002 is : 143
2015-08-12 17:40:48,027 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery/_temporary
2015-08-12 17:40:48,032 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:47.834, using cpu time: 00:20.410
2015-08-12 17:40:48,101 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery
2015-08-12 17:40:48,205 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:40:48,208 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:40:48,334 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.108
2015-08-12 17:40:48,340 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 17:40:48,340 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:40:48,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2015-08-12 17:40:48,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:40:48,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:40:48,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 17:40:48,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:40:48,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin"]
2015-08-12 17:40:48,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  parallel execution of steps is enabled: true
2015-08-12 17:40:48,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  executing total steps: 1
2015-08-12 17:40:48,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  allocating management threads: 1
2015-08-12 17:40:48,378 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2015-08-12 17:40:48,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1439426080426_0010
2015-08-12 17:40:48,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0010/
2015-08-12 17:41:18,608 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0010_01_000002 is : 143
2015-08-12 17:41:19,370 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0010_01_000003 is : 143
2015-08-12 17:41:21,581 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0010_01_000005 is : 143
2015-08-12 17:41:21,877 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0010_01_000006 is : 143
2015-08-12 17:41:22,175 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0010_01_000004 is : 143
2015-08-12 17:41:27,660 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0010_01_000007 is : 143
2015-08-12 17:41:28,980 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin/_temporary
2015-08-12 17:41:28,985 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  completed in: 00:40.602, using cpu time: 00:07.340
2015-08-12 17:41:29,041 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin
2015-08-12 17:41:29,112 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:41:29,113 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:41:29,242 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.125
2015-08-12 17:41:29,248 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2015-08-12 17:41:29,248 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:41:29,315 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting
2015-08-12 17:41:29,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:41:29,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:41:29,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:41:29,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs"]
2015-08-12 17:41:29,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs"]
2015-08-12 17:41:29,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  parallel execution of steps is enabled: true
2015-08-12 17:41:29,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  executing total steps: 3
2015-08-12 17:41:29,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  allocating management threads: 3
2015-08-12 17:41:29,334 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (1/3)
2015-08-12 17:41:29,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1439426080426_0011
2015-08-12 17:41:29,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0011/
2015-08-12 17:42:06,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0011_01_000003 is : 143
2015-08-12 17:42:10,028 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0011_01_000005 is : 143
2015-08-12 17:42:18,717 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0011_01_000007 is : 143
2015-08-12 17:42:20,039 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (2/3) ...testGroupBySplitJoins/rhs
2015-08-12 17:42:20,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (3/3) ...testGroupBySplitJoins/lhs
2015-08-12 17:42:20,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1439426080426_0012
2015-08-12 17:42:20,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0012/
2015-08-12 17:42:20,431 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1439426080426_0013
2015-08-12 17:42:20,431 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0013/
2015-08-12 17:42:46,900 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0012_01_000002 is : 143
2015-08-12 17:42:54,737 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0013_01_000002 is : 143
2015-08-12 17:42:56,193 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs/_temporary
2015-08-12 17:42:56,195 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs/_temporary
2015-08-12 17:42:56,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  completed in: 01:26.872, using cpu time: 00:12.120
2015-08-12 17:42:56,342 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs
2015-08-12 17:42:56,361 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs
2015-08-12 17:42:56,409 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:42:56,411 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:42:56,525 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.106
2015-08-12 17:42:56,527 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-08-12 17:42:56,527 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:42:56,564 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2015-08-12 17:42:56,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:42:56,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:42:56,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 17:42:56,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:42:56,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs"]
2015-08-12 17:42:56,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  parallel execution of steps is enabled: true
2015-08-12 17:42:56,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  executing total steps: 2
2015-08-12 17:42:56,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  allocating management threads: 2
2015-08-12 17:42:56,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/2)
2015-08-12 17:42:56,782 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1439426080426_0014
2015-08-12 17:42:56,783 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0014/
2015-08-12 17:43:40,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0014_01_000006 is : 143
2015-08-12 17:43:41,966 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (2/2) ...upLhs/joinsintocogrouplhs
2015-08-12 17:43:42,333 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1439426080426_0015
2015-08-12 17:43:42,334 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0015/
2015-08-12 17:44:27,059 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0015_01_000002 is : 143
2015-08-12 17:44:28,166 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0015_01_000004 is : 143
2015-08-12 17:44:37,467 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0015_01_000007 is : 143
2015-08-12 17:44:38,978 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs/_temporary
2015-08-12 17:44:38,983 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  completed in: 01:42.397, using cpu time: 00:19.560
2015-08-12 17:44:39,068 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs
2015-08-12 17:44:39,123 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:44:39,124 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:44:39,269 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.136
2015-08-12 17:44:39,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-08-12 17:44:39,293 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:44:39,348 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2015-08-12 17:44:39,349 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:44:39,349 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:44:39,350 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 17:44:39,351 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:44:39,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs"]
2015-08-12 17:44:39,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  parallel execution of steps is enabled: true
2015-08-12 17:44:39,357 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  executing total steps: 2
2015-08-12 17:44:39,357 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  allocating management threads: 2
2015-08-12 17:44:39,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/2)
2015-08-12 17:44:39,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1439426080426_0016
2015-08-12 17:44:39,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0016/
2015-08-12 17:45:36,300 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0016_01_000003 is : 143
2015-08-12 17:45:37,529 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0016_01_000004 is : 143
2015-08-12 17:45:39,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (2/2) ...upRhs/joinsintocogrouprhs
2015-08-12 17:45:40,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1439426080426_0017
2015-08-12 17:45:40,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0017/
2015-08-12 17:46:19,507 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0017_01_000006 is : 143
2015-08-12 17:46:22,252 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0017_01_000004 is : 143
2015-08-12 17:46:23,423 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0017_01_000005 is : 143
2015-08-12 17:46:24,108 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0017_01_000002 is : 143
2015-08-12 17:46:24,498 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0017_01_000003 is : 143
2015-08-12 17:46:32,465 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0017_01_000007 is : 143
2015-08-12 17:46:33,901 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs/_temporary
2015-08-12 17:46:33,908 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  completed in: 01:54.538, using cpu time: 00:20.540
2015-08-12 17:46:33,991 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs
2015-08-12 17:46:34,294 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:46:34,296 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:46:34,346 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2015-08-12 17:46:34,347 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:46:34,347 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:46:34,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 17:46:34,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:46:34,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:46:34,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher"]
2015-08-12 17:46:34,378 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 17:46:34,378 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-08-12 17:46:34,379 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-08-12 17:46:34,382 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...JoinWithHasher/joinhasher
2015-08-12 17:46:34,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0018
2015-08-12 17:46:34,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0018/
2015-08-12 17:47:13,043 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0018_01_000006 is : 143
2015-08-12 17:47:16,674 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0018_01_000003 is : 143
2015-08-12 17:47:18,474 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher/_temporary
2015-08-12 17:47:18,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:44.096, using cpu time: 00:09.540
2015-08-12 17:47:18,559 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher
2015-08-12 17:47:18,619 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:47:18,619 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:47:18,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2015-08-12 17:47:18,693 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-08-12 17:47:18,694 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:47:18,733 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting
2015-08-12 17:47:18,734 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:47:18,735 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:47:18,735 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:47:18,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin"]
2015-08-12 17:47:18,737 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  parallel execution of steps is enabled: true
2015-08-12 17:47:18,737 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  executing total steps: 2
2015-08-12 17:47:18,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  allocating management threads: 2
2015-08-12 17:47:18,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting step: (1/2)
2015-08-12 17:47:19,023 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] submitted hadoop job: job_1439426080426_0019
2015-08-12 17:47:19,023 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0019/
2015-08-12 17:47:55,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0019_01_000004 is : 143
2015-08-12 17:47:55,429 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0019_01_000002 is : 143
2015-08-12 17:47:55,587 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0019_01_000006 is : 143
2015-08-12 17:47:55,635 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0019_01_000003 is : 143
2015-08-12 17:48:03,603 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0019_01_000007 is : 143
2015-08-12 17:48:04,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting step: (2/2) ...oupByJoin/joingroupbyjoin
2015-08-12 17:48:05,103 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] submitted hadoop job: job_1439426080426_0020
2015-08-12 17:48:05,103 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0020/
2015-08-12 17:48:19,753 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0020_01_000002 is : 143
2015-08-12 17:48:21,127 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin/_temporary
2015-08-12 17:48:21,143 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  completed in: 01:02.389, using cpu time: 00:09.270
2015-08-12 17:48:21,201 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin
2015-08-12 17:48:21,257 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:48:21,258 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:48:21,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2015-08-12 17:48:21,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:48:21,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:48:21,334 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-08-12 17:48:21,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 17:48:21,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:48:21,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross"]
2015-08-12 17:48:21,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  parallel execution of steps is enabled: true
2015-08-12 17:48:21,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  executing total steps: 1
2015-08-12 17:48:21,338 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  allocating management threads: 1
2015-08-12 17:48:21,339 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2015-08-12 17:48:21,671 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1439426080426_0021
2015-08-12 17:48:21,671 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0021/
2015-08-12 17:48:49,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0021_01_000004 is : 143
2015-08-12 17:48:51,596 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross/_temporary
2015-08-12 17:48:51,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  completed in: 00:30.258, using cpu time: 00:04.960
2015-08-12 17:48:51,690 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testCross/cross
2015-08-12 17:48:51,744 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:48:51,746 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:48:51,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-08-12 17:48:51,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:48:51,788 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:48:51,817 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 17:48:51,817 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:48:51,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:48:51,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join"]
2015-08-12 17:48:51,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 17:48:51,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-08-12 17:48:51,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-08-12 17:48:51,822 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...pesplatform/testJoin/join
2015-08-12 17:48:52,036 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0022
2015-08-12 17:48:52,036 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0022/
2015-08-12 17:49:22,322 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0022_01_000006 is : 143
2015-08-12 17:49:23,454 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0022_01_000005 is : 143
2015-08-12 17:49:24,943 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join/_temporary
2015-08-12 17:49:24,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:33.123, using cpu time: 00:06.180
2015-08-12 17:49:25,033 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoin/join
2015-08-12 17:49:25,130 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:49:25,130 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:49:25,259 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.122
2015-08-12 17:49:25,263 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2015-08-12 17:49:25,263 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:49:25,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-08-12 17:49:25,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 17:49:25,321 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 17:49:25,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:49:25,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs"]
2015-08-12 17:49:25,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs"]
2015-08-12 17:49:25,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  parallel execution of steps is enabled: true
2015-08-12 17:49:25,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  executing total steps: 3
2015-08-12 17:49:25,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  allocating management threads: 3
2015-08-12 17:49:25,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/3)
2015-08-12 17:49:25,609 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439426080426_0023
2015-08-12 17:49:25,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0023/
2015-08-12 17:49:56,782 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0023_01_000002 is : 143
2015-08-12 17:49:57,728 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0023_01_000004 is : 143
2015-08-12 17:49:58,660 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0023_01_000006 is : 143
2015-08-12 17:50:00,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/3) ...stJoinSplitBeforeJoin/lhs
2015-08-12 17:50:00,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (3/3) ...stJoinSplitBeforeJoin/rhs
2015-08-12 17:50:00,294 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439426080426_0024
2015-08-12 17:50:00,294 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0024/
2015-08-12 17:50:00,388 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439426080426_0025
2015-08-12 17:50:00,388 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0025/
2015-08-12 17:50:33,854 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0024_01_000003 is : 143
2015-08-12 17:50:35,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0024_01_000005 is : 143
2015-08-12 17:51:03,837 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0025_01_000006 is : 143
2015-08-12 17:51:04,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0025_01_000002 is : 143
2015-08-12 17:51:13,599 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0025_01_000007 is : 143
2015-08-12 17:51:14,896 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs/_temporary
2015-08-12 17:51:14,899 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs/_temporary
2015-08-12 17:51:14,907 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  completed in: 01:49.572, using cpu time: 00:20.330
2015-08-12 17:51:14,981 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs
2015-08-12 17:51:14,993 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs
2015-08-12 17:51:15,058 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:51:15,060 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:51:15,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2015-08-12 17:51:15,165 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 17:51:15,166 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:51:15,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] starting
2015-08-12 17:51:15,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:51:15,217 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:51:15,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 17:51:15,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:51:15,221 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby"]
2015-08-12 17:51:15,222 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  parallel execution of steps is enabled: true
2015-08-12 17:51:15,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  executing total steps: 1
2015-08-12 17:51:15,225 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  allocating management threads: 1
2015-08-12 17:51:15,228 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] starting step: (1/1) ...oGroupBy/joinsintogroupby
2015-08-12 17:51:15,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] submitted hadoop job: job_1439426080426_0026
2015-08-12 17:51:15,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0026/
2015-08-12 17:51:53,356 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0026_01_000005 is : 143
2015-08-12 17:51:54,266 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0026_01_000004 is : 143
2015-08-12 17:51:54,946 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0026_01_000007 is : 143
2015-08-12 17:51:55,031 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0026_01_000006 is : 143
2015-08-12 17:52:02,225 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0026_01_000008 is : 143
2015-08-12 17:52:03,565 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby/_temporary
2015-08-12 17:52:03,572 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  completed in: 00:48.339, using cpu time: 00:08.450
2015-08-12 17:52:03,667 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby
2015-08-12 17:52:03,711 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:52:03,712 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:52:03,776 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2015-08-12 17:52:03,778 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:52:03,778 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:52:03,789 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 17:52:03,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:52:03,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:52:03,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown"]
2015-08-12 17:52:03,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 17:52:03,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-08-12 17:52:03,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-08-12 17:52:03,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...tJoinWithUnknowns/unknown
2015-08-12 17:52:04,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0027
2015-08-12 17:52:04,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0027/
2015-08-12 17:52:32,268 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0027_01_000003 is : 143
2015-08-12 17:52:34,144 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0027_01_000004 is : 143
2015-08-12 17:52:34,986 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0027_01_000005 is : 143
2015-08-12 17:52:36,378 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown/_temporary
2015-08-12 17:52:36,381 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:32.575, using cpu time: 00:05.900
2015-08-12 17:52:36,483 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown
2015-08-12 17:52:36,569 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:52:36,571 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:52:36,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2015-08-12 17:52:36,678 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:52:36,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:52:36,704 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2015-08-12 17:52:36,705 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:52:36,707 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:52:36,708 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:52:36,713 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost"]
2015-08-12 17:52:36,715 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2015-08-12 17:52:36,717 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  executing total steps: 1
2015-08-12 17:52:36,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  allocating management threads: 1
2015-08-12 17:52:36,720 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/1) ...t/joinaroundjoinrightmost
2015-08-12 17:52:36,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1439426080426_0028
2015-08-12 17:52:36,929 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0028/
2015-08-12 17:53:10,010 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0028_01_000006 is : 143
2015-08-12 17:53:10,836 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0028_01_000003 is : 143
2015-08-12 17:53:13,151 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost/_temporary
2015-08-12 17:53:13,156 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  completed in: 00:36.444, using cpu time: 00:06.040
2015-08-12 17:53:13,242 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost
2015-08-12 17:53:13,300 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:53:13,301 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:53:13,340 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2015-08-12 17:53:13,344 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:53:13,344 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:53:13,361 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 17:53:13,361 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:53:13,361 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:53:13,362 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone"]
2015-08-12 17:53:13,362 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 17:53:13,362 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-08-12 17:53:13,362 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-08-12 17:53:13,365 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2015-08-12 17:53:13,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0029
2015-08-12 17:53:13,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0029/
2015-08-12 17:53:43,594 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0029_01_000002 is : 143
2015-08-12 17:53:44,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0029_01_000003 is : 143
2015-08-12 17:53:48,235 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone/_temporary
2015-08-12 17:53:48,240 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:34.866, using cpu time: 00:06.330
2015-08-12 17:53:48,339 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone
2015-08-12 17:53:48,422 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:53:48,423 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:53:48,477 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2015-08-12 17:53:48,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-08-12 17:53:48,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:53:48,516 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 17:53:48,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:53:48,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:53:48,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself"]
2015-08-12 17:53:48,522 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 17:53:48,524 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 2
2015-08-12 17:53:48,527 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 2
2015-08-12 17:53:48,539 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-08-12 17:53:48,768 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0030
2015-08-12 17:53:48,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0030/
2015-08-12 17:54:16,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0030_01_000006 is : 143
2015-08-12 17:54:19,087 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0030_01_000002 is : 143
2015-08-12 17:54:19,915 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0030_01_000004 is : 143
2015-08-12 17:54:21,433 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...orm/testJoinSelf/joinself
2015-08-12 17:54:21,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0031
2015-08-12 17:54:21,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0031/
2015-08-12 17:54:52,463 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0031_01_000003 is : 143
2015-08-12 17:54:54,473 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself/_temporary
2015-08-12 17:54:54,476 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:05.943, using cpu time: 00:12.040
2015-08-12 17:54:54,574 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself
2015-08-12 17:54:54,641 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:54:54,642 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:54:54,737 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.088
2015-08-12 17:54:54,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-08-12 17:54:54,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:54:54,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-08-12 17:54:54,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 17:54:54,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:54:54,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:54:54,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs"]
2015-08-12 17:54:54,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs"]
2015-08-12 17:54:54,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  parallel execution of steps is enabled: true
2015-08-12 17:54:54,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  executing total steps: 3
2015-08-12 17:54:54,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  allocating management threads: 3
2015-08-12 17:54:54,814 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/3)
2015-08-12 17:54:55,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439426080426_0032
2015-08-12 17:54:55,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0032/
2015-08-12 17:55:21,698 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0032_01_000002 is : 143
2015-08-12 17:55:22,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0032_01_000004 is : 143
2015-08-12 17:55:23,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/3) ...urceJoinSplitIntoJoin/rhs
2015-08-12 17:55:23,755 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (3/3) ...urceJoinSplitIntoJoin/lhs
2015-08-12 17:55:24,030 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439426080426_0033
2015-08-12 17:55:24,030 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0033/
2015-08-12 17:55:24,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439426080426_0034
2015-08-12 17:55:24,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0034/
2015-08-12 17:56:00,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0033_01_000005 is : 143
2015-08-12 17:56:01,652 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0033_01_000004 is : 143
2015-08-12 17:56:19,747 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0034_01_000004 is : 143
2015-08-12 17:56:19,874 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0034_01_000005 is : 143
2015-08-12 17:56:20,382 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0034_01_000003 is : 143
2015-08-12 17:56:21,701 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs/_temporary
2015-08-12 17:56:21,704 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs/_temporary
2015-08-12 17:56:21,709 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  completed in: 01:26.897, using cpu time: 00:15.920
2015-08-12 17:56:21,786 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs
2015-08-12 17:56:21,808 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs
2015-08-12 17:56:21,881 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:56:21,881 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:56:21,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-08-12 17:56:21,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-08-12 17:56:21,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:56:21,969 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting
2015-08-12 17:56:21,970 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:56:21,970 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:56:21,971 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:56:21,972 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped"]
2015-08-12 17:56:21,973 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  parallel execution of steps is enabled: true
2015-08-12 17:56:21,973 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  executing total steps: 2
2015-08-12 17:56:21,973 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  allocating management threads: 2
2015-08-12 17:56:21,976 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting step: (1/2)
2015-08-12 17:56:22,180 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] submitted hadoop job: job_1439426080426_0035
2015-08-12 17:56:22,180 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0035/
2015-08-12 17:56:51,764 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0035_01_000002 is : 143
2015-08-12 17:56:52,619 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0035_01_000003 is : 143
2015-08-12 17:56:54,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0035_01_000005 is : 143
2015-08-12 17:56:55,022 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0035_01_000006 is : 143
2015-08-12 17:56:55,112 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0035_01_000004 is : 143
2015-08-12 17:56:56,480 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting step: (2/2) ...ped/joinaroundjoinswapped
2015-08-12 17:56:56,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] submitted hadoop job: job_1439426080426_0036
2015-08-12 17:56:56,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0036/
2015-08-12 17:57:28,271 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0036_01_000005 is : 143
2015-08-12 17:57:28,791 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0036_01_000003 is : 143
2015-08-12 17:57:28,903 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0036_01_000002 is : 143
2015-08-12 17:57:30,733 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped/_temporary
2015-08-12 17:57:30,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  completed in: 01:08.754, using cpu time: 00:13.660
2015-08-12 17:57:30,816 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped
2015-08-12 17:57:30,889 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:57:30,890 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:57:30,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2015-08-12 17:57:30,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-08-12 17:57:30,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:57:30,993 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 17:57:30,995 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:57:30,996 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:57:30,999 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch"]
2015-08-12 17:57:30,999 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 17:57:30,999 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 2
2015-08-12 17:57:30,999 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 2
2015-08-12 17:57:31,003 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-08-12 17:57:31,270 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0037
2015-08-12 17:57:31,270 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0037/
2015-08-12 17:58:04,549 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0037_01_000004 is : 143
2015-08-12 17:58:05,528 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0037_01_000003 is : 143
2015-08-12 17:58:05,648 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0037_01_000006 is : 143
2015-08-12 17:58:13,297 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0037_01_000007 is : 143
2015-08-12 17:58:14,535 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...Branch/joinfilteredbranch
2015-08-12 17:58:14,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0038
2015-08-12 17:58:14,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0038/
2015-08-12 17:58:42,285 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0038_01_000006 is : 143
2015-08-12 17:58:45,451 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0038_01_000004 is : 143
2015-08-12 17:58:45,899 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0038_01_000003 is : 143
2015-08-12 17:58:46,189 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0038_01_000002 is : 143
2015-08-12 17:58:47,560 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch/_temporary
2015-08-12 17:58:47,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:16.565, using cpu time: 00:13.020
2015-08-12 17:58:47,658 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch
2015-08-12 17:58:47,712 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:58:47,713 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:58:47,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2015-08-12 17:58:47,789 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-08-12 17:58:47,789 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 17:58:47,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2015-08-12 17:58:47,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:58:47,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:58:47,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:58:47,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin"]
2015-08-12 17:58:47,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2015-08-12 17:58:47,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  executing total steps: 3
2015-08-12 17:58:47,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  allocating management threads: 3
2015-08-12 17:58:47,860 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/3)
2015-08-12 17:58:48,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1439426080426_0039
2015-08-12 17:58:48,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0039/
2015-08-12 17:59:17,271 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0039_01_000006 is : 143
2015-08-12 17:59:19,497 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0039_01_000003 is : 143
2015-08-12 17:59:19,881 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0039_01_000004 is : 143
2015-08-12 17:59:20,010 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0039_01_000005 is : 143
2015-08-12 17:59:21,283 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (2/3)
2015-08-12 17:59:21,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1439426080426_0040
2015-08-12 17:59:21,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0040/
2015-08-12 17:59:52,241 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0040_01_000002 is : 143
2015-08-12 17:59:52,975 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0040_01_000003 is : 143
2015-08-12 17:59:53,901 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0040_01_000005 is : 143
2015-08-12 17:59:53,951 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0040_01_000006 is : 143
2015-08-12 17:59:56,485 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (3/3) ...in/joinsamesourceintojoin
2015-08-12 17:59:56,716 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1439426080426_0041
2015-08-12 17:59:56,717 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0041/
2015-08-12 18:00:27,239 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0041_01_000002 is : 143
2015-08-12 18:00:27,311 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0041_01_000004 is : 143
2015-08-12 18:00:29,158 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin/_temporary
2015-08-12 18:00:29,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  completed in: 01:41.314, using cpu time: 00:19.050
2015-08-12 18:00:29,255 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin
2015-08-12 18:00:29,308 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:00:29,310 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:00:29,431 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.114
2015-08-12 18:00:29,433 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 18:00:29,433 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:00:29,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2015-08-12 18:00:29,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 18:00:29,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 18:00:29,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 18:00:29,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 18:00:29,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup"]
2015-08-12 18:00:29,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  parallel execution of steps is enabled: true
2015-08-12 18:00:29,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  executing total steps: 1
2015-08-12 18:00:29,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  allocating management threads: 1
2015-08-12 18:00:29,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/1) ...oCoGroup/joinsintocogroup
2015-08-12 18:00:29,813 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1439426080426_0042
2015-08-12 18:00:29,814 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0042/
2015-08-12 18:01:05,630 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0042_01_000006 is : 143
2015-08-12 18:01:06,886 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0042_01_000007 is : 143
2015-08-12 18:01:07,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0042_01_000004 is : 143
2015-08-12 18:01:16,752 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0042_01_000008 is : 143
2015-08-12 18:01:18,193 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup/_temporary
2015-08-12 18:01:18,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  completed in: 00:48.707, using cpu time: 00:10.030
2015-08-12 18:01:18,274 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup
2015-08-12 18:01:18,365 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:01:18,366 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:01:18,412 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-08-12 18:01:18,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:01:18,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:01:18,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 18:01:18,447 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs-sparse.txt"]
2015-08-12 18:01:18,447 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs-sparse.txt"]
2015-08-12 18:01:18,448 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner"]
2015-08-12 18:01:18,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 18:01:18,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-08-12 18:01:18,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-08-12 18:01:18,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...m/testJoinInner/joininner
2015-08-12 18:01:18,644 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0043
2015-08-12 18:01:18,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0043/
2015-08-12 18:02:04,216 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0043_01_000004 is : 143
2015-08-12 18:02:07,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0043_01_000003 is : 143
2015-08-12 18:02:07,715 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0043_01_000006 is : 143
2015-08-12 18:02:08,129 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0043_01_000002 is : 143
2015-08-12 18:02:09,075 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0043_01_000005 is : 143
2015-08-12 18:02:10,983 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner/_temporary
2015-08-12 18:02:10,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:52.520, using cpu time: 00:11.990
2015-08-12 18:02:11,219 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner
2015-08-12 18:02:11,474 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:02:11,475 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:02:11,587 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.093
2015-08-12 18:02:11,588 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-08-12 18:02:11,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:02:11,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-08-12 18:02:11,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 18:02:11,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 18:02:11,657 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs"]
2015-08-12 18:02:11,659 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs"]
2015-08-12 18:02:11,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  parallel execution of steps is enabled: true
2015-08-12 18:02:11,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  executing total steps: 2
2015-08-12 18:02:11,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  allocating management threads: 2
2015-08-12 18:02:11,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/2) ...latform/testJoinSplit/lhs
2015-08-12 18:02:11,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/2) ...latform/testJoinSplit/rhs
2015-08-12 18:02:12,351 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439426080426_0044
2015-08-12 18:02:12,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0044/
2015-08-12 18:02:12,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1439426080426_0045
2015-08-12 18:02:12,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0045/
2015-08-12 18:03:26,234 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0045_01_000002 is : 143
2015-08-12 18:03:26,611 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0045_01_000005 is : 143
2015-08-12 18:03:28,243 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs/_temporary
2015-08-12 18:03:28,247 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs/_temporary
2015-08-12 18:03:28,252 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  completed in: 01:16.588, using cpu time: 00:14.450
2015-08-12 18:03:28,398 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs
2015-08-12 18:03:28,423 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs
2015-08-12 18:03:28,484 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:03:28,485 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:03:28,544 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-08-12 18:03:28,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-08-12 18:03:28,549 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:03:28,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-08-12 18:03:28,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 18:03:28,572 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby"]
2015-08-12 18:03:28,572 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  parallel execution of steps is enabled: true
2015-08-12 18:03:28,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  executing total steps: 2
2015-08-12 18:03:28,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  allocating management threads: 2
2015-08-12 18:03:28,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/2)
2015-08-12 18:03:28,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1439426080426_0046
2015-08-12 18:03:28,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0046/
2015-08-12 18:04:11,053 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0046_01_000006 is : 143
2015-08-12 18:04:11,336 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0046_01_000005 is : 143
2015-08-12 18:04:11,581 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0046_01_000004 is : 143
2015-08-12 18:04:12,165 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0046_01_000003 is : 143
2015-08-12 18:04:22,181 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (2/2) ...pBy/samepipearoundgroupby
2015-08-12 18:04:22,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1439426080426_0047
2015-08-12 18:04:22,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0047/
2015-08-12 18:04:59,166 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby/_temporary
2015-08-12 18:04:59,171 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  completed in: 01:30.581, using cpu time: 00:15.700
2015-08-12 18:04:59,264 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby
2015-08-12 18:04:59,319 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:04:59,320 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:04:59,447 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.123
2015-08-12 18:04:59,448 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2015-08-12 18:04:59,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:04:59,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting
2015-08-12 18:04:59,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 18:04:59,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 18:04:59,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple"]
2015-08-12 18:04:59,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  parallel execution of steps is enabled: true
2015-08-12 18:04:59,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  executing total steps: 3
2015-08-12 18:04:59,493 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  allocating management threads: 3
2015-08-12 18:04:59,502 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (1/3)
2015-08-12 18:04:59,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (2/3)
2015-08-12 18:05:00,079 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1439426080426_0048
2015-08-12 18:05:00,079 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0048/
2015-08-12 18:05:00,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1439426080426_0049
2015-08-12 18:05:00,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0049/
2015-08-12 18:05:44,513 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0048_01_000005 is : 143
2015-08-12 18:05:45,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0048_01_000004 is : 143
2015-08-12 18:05:45,570 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0048_01_000006 is : 143
2015-08-12 18:06:07,828 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0049_01_000004 is : 143
2015-08-12 18:06:09,299 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0049_01_000003 is : 143
2015-08-12 18:06:12,707 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0049_01_000006 is : 143
2015-08-12 18:06:13,292 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0048_01_000007 is : 143
2015-08-12 18:06:20,491 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0049_01_000007 is : 143
2015-08-12 18:06:21,715 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (3/3) ...overgroupbyintojoinsimple
2015-08-12 18:06:21,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1439426080426_0050
2015-08-12 18:06:21,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0050/
2015-08-12 18:06:37,709 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple/_temporary
2015-08-12 18:06:37,713 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  completed in: 01:38.207, using cpu time: 00:15.810
2015-08-12 18:06:37,782 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple
2015-08-12 18:06:37,880 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:06:37,881 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:06:37,936 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [join-merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.050
2015-08-12 18:06:37,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [join-merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 18:06:37,940 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/testJoinMergeGroupBy/hashjoin
2015-08-12 18:06:37,965 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:06:37,966 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:06:37,990 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-08-12 18:06:37,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:06:37,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:06:38,006 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2015-08-12 18:06:38,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 18:06:38,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2"]
2015-08-12 18:06:38,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  parallel execution of steps is enabled: true
2015-08-12 18:06:38,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  executing total steps: 1
2015-08-12 18:06:38,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  allocating management threads: 1
2015-08-12 18:06:38,009 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...stJoinSamePipe2/samepipe2
2015-08-12 18:06:38,202 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1439426080426_0051
2015-08-12 18:06:38,202 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0051/
2015-08-12 18:07:08,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0051_01_000003 is : 143
2015-08-12 18:07:10,461 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0051_01_000006 is : 143
2015-08-12 18:07:10,709 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0051_01_000005 is : 143
2015-08-12 18:07:12,059 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2/_temporary
2015-08-12 18:07:12,073 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  completed in: 00:34.048, using cpu time: 00:05.540
2015-08-12 18:07:12,166 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2
2015-08-12 18:07:12,215 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:07:12,216 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:07:12,246 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-08-12 18:07:12,249 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:07:12,251 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:07:12,264 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting
2015-08-12 18:07:12,264 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 18:07:12,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3"]
2015-08-12 18:07:12,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  parallel execution of steps is enabled: true
2015-08-12 18:07:12,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  executing total steps: 1
2015-08-12 18:07:12,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  allocating management threads: 1
2015-08-12 18:07:12,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting step: (1/1) ...stJoinSamePipe3/samepipe3
2015-08-12 18:07:12,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] submitted hadoop job: job_1439426080426_0052
2015-08-12 18:07:12,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0052/
2015-08-12 18:07:45,379 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0052_01_000006 is : 143
2015-08-12 18:07:49,922 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0052_01_000003 is : 143
2015-08-12 18:07:50,113 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0052_01_000004 is : 143
2015-08-12 18:07:51,573 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3/_temporary
2015-08-12 18:07:51,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  completed in: 00:39.305, using cpu time: 00:06.970
2015-08-12 18:07:51,728 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3
2015-08-12 18:07:51,800 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:07:51,801 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:07:51,846 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-08-12 18:07:51,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 18:07:51,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:07:51,870 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 18:07:51,871 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 18:07:51,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 18:07:51,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby"]
2015-08-12 18:07:51,876 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 18:07:51,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-08-12 18:07:51,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-08-12 18:07:51,881 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...stJoinGroupBy/joingroupby
2015-08-12 18:07:52,084 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0053
2015-08-12 18:07:52,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0053/
2015-08-12 18:08:25,305 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0053_01_000005 is : 143
2015-08-12 18:08:25,710 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0053_01_000004 is : 143
2015-08-12 18:08:25,813 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0053_01_000003 is : 143
2015-08-12 18:08:33,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0053_01_000007 is : 143
2015-08-12 18:08:35,168 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby/_temporary
2015-08-12 18:08:35,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:43.295, using cpu time: 00:07.440
2015-08-12 18:08:35,255 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby
2015-08-12 18:08:35,328 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:08:35,329 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:08:35,364 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-08-12 18:08:35,369 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:08:35,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:08:35,394 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2015-08-12 18:08:35,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 18:08:35,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe"]
2015-08-12 18:08:35,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  parallel execution of steps is enabled: true
2015-08-12 18:08:35,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  executing total steps: 1
2015-08-12 18:08:35,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  allocating management threads: 1
2015-08-12 18:08:35,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...testJoinSamePipe/samepipe
2015-08-12 18:08:35,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1439426080426_0054
2015-08-12 18:08:35,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0054/
2015-08-12 18:09:08,906 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0054_01_000006 is : 143
2015-08-12 18:09:11,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0054_01_000004 is : 143
2015-08-12 18:09:11,618 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0054_01_000002 is : 143
2015-08-12 18:09:12,966 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe/_temporary
2015-08-12 18:09:12,970 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  completed in: 00:37.569, using cpu time: 00:05.880
2015-08-12 18:09:13,052 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe
2015-08-12 18:09:13,098 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:09:13,100 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:09:13,229 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.122
2015-08-12 18:09:13,239 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2015-08-12 18:09:13,239 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:09:13,321 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting
2015-08-12 18:09:13,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 18:09:13,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink"]
2015-08-12 18:09:13,325 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  parallel execution of steps is enabled: true
2015-08-12 18:09:13,325 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  executing total steps: 4
2015-08-12 18:09:13,327 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  allocating management threads: 4
2015-08-12 18:09:13,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (1/4)
2015-08-12 18:09:13,543 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_1439426080426_0055
2015-08-12 18:09:13,543 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0055/
2015-08-12 18:09:49,141 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0055_01_000005 is : 143
2015-08-12 18:09:49,702 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0055_01_000006 is : 143
2015-08-12 18:09:59,378 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0055_01_000007 is : 143
2015-08-12 18:10:00,678 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (2/4)
2015-08-12 18:10:00,882 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_1439426080426_0056
2015-08-12 18:10:00,883 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0056/
2015-08-12 18:10:17,348 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0056_01_000002 is : 143
2015-08-12 18:10:27,760 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0056_01_000003 is : 143
2015-08-12 18:10:29,233 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (3/4)
2015-08-12 18:10:29,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_1439426080426_0057
2015-08-12 18:10:29,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0057/
2015-08-12 18:10:45,526 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0057_01_000002 is : 143
2015-08-12 18:10:56,457 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0057_01_000003 is : 143
2015-08-12 18:10:57,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (4/4) ...upBySplitGroupByJoin/sink
2015-08-12 18:10:57,941 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_1439426080426_0058
2015-08-12 18:10:57,941 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0058/
2015-08-12 18:11:13,753 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0058_01_000002 is : 143
2015-08-12 18:11:15,159 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink/_temporary
2015-08-12 18:11:15,164 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  completed in: 02:01.830, using cpu time: 00:14.470
2015-08-12 18:11:15,221 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink
2015-08-12 18:11:15,267 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:11:15,268 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:11:15,309 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-08-12 18:11:15,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:11:15,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:11:15,328 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 18:11:15,328 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs-sparse.txt"]
2015-08-12 18:11:15,329 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs-sparse.txt"]
2015-08-12 18:11:15,329 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter"]
2015-08-12 18:11:15,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 18:11:15,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-08-12 18:11:15,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-08-12 18:11:15,333 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...InnerOuter/joininnerouter
2015-08-12 18:11:15,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0059
2015-08-12 18:11:15,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0059/
2015-08-12 18:11:47,981 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0059_01_000003 is : 143
2015-08-12 18:11:48,926 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0059_01_000004 is : 143
2015-08-12 18:11:50,182 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0059_01_000005 is : 143
2015-08-12 18:11:51,542 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter/_temporary
2015-08-12 18:11:51,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:36.209, using cpu time: 00:06.020
2015-08-12 18:11:51,647 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter
2015-08-12 18:11:51,711 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 18:11:51,713 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 18:11:51,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-08-12 18:11:51,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 18:11:51,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 18:11:51,778 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 18:11:51,779 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 18:11:51,779 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 18:11:51,789 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields"]
2015-08-12 18:11:51,791 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-08-12 18:11:51,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-08-12 18:11:51,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-08-12 18:11:51,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...JoinDiffFields/difffields
2015-08-12 18:11:52,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1439426080426_0060
2015-08-12 18:11:52,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://node1.bidemo.com:46123/proxy/application_1439426080426_0060/
2015-08-12 18:12:24,502 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0060_01_000003 is : 143
2015-08-12 18:12:25,479 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0060_01_000006 is : 143
2015-08-12 18:12:25,649 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0060_01_000004 is : 143
2015-08-12 18:12:26,560 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439426080426_0060_01_000005 is : 143
2015-08-12 18:12:27,847 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields/_temporary
2015-08-12 18:12:27,852 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:36.066, using cpu time: 00:07.300
2015-08-12 18:12:27,943 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields

Standard error

Aug 12, 2015 5:34:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Aug 12, 2015 5:34:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 5:34:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 5:34:41 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 5:34:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:41 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:42 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Aug 12, 2015 5:34:42 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 5:34:42 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 5:34:43 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 5:34:43 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Aug 12, 2015 5:34:43 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 5:34:43 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 5:34:43 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:43 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:43 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:43 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 5:34:44 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Aug 12, 2015 5:34:44 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 5:34:44 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 5:34:44 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 5:34:44 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:44 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:44 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:44 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 5:34:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Aug 12, 2015 5:34:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 5:34:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 5:34:45 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 5:34:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 5:34:45 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.