See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/733/display/redirect?page=changes>
Changes:
[kirpichov] Removed some dead code, fixed some warnings
[kirpichov] Adds tracing of watermarks in direct runner
[kirpichov] Fixes typo in class name
[kirpichov] Simplifies GBK expansion code a bit
[kirpichov] Fixes bug: Processes values arriving for a GBK key sequentially
[kirpichov] Introduces BundleProgressHandler.
[kirpichov] [BEAM-4473,BEAM-4281] Makes ReferenceRunner use a Direct stream
observer
------------------------------------------
[...truncated 27.70 MB...]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@380de98eidentifier=tcp://localhost:36057/71.output.115,
upstream=71.output.115, group=stream137/114.sideInput1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7a07e408{da=com.datatorrent.bufferserver.internal.DataList$Block@26e31505{identifier=71.output.115,
data=1048576, readingOffset=0, writingOffset=120,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@707e6821[identifier=71.output.115]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-68 msg: [container-68] Exiting heartbeat loop..
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@64b429ccidentifier=tcp://localhost:36057/67.output.68,
upstream=67.output.68, group=stream44/68.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3122fa47{da=com.datatorrent.bufferserver.internal.DataList$Block@74c06fcf{identifier=67.output.68,
data=1048576, readingOffset=0, writingOffset=120,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@4a35176f[identifier=67.output.68]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-8 terminating.
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-68 terminating.
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-24 terminating.
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-34 terminating.
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-35 terminating.
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-33 terminating.
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-2 terminating.
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@22e10d4didentifier=tcp://localhost:36057/42.out.43,
upstream=42.out.43, group=stream12/43.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@49895168{da=com.datatorrent.bufferserver.internal.DataList$Block@6fdf6adc{identifier=42.out.43,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@1816deff[identifier=42.out.43]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-16 terminating.
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-15 terminating.
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@18aa44e8identifier=tcp://localhost:36057/21.output.22,
upstream=21.output.22, group=stream75/22.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7afa2cfd{da=com.datatorrent.bufferserver.internal.DataList$Block@79fb20db{identifier=21.output.22,
data=1048576, readingOffset=0, writingOffset=1988,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@6d663cb2[identifier=21.output.22]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-56 terminating.
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@28a62da9identifier=tcp://localhost:36057/13.out.12,
upstream=13.out.12, group=stream81/14.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@43a9e6c7{da=com.datatorrent.bufferserver.internal.DataList$Block@681fa78b{identifier=13.out.12,
data=1048576, readingOffset=0, writingOffset=4690,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@48c2bfab[identifier=13.out.12]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-38 terminating.
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@4b2aeb5didentifier=tcp://localhost:36057/104.output.105,
upstream=104.output.105, group=stream124/105.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@149d89ad{da=com.datatorrent.bufferserver.internal.DataList$Block@188eca27{identifier=104.output.105,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@db80542[identifier=104.output.105]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-53 terminating.
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@6a7ca522identifier=tcp://localhost:36057/112.output.113,
upstream=112.output.113, group=stream130/113.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@505accb9{da=com.datatorrent.bufferserver.internal.DataList$Block@2872f7fe{identifier=112.output.113,
data=1048576, readingOffset=0, writingOffset=73,
starting_window=5b23132d00000001, ending_window=5b23132d00000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@4643cf25[identifier=112.output.113]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-30 terminating.
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@29faf677identifier=tcp://localhost:36057/18.out.18,
upstream=18.out.18, group=stream37/19.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@b9c40ba{da=com.datatorrent.bufferserver.internal.DataList$Block@d257a74{identifier=18.out.18,
data=1048576, readingOffset=0, writingOffset=4684,
starting_window=5b23132d00000001, ending_window=5b23132d0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@32d7a129[identifier=18.out.18]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-29 terminating.
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@6f0291eaidentifier=tcp://localhost:36057/136.output.137,
upstream=136.output.137, group=stream43/137.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6ab56ab1{da=com.datatorrent.bufferserver.internal.DataList$Block@3c57ecd{identifier=136.output.137,
data=1048576, readingOffset=0, writingOffset=73,
starting_window=5b23132d00000001, ending_window=5b23132d00000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2595521b[identifier=136.output.137]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-62 terminating.
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@21c6dbe1identifier=tcp://localhost:36057/14.out.14,
upstream=14.out.14, group=stream99/15.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2a447169{da=com.datatorrent.bufferserver.internal.DataList$Block@6be56672{identifier=14.out.14,
data=1048576, readingOffset=0, writingOffset=9162,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@43fe5ed5[identifier=14.out.14]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-21 terminating.
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-31 msg: [container-31] Exiting heartbeat loop..
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@5edc9f97identifier=tcp://localhost:36057/16.output.15,
upstream=16.output.15, group=stream9/18.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4cf4c93b{da=com.datatorrent.bufferserver.internal.DataList$Block@45b226f5{identifier=16.output.15,
data=1048576, readingOffset=0, writingOffset=2378,
starting_window=5b23132d00000001, ending_window=5b23132d00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@5a40ec7[identifier=16.output.15]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@2a100363identifier=tcp://localhost:36057/59.outputPort.60,
upstream=59.outputPort.60, group=stream83/60.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@349de050{da=com.datatorrent.bufferserver.internal.DataList$Block@5e4a5ae9{identifier=59.outputPort.60,
data=1048576, readingOffset=0, writingOffset=126,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@a1b4a5b[identifier=59.outputPort.60]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@7913884didentifier=tcp://localhost:36057/81.output.83,
upstream=81.output.83, group=stream66/82.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2f6cafe9{da=com.datatorrent.bufferserver.internal.DataList$Block@74a84534{identifier=81.output.83,
data=1048576, readingOffset=0, writingOffset=108,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@78b9d45a[identifier=81.output.83]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@56149921identifier=tcp://localhost:36057/119.outputPort.121,
upstream=119.outputPort.121, group=stream36/120.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@28200084{da=com.datatorrent.bufferserver.internal.DataList$Block@62f9e18e{identifier=119.outputPort.121,
data=1048576, readingOffset=0, writingOffset=126,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@54ce8900[identifier=119.outputPort.121]
Jun 15, 2018 1:15:30 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-31 terminating.
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@18db3d1didentifier=tcp://localhost:36057/96.output.98,
upstream=96.output.98, group=stream101/97.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@62638cc7{da=com.datatorrent.bufferserver.internal.DataList$Block@4aef842f{identifier=96.output.98,
data=1048576, readingOffset=0, writingOffset=120,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@67b7f96d[identifier=96.output.98]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@5e64dce4identifier=tcp://localhost:36057/5.output.4,
upstream=5.output.4, group=stream143/6.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4791fa12{da=com.datatorrent.bufferserver.internal.DataList$Block@39ea5393{identifier=5.output.4,
data=1048576, readingOffset=0, writingOffset=2384,
starting_window=5b23132d00000001, ending_window=5b23132d0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@f92767d[identifier=5.output.4]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@3276c5aidentifier=tcp://localhost:36057/60.output.61,
upstream=60.output.61, group=stream51/61.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@57369a73{da=com.datatorrent.bufferserver.internal.DataList$Block@1f3fabed{identifier=60.output.61,
data=1048576, readingOffset=0, writingOffset=130,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@74a20552[identifier=60.output.61]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@5672f0beidentifier=tcp://localhost:36057/32.output.32,
upstream=32.output.32, group=stream65/33.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@681fb425{da=com.datatorrent.bufferserver.internal.DataList$Block@b994e57{identifier=32.output.32,
data=1048576, readingOffset=0, writingOffset=1991,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@699bfc0a[identifier=32.output.32]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@651a0b44identifier=tcp://localhost:36057/66.output.67,
upstream=66.output.67, group=stream131/67.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@d77fcfe{da=com.datatorrent.bufferserver.internal.DataList$Block@18dccfe9{identifier=66.output.67,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@5976c153[identifier=66.output.67]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@491d5e9fidentifier=tcp://localhost:36057/28.output.28,
upstream=28.output.28, group=stream34/29.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6f3b0ddb{da=com.datatorrent.bufferserver.internal.DataList$Block@5d998cce{identifier=28.output.28,
data=1048576, readingOffset=0, writingOffset=26962,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2344b313[identifier=28.output.28]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@53dbbbdeidentifier=tcp://localhost:36057/26.output.82,
upstream=26.output.82, group=stream68/81.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4c578271{da=com.datatorrent.bufferserver.internal.DataList$Block@7b351bf5{identifier=26.output.82,
data=1048576, readingOffset=0, writingOffset=72,
starting_window=5b23132d00000001, ending_window=5b23132d00000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@6adb07a1[identifier=26.output.82]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@64afddd2identifier=tcp://localhost:36057/12.output.10,
upstream=12.output.10, group=stream84/13.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6c81edc2{da=com.datatorrent.bufferserver.internal.DataList$Block@1cb5ae29{identifier=12.output.10,
data=1048576, readingOffset=0, writingOffset=2390,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@4f0cf4f9[identifier=12.output.10]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@73869c52identifier=tcp://localhost:36057/3.out.5, upstream=3.out.5,
group=stream97/7.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7dd814b6{da=com.datatorrent.bufferserver.internal.DataList$Block@1e540932{identifier=3.out.5,
data=1048576, readingOffset=0, writingOffset=4690,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2f212837[identifier=3.out.5]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@63aa7bc7identifier=tcp://localhost:36057/72.output.72,
upstream=72.output.72, group=stream112/73.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7a2aa16{da=com.datatorrent.bufferserver.internal.DataList$Block@3a6263f0{identifier=72.output.72,
data=1048576, readingOffset=0, writingOffset=22962,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@4c1e017[identifier=72.output.72]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@33fd1032identifier=tcp://localhost:36057/9.output.8,
upstream=9.output.8, group=stream95/10.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@22070028{da=com.datatorrent.bufferserver.internal.DataList$Block@3067ec64{identifier=9.output.8,
data=1048576, readingOffset=0, writingOffset=2356,
starting_window=5b23132d00000001, ending_window=5b23132d0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@1933647b[identifier=9.output.8]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@79e6c20didentifier=tcp://localhost:36057/50.output.53,
upstream=50.output.53, group=stream0/54.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1279ee12{da=com.datatorrent.bufferserver.internal.DataList$Block@865aa35{identifier=50.output.53,
data=1048576, readingOffset=0, writingOffset=72,
starting_window=5b23132d00000001, ending_window=5b23132d00000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@7ee6391[identifier=50.output.53]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@3ca372d2identifier=tcp://localhost:36057/37.output.38,
upstream=37.output.38, group=stream146/38.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5fcdfab{da=com.datatorrent.bufferserver.internal.DataList$Block@5828b878{identifier=37.output.38,
data=1048576, readingOffset=0, writingOffset=120,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@7d39854a[identifier=37.output.38]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@359f4c94identifier=tcp://localhost:36057/31.output.31,
upstream=31.output.31, group=stream140/32.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@93f9397{da=com.datatorrent.bufferserver.internal.DataList$Block@6a5d049c{identifier=31.output.31,
data=1048576, readingOffset=0, writingOffset=22965,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@77ab8ad7[identifier=31.output.31]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@49b59046identifier=tcp://localhost:36057/133.output.144,
upstream=133.output.144, group=stream5/144.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@460952bd{da=com.datatorrent.bufferserver.internal.DataList$Block@33dfd2c0{identifier=133.output.144,
data=1048576, readingOffset=0, writingOffset=119,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@31a449c3[identifier=133.output.144]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@64459851identifier=tcp://localhost:36057/82.out.84,
upstream=82.out.84, group=stream133/83.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1af28012{da=com.datatorrent.bufferserver.internal.DataList$Block@1662b54b{identifier=82.out.84,
data=1048576, readingOffset=0, writingOffset=115,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@5be63c95[identifier=82.out.84]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1236f29fidentifier=tcp://localhost:36057/46.outputPort.47,
upstream=46.outputPort.47, group=stream57/47.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@481f8c7b{da=com.datatorrent.bufferserver.internal.DataList$Block@46e3677a{identifier=46.outputPort.47,
data=1048576, readingOffset=0, writingOffset=126,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@45a84a00[identifier=46.outputPort.47]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@20f3f71identifier=tcp://localhost:36057/47.output.48,
upstream=47.output.48, group=stream40/48.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2fc0c4b4{da=com.datatorrent.bufferserver.internal.DataList$Block@1b08f963{identifier=47.output.48,
data=1048576, readingOffset=0, writingOffset=130,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@468d95cf[identifier=47.output.48]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@5de49d83identifier=tcp://localhost:36057/140.output.140,
upstream=140.output.140, group=stream91/141.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@41f22f54{da=com.datatorrent.bufferserver.internal.DataList$Block@68beb6ba{identifier=140.output.140,
data=1048576, readingOffset=0, writingOffset=73,
starting_window=5b23132d00000001, ending_window=5b23132d00000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@3421992f[identifier=140.output.140]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1b70f158identifier=tcp://localhost:36057/4.output.3,
upstream=4.output.3, group=stream56/6.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1e285189{da=com.datatorrent.bufferserver.internal.DataList$Block@4ef05597{identifier=4.output.3,
data=1048576, readingOffset=0, writingOffset=2384,
starting_window=5b23132d00000001, ending_window=5b23132d0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@53663195[identifier=4.output.3]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@5cabf77eidentifier=tcp://localhost:36057/99.output.99,
upstream=99.output.99, group=stream113/100.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6bb62237{da=com.datatorrent.bufferserver.internal.DataList$Block@374e82d1{identifier=99.output.99,
data=1048576, readingOffset=0, writingOffset=22962,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@7bde2542[identifier=99.output.99]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1ffed830identifier=tcp://localhost:36057/95.output.97,
upstream=95.output.97, group=stream78/96.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@19d65935{da=com.datatorrent.bufferserver.internal.DataList$Block@432b77a2{identifier=95.output.97,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@b03d1c[identifier=95.output.97]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@35632775identifier=tcp://localhost:36057/111.out.117,
upstream=111.out.117, group=stream129/116.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@acefc7d{da=com.datatorrent.bufferserver.internal.DataList$Block@21fa03e0{identifier=111.out.117,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@39f4e61a[identifier=111.out.117]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1505eb0fidentifier=tcp://localhost:36057/6.out.6, upstream=6.out.6,
group=stream117/7.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@382d64e5{da=com.datatorrent.bufferserver.internal.DataList$Block@45fd4a89{identifier=6.out.6,
data=1048576, readingOffset=0, writingOffset=4684,
starting_window=5b23132d00000001, ending_window=5b23132d0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@3469a4d5[identifier=6.out.6]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@8c18b5cidentifier=tcp://localhost:36057/102.output.102,
upstream=102.output.102, group=stream17/103.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2a335074{da=com.datatorrent.bufferserver.internal.DataList$Block@79ea039b{identifier=102.output.102,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@56eca72d[identifier=102.output.102]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1947af76identifier=tcp://localhost:36057/102.output.103,
upstream=102.output.103, group=stream17/111.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2fdafe29{da=com.datatorrent.bufferserver.internal.DataList$Block@1f5aab56{identifier=102.output.103,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@368595fd[identifier=102.output.103]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@109b847cidentifier=tcp://localhost:36057/11.output.9,
upstream=11.output.9, group=stream71/13.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5e399cf{da=com.datatorrent.bufferserver.internal.DataList$Block@7db004ec{identifier=11.output.9,
data=1048576, readingOffset=0, writingOffset=2384,
starting_window=5b23132d00000001, ending_window=5b23132d0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@37fa1017[identifier=11.output.9]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@580bf830identifier=tcp://localhost:36057/100.output.100,
upstream=100.output.100, group=stream10/101.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2d4a4168{da=com.datatorrent.bufferserver.internal.DataList$Block@347e98ef{identifier=100.output.100,
data=1048576, readingOffset=0, writingOffset=1988,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@49147de8[identifier=100.output.100]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1102f85didentifier=tcp://localhost:36057/7.out.13,
upstream=7.out.13, group=stream61/15.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2e89a675{da=com.datatorrent.bufferserver.internal.DataList$Block@5137f3cd{identifier=7.out.13,
data=1048576, readingOffset=0, writingOffset=9290,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@11cea0e4[identifier=7.out.13]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@55e5b61aidentifier=tcp://localhost:36057/25.output.50,
upstream=25.output.50, group=stream73/51.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7bdf6408{da=com.datatorrent.bufferserver.internal.DataList$Block@1886cf08{identifier=25.output.50,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@76c1fe4e[identifier=25.output.50]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@2b0093a3identifier=tcp://localhost:36057/2.output.2,
upstream=2.output.2, group=stream80/3.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@126ca9f2{da=com.datatorrent.bufferserver.internal.DataList$Block@12936093{identifier=2.output.2,
data=1048576, readingOffset=0, writingOffset=2384,
starting_window=5b23132d00000001, ending_window=5b23132d0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@3c430346[identifier=2.output.2]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@4333f550identifier=tcp://localhost:36057/54.output.55,
upstream=54.output.55, group=stream62/55.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4589a90e{da=com.datatorrent.bufferserver.internal.DataList$Block@325dbb74{identifier=54.output.55,
data=1048576, readingOffset=0, writingOffset=108,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@3bc3c254[identifier=54.output.55]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@4e34e5abidentifier=tcp://localhost:36057/1.output.1,
upstream=1.output.1, group=stream3/3.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1f3ebf59{da=com.datatorrent.bufferserver.internal.DataList$Block@17f7a469{identifier=1.output.1,
data=1048576, readingOffset=0, writingOffset=2390,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@482e3bf8[identifier=1.output.1]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1a1b6561identifier=tcp://localhost:36057/139.output.143,
upstream=139.output.143, group=stream6/143.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6d5a81cb{da=com.datatorrent.bufferserver.internal.DataList$Block@7742f4e{identifier=139.output.143,
data=1048576, readingOffset=0, writingOffset=73,
starting_window=5b23132d00000001, ending_window=5b23132d00000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2d0a1725[identifier=139.output.143]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@5aba86bbidentifier=tcp://localhost:36057/19.out.19,
upstream=19.out.19, group=stream121/99.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@14c20887{da=com.datatorrent.bufferserver.internal.DataList$Block@2daf970d{identifier=19.out.19,
data=1048576, readingOffset=0, writingOffset=22962,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@b07d3a9[identifier=19.out.19]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@201b8778identifier=tcp://localhost:36057/19.out.20,
upstream=19.out.20, group=stream121/27.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@76495ed3{da=com.datatorrent.bufferserver.internal.DataList$Block@724bf6ad{identifier=19.out.20,
data=1048576, readingOffset=0, writingOffset=22962,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@238d1016[identifier=19.out.20]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@7572436aidentifier=tcp://localhost:36057/19.out.153,
upstream=19.out.153, group=stream121/20.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@16220555{da=com.datatorrent.bufferserver.internal.DataList$Block@2a216e84{identifier=19.out.153,
data=1048576, readingOffset=0, writingOffset=22962,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@7f20bf3[identifier=19.out.153]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@29179f14identifier=tcp://localhost:36057/19.out.154,
upstream=19.out.154, group=stream121/72.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4c34a6bb{da=com.datatorrent.bufferserver.internal.DataList$Block@4aba1ac5{identifier=19.out.154,
data=1048576, readingOffset=0, writingOffset=22962,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@6bce0858[identifier=19.out.154]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@42d63132identifier=tcp://localhost:36057/120.output.122,
upstream=120.output.122, group=stream52/121.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7cf43b41{da=com.datatorrent.bufferserver.internal.DataList$Block@159c5b1a{identifier=120.output.122,
data=1048576, readingOffset=0, writingOffset=130,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@f6a175e[identifier=120.output.122]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@95b5152identifier=tcp://localhost:36057/15.out.17,
upstream=15.out.17, group=stream14/19.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@14fd5223{da=com.datatorrent.bufferserver.internal.DataList$Block@498e4dce{identifier=15.out.17,
data=1048576, readingOffset=0, writingOffset=18362,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@3ebd8b6e[identifier=15.out.17]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@bcd269eidentifier=tcp://localhost:36057/17.output.16,
upstream=17.output.16, group=stream139/18.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6132bb00{da=com.datatorrent.bufferserver.internal.DataList$Block@1fa0914f{identifier=17.output.16,
data=1048576, readingOffset=0, writingOffset=2384,
starting_window=5b23132d00000001, ending_window=5b23132d0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@247b5f48[identifier=17.output.16]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@69071436identifier=tcp://localhost:36057/55.out.56,
upstream=55.out.56, group=stream88/56.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@764f5652{da=com.datatorrent.bufferserver.internal.DataList$Block@2510920{identifier=55.out.56,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@19e0dacc[identifier=55.out.56]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@7c70c156identifier=tcp://localhost:36057/77.output.78,
upstream=77.output.78, group=stream109/78.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@671f47a7{da=com.datatorrent.bufferserver.internal.DataList$Block@6bee70d0{identifier=77.output.78,
data=1048576, readingOffset=0, writingOffset=115,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@61fc6c84[identifier=77.output.78]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@5ec22d40identifier=tcp://localhost:36057/73.output.73,
upstream=73.output.73, group=stream108/74.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7ed5eccd{da=com.datatorrent.bufferserver.internal.DataList$Block@636abecf{identifier=73.output.73,
data=1048576, readingOffset=0, writingOffset=1988,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@7b1a3a82[identifier=73.output.73]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@39efcd92identifier=tcp://localhost:36057/8.output.7,
upstream=8.output.7, group=stream53/10.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7900f129{da=com.datatorrent.bufferserver.internal.DataList$Block@2862c940{identifier=8.output.7,
data=1048576, readingOffset=0, writingOffset=2290,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@1e488645[identifier=8.output.7]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@39457711identifier=tcp://localhost:36057/23.output.24,
upstream=23.output.24, group=stream92/24.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@34ac6124{da=com.datatorrent.bufferserver.internal.DataList$Block@4a5b5721{identifier=23.output.24,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@74cdbfe3[identifier=23.output.24]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@69cc6b91identifier=tcp://localhost:36057/23.output.25,
upstream=23.output.25, group=stream92/55.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2eed7591{da=com.datatorrent.bufferserver.internal.DataList$Block@791f8429{identifier=23.output.25,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@696d2674[identifier=23.output.25]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1bd545fdidentifier=tcp://localhost:36057/105.output.106,
upstream=105.output.106, group=stream30/106.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@70c6be1d{da=com.datatorrent.bufferserver.internal.DataList$Block@35421c69{identifier=105.output.106,
data=1048576, readingOffset=0, writingOffset=120,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@3079e824[identifier=105.output.106]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@2699ef7identifier=tcp://localhost:36057/51.output.51,
upstream=51.output.51, group=stream96/52.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@302736d9{da=com.datatorrent.bufferserver.internal.DataList$Block@75d45096{identifier=51.output.51,
data=1048576, readingOffset=0, writingOffset=120,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@5050bb11[identifier=51.output.51]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@45c2cd61identifier=tcp://localhost:36057/132.output.134,
upstream=132.output.134, group=stream41/133.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2f9751f7{da=com.datatorrent.bufferserver.internal.DataList$Block@260f3b22{identifier=132.output.134,
data=1048576, readingOffset=0, writingOffset=115,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@71088f95[identifier=132.output.134]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@389f0dd7identifier=tcp://localhost:36057/98.output.108,
upstream=98.output.108, group=stream67/108.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@24d53a96{da=com.datatorrent.bufferserver.internal.DataList$Block@3158cf12{identifier=98.output.108,
data=1048576, readingOffset=0, writingOffset=72,
starting_window=5b23132d00000001, ending_window=5b23132d00000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@6ed12430[identifier=98.output.108]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@150843dbidentifier=tcp://localhost:36057/41.output.42,
upstream=41.output.42, group=stream7/42.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5b906a58{da=com.datatorrent.bufferserver.internal.DataList$Block@561cfa36{identifier=41.output.42,
data=1048576, readingOffset=0, writingOffset=108,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@214b8fb8[identifier=41.output.42]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@7fd2ed72identifier=tcp://localhost:36057/87.output.89,
upstream=87.output.89, group=stream100/88.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@46dcdf05{da=com.datatorrent.bufferserver.internal.DataList$Block@1e46bf2c{identifier=87.output.89,
data=1048576, readingOffset=0, writingOffset=129,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2f3a3b98[identifier=87.output.89]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@55df0e38identifier=tcp://localhost:36057/10.out.11,
upstream=10.out.11, group=stream29/14.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@52715788{da=com.datatorrent.bufferserver.internal.DataList$Block@72f59e34{identifier=10.out.11,
data=1048576, readingOffset=0, writingOffset=4562,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@5961f099[identifier=10.out.11]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@75d4a1beidentifier=tcp://localhost:36057/40.output.41,
upstream=40.output.41, group=stream125/41.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@27f9e6d6{da=com.datatorrent.bufferserver.internal.DataList$Block@7f6c38b6{identifier=40.output.41,
data=1048576, readingOffset=0, writingOffset=72,
starting_window=5b23132d00000001, ending_window=5b23132d00000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@21b60d51[identifier=40.output.41]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@369b262aidentifier=tcp://localhost:36057/78.output.79,
upstream=78.output.79, group=stream132/79.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7705c4c6{da=com.datatorrent.bufferserver.internal.DataList$Block@1f2243a6{identifier=78.output.79,
data=1048576, readingOffset=0, writingOffset=119,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@195617c[identifier=78.output.79]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@ed9818bidentifier=tcp://localhost:36057/75.output.75,
upstream=75.output.75, group=stream135/76.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1058389a{da=com.datatorrent.bufferserver.internal.DataList$Block@49a2eda3{identifier=75.output.75,
data=1048576, readingOffset=0, writingOffset=115,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@4490b842[identifier=75.output.75]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@3a7977eaidentifier=tcp://localhost:36057/75.output.76,
upstream=75.output.76, group=stream135/82.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6ea4bf2d{da=com.datatorrent.bufferserver.internal.DataList$Block@3fe9c68b{identifier=75.output.76,
data=1048576, readingOffset=0, writingOffset=115,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@61f8eb20[identifier=75.output.76]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@e0cac48identifier=tcp://localhost:36057/34.output.35,
upstream=34.output.35, group=stream58/42.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@20eb1df5{da=com.datatorrent.bufferserver.internal.DataList$Block@6bfd9312{identifier=34.output.35,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@1ad1dd78[identifier=34.output.35]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@662535f7identifier=tcp://localhost:36057/34.output.34,
upstream=34.output.34, group=stream58/35.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3cd684e9{da=com.datatorrent.bufferserver.internal.DataList$Block@44aa3233{identifier=34.output.34,
data=1048576, readingOffset=0, writingOffset=116,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@43485cb7[identifier=34.output.34]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@61e9dc80identifier=tcp://localhost:36057/27.output.27,
upstream=27.output.27, group=stream103/28.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@576663bb{da=com.datatorrent.bufferserver.internal.DataList$Block@5f1f4472{identifier=27.output.27,
data=1048576, readingOffset=0, writingOffset=22962,
starting_window=5b23132d00000001, ending_window=5b23132d0000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@4a31de08[identifier=27.output.27]
Jun 15, 2018 1:15:30 AM com.datatorrent.bufferserver.server.Server$1 run
INFO: Server stopped listening at /0:0:0:0:0:0:0:0:36057
Jun 15, 2018 1:15:30 AM com.datatorrent.stram.StramLocalCluster run
INFO: Application finished.
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: UniqueCount/Flatten.PCollections.out:
org/hamcrest/Matchers
at
org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at
org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:66)
at
org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-apex:validatesRunnerBatch FAILED
198 tests completed, 112 failed, 1 skipped
Finished generating test XML results (0.299 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/ws/src/runners/apex/build/test-results/validatesRunnerBatch>
Generating HTML test report...
Finished generating test html results (0.255 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/ws/src/runners/apex/build/reports/tests/validatesRunnerBatch>
:beam-runners-apex:validatesRunnerBatch (Thread[Task worker for ':' Thread
8,5,main]) completed. Took 28 mins 2.391 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-apex:validatesRunnerBatch'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/ws/src/runners/apex/build/reports/tests/validatesRunnerBatch/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
See
https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 28m 54s
32 actionable tasks: 28 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/nga54vam6iazm
Build cache (/home/jenkins/.gradle/caches/build-cache-1) remove files older
than Fri Jun 08 00:46:40 UTC 2018.
Build cache (/home/jenkins/.gradle/caches/build-cache-1) removing 757 cache
entries (134 MB reclaimed).
Build cache (/home/jenkins/.gradle/caches/build-cache-1) cleaned up in 0.071
secs.
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Recording test results
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user
[email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
