See 
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/727/display/redirect?page=changes>

Changes:

[apilloud] [SQL] Make getString more generic

[apilloud] [SQL] Support unquoted table types

[aaltay] [BEAM-4333] Add integration tests for python mobile games (#5630)

------------------------------------------
[...truncated 27.66 MB...]
    Jun 14, 2018 6:36:33 PM com.datatorrent.stram.engine.StreamingContainer 
processHeartbeatResponse
    INFO: Received shutdown request type ABORT
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
    INFO: container-19 msg: [container-19] Exiting heartbeat loop..
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
    INFO: container-48 msg: [container-48] Exiting heartbeat loop..
    Jun 14, 2018 6:36:33 PM com.datatorrent.stram.engine.StreamingContainer 
processHeartbeatResponse
    INFO: Received shutdown request type ABORT
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-19 terminating.
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-56 terminating.
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
    INFO: container-52 msg: [container-52] Exiting heartbeat loop..
    Jun 14, 2018 6:36:33 PM com.datatorrent.stram.engine.StreamingContainer 
processHeartbeatResponse
    INFO: Received shutdown request type ABORT
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-52 terminating.
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-48 terminating.
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
    INFO: container-41 msg: [container-41] Exiting heartbeat loop..
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@80780dbidentifier=tcp://localhost:41333/67.output.68, 
upstream=67.output.68, group=stream81/68.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@268f15a1{da=com.datatorrent.bufferserver.internal.DataList$Block@17f1b4d1{identifier=67.output.68,
 data=1048576, readingOffset=0, writingOffset=108, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@2fdde22b[identifier=67.output.68]
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
    INFO: container-11 msg: [container-11] Exiting heartbeat loop..
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@71d36447identifier=tcp://localhost:41333/99.output.99, 
upstream=99.output.99, group=stream9/100.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7d20af6f{da=com.datatorrent.bufferserver.internal.DataList$Block@23dc9f77{identifier=99.output.99,
 data=1048576, readingOffset=0, writingOffset=22950, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@3991e0e1[identifier=99.output.99]
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-41 terminating.
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@3d02ae7eidentifier=tcp://localhost:41333/112.output.113, 
upstream=112.output.113, group=stream15/113.inputPort, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@791d8142{da=com.datatorrent.bufferserver.internal.DataList$Block@13e12d9{identifier=112.output.113,
 data=1048576, readingOffset=0, writingOffset=73, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000002, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@465e02ae[identifier=112.output.113]
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-11 terminating.
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@7b0a7396identifier=tcp://localhost:41333/27.output.40, 
upstream=27.output.40, group=stream6/41.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@70fe646c{da=com.datatorrent.bufferserver.internal.DataList$Block@65fcfca0{identifier=27.output.40,
 data=1048576, readingOffset=0, writingOffset=72, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000002, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1425921c[identifier=27.output.40]
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-12 terminating.
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@37d2e7e1identifier=tcp://localhost:41333/21.output.22, 
upstream=21.output.22, group=stream120/22.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2258b944{da=com.datatorrent.bufferserver.internal.DataList$Block@21867467{identifier=21.output.22,
 data=1048576, readingOffset=0, writingOffset=1976, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@239d850b[identifier=21.output.22]
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-49 terminating.
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@7c1fb00bidentifier=tcp://localhost:41333/33.output.32, 
upstream=33.output.32, group=stream62/34.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1b905616{da=com.datatorrent.bufferserver.internal.DataList$Block@7c655eb9{identifier=33.output.32,
 data=1048576, readingOffset=0, writingOffset=1979, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6ed2381e[identifier=33.output.32]
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-13 terminating.
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@5c910d89identifier=tcp://localhost:41333/95.output.97, 
upstream=95.output.97, group=stream101/96.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@21284d12{da=com.datatorrent.bufferserver.internal.DataList$Block@38919fc7{identifier=95.output.97,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6e579efa[identifier=95.output.97]
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-36 terminating.
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@769c7b96identifier=tcp://localhost:41333/148.output.150, 
upstream=148.output.150, group=stream137/149.sideInput1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@113a49e6{da=com.datatorrent.bufferserver.internal.DataList$Block@7299d60e{identifier=148.output.150,
 data=1048576, readingOffset=0, writingOffset=107, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@4642003d[identifier=148.output.150]
    Jun 14, 2018 6:36:33 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-70 terminating.
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@15794100identifier=tcp://localhost:41333/55.out.56, 
upstream=55.out.56, group=stream143/56.inputPort, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1430e641{da=com.datatorrent.bufferserver.internal.DataList$Block@5786f858{identifier=55.out.56,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6b937d00[identifier=55.out.56]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@81b2e55identifier=tcp://localhost:41333/25.output.50, 
upstream=25.output.50, group=stream28/51.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3d86dba7{da=com.datatorrent.bufferserver.internal.DataList$Block@2e9730b8{identifier=25.output.50,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@4eb3490a[identifier=25.output.50]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@1361ffc0identifier=tcp://localhost:41333/50.output.53, 
upstream=50.output.53, group=stream54/54.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3e3846a1{da=com.datatorrent.bufferserver.internal.DataList$Block@3568e922{identifier=50.output.53,
 data=1048576, readingOffset=0, writingOffset=72, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000002, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@22ed1dc7[identifier=50.output.53]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@28e2f98eidentifier=tcp://localhost:41333/132.output.134, 
upstream=132.output.134, group=stream5/133.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@76c2fb89{da=com.datatorrent.bufferserver.internal.DataList$Block@ab3a6be{identifier=132.output.134,
 data=1048576, readingOffset=0, writingOffset=103, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@78606f33[identifier=132.output.134]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@5d2f806cidentifier=tcp://localhost:41333/3.out.17, 
upstream=3.out.17, group=stream12/19.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@322946dd{da=com.datatorrent.bufferserver.internal.DataList$Block@53d6eda2{identifier=3.out.17,
 data=1048576, readingOffset=0, writingOffset=4672, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000008, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@44472730[identifier=3.out.17]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@78ab16eidentifier=tcp://localhost:41333/12.output.10, 
upstream=12.output.10, group=stream135/13.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3f25d17c{da=com.datatorrent.bufferserver.internal.DataList$Block@474277eb{identifier=12.output.10,
 data=1048576, readingOffset=0, writingOffset=2378, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@239d295c[identifier=12.output.10]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@b0cc961identifier=tcp://localhost:41333/19.out.154, 
upstream=19.out.154, group=stream114/72.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5e1ee4b8{da=com.datatorrent.bufferserver.internal.DataList$Block@4f217036{identifier=19.out.154,
 data=1048576, readingOffset=0, writingOffset=22950, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1b08bb16[identifier=19.out.154]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@226c518aidentifier=tcp://localhost:41333/98.output.108, 
upstream=98.output.108, group=stream24/108.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5195a6e2{da=com.datatorrent.bufferserver.internal.DataList$Block@7807b34c{identifier=98.output.108,
 data=1048576, readingOffset=0, writingOffset=72, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000002, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@3c63ccba[identifier=98.output.108]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@2b6282e4identifier=tcp://localhost:41333/38.output.38, 
upstream=38.output.38, group=stream95/39.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@62ed102b{da=com.datatorrent.bufferserver.internal.DataList$Block@1eb30822{identifier=38.output.38,
 data=1048576, readingOffset=0, writingOffset=108, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@5beb556b[identifier=38.output.38]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@4f17cbc8identifier=tcp://localhost:41333/2.output.2, 
upstream=2.output.2, group=stream8/3.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@79cf44b0{da=com.datatorrent.bufferserver.internal.DataList$Block@73a96fea{identifier=2.output.2,
 data=1048576, readingOffset=0, writingOffset=2372, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000008, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@755d8ba5[identifier=2.output.2]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@4f9d871identifier=tcp://localhost:41333/127.output.129, 
upstream=127.output.129, group=stream106/128.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@741cc868{da=com.datatorrent.bufferserver.internal.DataList$Block@77f5e89f{identifier=127.output.129,
 data=1048576, readingOffset=0, writingOffset=108, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@4f1b0fb4[identifier=127.output.129]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@3ad7cb2cidentifier=tcp://localhost:41333/19.out.19, 
upstream=19.out.19, group=stream114/99.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5682a551{da=com.datatorrent.bufferserver.internal.DataList$Block@444f6861{identifier=19.out.19,
 data=1048576, readingOffset=0, writingOffset=22950, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1c26c167[identifier=19.out.19]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@5e6dccfbidentifier=tcp://localhost:41333/19.out.20, 
upstream=19.out.20, group=stream114/28.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@bd71bf8{da=com.datatorrent.bufferserver.internal.DataList$Block@48bc9ffe{identifier=19.out.20,
 data=1048576, readingOffset=0, writingOffset=22950, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@778feae8[identifier=19.out.20]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@211849f9identifier=tcp://localhost:41333/19.out.153, 
upstream=19.out.153, group=stream114/20.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5d082087{da=com.datatorrent.bufferserver.internal.DataList$Block@6eb3f805{identifier=19.out.153,
 data=1048576, readingOffset=0, writingOffset=22950, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@42dcc942[identifier=19.out.153]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@cb76c24identifier=tcp://localhost:41333/42.out.43, 
upstream=42.out.43, group=stream59/43.inputPort, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4a8ca35b{da=com.datatorrent.bufferserver.internal.DataList$Block@569cbe95{identifier=42.out.43,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@279e1793[identifier=42.out.43]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@73f86f6identifier=tcp://localhost:41333/135.output.136, 
upstream=135.output.136, group=stream56/136.inputPort, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@32c5cfb{da=com.datatorrent.bufferserver.internal.DataList$Block@2c95b1be{identifier=135.output.136,
 data=1048576, readingOffset=0, writingOffset=73, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000002, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1f4ecaaf[identifier=135.output.136]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@6c5ed405identifier=tcp://localhost:41333/23.output.24, 
upstream=23.output.24, group=stream92/24.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@48bb745a{da=com.datatorrent.bufferserver.internal.DataList$Block@29113232{identifier=23.output.24,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@28886eef[identifier=23.output.24]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@2178ab47identifier=tcp://localhost:41333/23.output.25, 
upstream=23.output.25, group=stream92/55.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@417ad2e3{da=com.datatorrent.bufferserver.internal.DataList$Block@52f06732{identifier=23.output.25,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@72d05ffc[identifier=23.output.25]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@6fc3dd1eidentifier=tcp://localhost:41333/1.output.1, 
upstream=1.output.1, group=stream0/3.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@19c4b85f{da=com.datatorrent.bufferserver.internal.DataList$Block@ebe8c4e{identifier=1.output.1,
 data=1048576, readingOffset=0, writingOffset=2372, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000008, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@5f26b35c[identifier=1.output.1]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@628dbd0eidentifier=tcp://localhost:41333/77.output.78, 
upstream=77.output.78, group=stream141/78.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2ff928fb{da=com.datatorrent.bufferserver.internal.DataList$Block@13437b1b{identifier=77.output.78,
 data=1048576, readingOffset=0, writingOffset=103, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@696559c1[identifier=77.output.78]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@534e6741identifier=tcp://localhost:41333/29.output.28, 
upstream=29.output.28, group=stream104/30.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3b3abe2{da=com.datatorrent.bufferserver.internal.DataList$Block@656bf59f{identifier=29.output.28,
 data=1048576, readingOffset=0, writingOffset=26950, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6df8d18a[identifier=29.output.28]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@3938bd5bidentifier=tcp://localhost:41333/100.output.100, 
upstream=100.output.100, group=stream10/101.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2e9036a5{da=com.datatorrent.bufferserver.internal.DataList$Block@3062642e{identifier=100.output.100,
 data=1048576, readingOffset=0, writingOffset=1976, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@a1fa8b0[identifier=100.output.100]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@759a2029identifier=tcp://localhost:41333/111.out.117, 
upstream=111.out.117, group=stream17/116.inputPort, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@21404cf8{da=com.datatorrent.bufferserver.internal.DataList$Block@eca636b{identifier=111.out.117,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@2daa3588[identifier=111.out.117]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@42f1f092identifier=tcp://localhost:41333/13.out.13, 
upstream=13.out.13, group=stream34/17.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5a8742a5{da=com.datatorrent.bufferserver.internal.DataList$Block@7903e281{identifier=13.out.13,
 data=1048576, readingOffset=0, writingOffset=4678, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@248f17f1[identifier=13.out.13]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@642fe740identifier=tcp://localhost:41333/86.outputPort.88, 
upstream=86.outputPort.88, group=stream38/87.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@58f5709d{da=com.datatorrent.bufferserver.internal.DataList$Block@3807934c{identifier=86.outputPort.88,
 data=1048576, readingOffset=0, writingOffset=113, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@5ef67927[identifier=86.outputPort.88]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@33581f3aidentifier=tcp://localhost:41333/28.output.27, 
upstream=28.output.27, group=stream30/29.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@21add97{da=com.datatorrent.bufferserver.internal.DataList$Block@711824d1{identifier=28.output.27,
 data=1048576, readingOffset=0, writingOffset=22950, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@7501544d[identifier=28.output.27]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@209fd5c3identifier=tcp://localhost:41333/51.output.51, 
upstream=51.output.51, group=stream7/52.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@18d3248b{da=com.datatorrent.bufferserver.internal.DataList$Block@4c71a463{identifier=51.output.51,
 data=1048576, readingOffset=0, writingOffset=108, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@7c7f2f90[identifier=51.output.51]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@b71e637identifier=tcp://localhost:41333/126.output.128, 
upstream=126.output.128, group=stream41/127.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3a3af6e{da=com.datatorrent.bufferserver.internal.DataList$Block@25534ed{identifier=126.output.128,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@4346ca78[identifier=126.output.128]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@6456a786identifier=tcp://localhost:41333/87.output.89, 
upstream=87.output.89, group=stream14/88.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@46407e2f{da=com.datatorrent.bufferserver.internal.DataList$Block@58066156{identifier=87.output.89,
 data=1048576, readingOffset=0, writingOffset=117, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@73dfc4e7[identifier=87.output.89]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@36f9b077identifier=tcp://localhost:41333/20.output.21, 
upstream=20.output.21, group=stream68/21.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@63fd5ee{da=com.datatorrent.bufferserver.internal.DataList$Block@434b7200{identifier=20.output.21,
 data=1048576, readingOffset=0, writingOffset=22950, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@282ca7ee[identifier=20.output.21]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@b132c6cidentifier=tcp://localhost:41333/102.output.102, 
upstream=102.output.102, group=stream64/103.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2559a6f0{da=com.datatorrent.bufferserver.internal.DataList$Block@5db18710{identifier=102.output.102,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@457235d4[identifier=102.output.102]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@ec257eeidentifier=tcp://localhost:41333/102.output.103, 
upstream=102.output.103, group=stream64/111.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@82ce943{da=com.datatorrent.bufferserver.internal.DataList$Block@602ab090{identifier=102.output.103,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@31f22282[identifier=102.output.103]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@1b9155fidentifier=tcp://localhost:41333/26.output.82, 
upstream=26.output.82, group=stream58/81.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@657a7dfd{da=com.datatorrent.bufferserver.internal.DataList$Block@af3f6e0{identifier=26.output.82,
 data=1048576, readingOffset=0, writingOffset=72, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000002, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@3fe8691e[identifier=26.output.82]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@584f883aidentifier=tcp://localhost:41333/14.output.11, 
upstream=14.output.11, group=stream76/16.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1f2eaa53{da=com.datatorrent.bufferserver.internal.DataList$Block@298db9de{identifier=14.output.11,
 data=1048576, readingOffset=0, writingOffset=2350, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@3c5c1ef9[identifier=14.output.11]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@63d560a4identifier=tcp://localhost:41333/140.output.140, 
upstream=140.output.140, group=stream126/141.inputPort, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@400020f5{da=com.datatorrent.bufferserver.internal.DataList$Block@2a967694{identifier=140.output.140,
 data=1048576, readingOffset=0, writingOffset=73, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000002, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6e117951[identifier=140.output.140]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@6c01c43cidentifier=tcp://localhost:41333/119.outputPort.121, 
upstream=119.outputPort.121, group=stream29/120.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@326619bc{da=com.datatorrent.bufferserver.internal.DataList$Block@73a0908d{identifier=119.outputPort.121,
 data=1048576, readingOffset=0, writingOffset=114, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6a1b7abb[identifier=119.outputPort.121]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@578452edidentifier=tcp://localhost:41333/59.outputPort.60, 
upstream=59.outputPort.60, group=stream85/60.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@fa55d58{da=com.datatorrent.bufferserver.internal.DataList$Block@d0c0ee9{identifier=59.outputPort.60,
 data=1048576, readingOffset=0, writingOffset=114, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@7adfd33d[identifier=59.outputPort.60]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@4049cdb7identifier=tcp://localhost:41333/137.output.139, 
upstream=137.output.139, group=stream55/138.sideInput1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4ba0a07f{da=com.datatorrent.bufferserver.internal.DataList$Block@6eca7bce{identifier=137.output.139,
 data=1048576, readingOffset=0, writingOffset=108, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@3dc4bb8[identifier=137.output.139]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@5ab39ba5identifier=tcp://localhost:41333/139.output.143, 
upstream=139.output.143, group=stream84/143.inputPort, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@79e36c5{da=com.datatorrent.bufferserver.internal.DataList$Block@4973cd11{identifier=139.output.143,
 data=1048576, readingOffset=0, writingOffset=73, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000002, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@745adbfa[identifier=139.output.143]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@176b90a4identifier=tcp://localhost:41333/17.out.16, 
upstream=17.out.16, group=stream49/18.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@153adf42{da=com.datatorrent.bufferserver.internal.DataList$Block@63e4fb3e{identifier=17.out.16,
 data=1048576, readingOffset=0, writingOffset=9150, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@3428a916[identifier=17.out.16]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@42882ffbidentifier=tcp://localhost:41333/11.output.9, 
upstream=11.output.9, group=stream65/13.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@160f3162{da=com.datatorrent.bufferserver.internal.DataList$Block@558c3c2e{identifier=11.output.9,
 data=1048576, readingOffset=0, writingOffset=2378, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@11f500aa[identifier=11.output.9]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@1f21a546identifier=tcp://localhost:41333/4.output.3, 
upstream=4.output.3, group=stream4/6.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@60647b9b{da=com.datatorrent.bufferserver.internal.DataList$Block@f8fc2d4{identifier=4.output.3,
 data=1048576, readingOffset=0, writingOffset=2372, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000008, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@3bd6f247[identifier=4.output.3]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@458bfbe2identifier=tcp://localhost:41333/37.output.37, 
upstream=37.output.37, group=stream93/38.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@29f45c7{da=com.datatorrent.bufferserver.internal.DataList$Block@41e45eac{identifier=37.output.37,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@308cbd26[identifier=37.output.37]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@47b2d6aeidentifier=tcp://localhost:41333/60.output.61, 
upstream=60.output.61, group=stream16/61.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3cc435ba{da=com.datatorrent.bufferserver.internal.DataList$Block@448dfe98{identifier=60.output.61,
 data=1048576, readingOffset=0, writingOffset=118, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@277fc99b[identifier=60.output.61]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@3239119fidentifier=tcp://localhost:41333/15.output.12, 
upstream=15.output.12, group=stream91/16.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@724f25df{da=com.datatorrent.bufferserver.internal.DataList$Block@6f3ba7c9{identifier=15.output.12,
 data=1048576, readingOffset=0, writingOffset=2272, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000008, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@44e9ed88[identifier=15.output.12]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@6334f1d1identifier=tcp://localhost:41333/10.out.15, 
upstream=10.out.15, group=stream1/18.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1d03d79f{da=com.datatorrent.bufferserver.internal.DataList$Block@1669683d{identifier=10.out.15,
 data=1048576, readingOffset=0, writingOffset=9278, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@24de80d6[identifier=10.out.15]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@59ffdbd6identifier=tcp://localhost:41333/18.out.18, 
upstream=18.out.18, group=stream133/19.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2fd0bc68{da=com.datatorrent.bufferserver.internal.DataList$Block@2c6c2922{identifier=18.out.18,
 data=1048576, readingOffset=0, writingOffset=18350, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@71198412[identifier=18.out.18]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@3fa28971identifier=tcp://localhost:41333/120.output.122, 
upstream=120.output.122, group=stream45/121.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@219162d7{da=com.datatorrent.bufferserver.internal.DataList$Block@b08a971{identifier=120.output.122,
 data=1048576, readingOffset=0, writingOffset=118, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@4660a40b[identifier=120.output.122]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@282f346identifier=tcp://localhost:41333/54.output.55, 
upstream=54.output.55, group=stream39/55.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7be491c1{da=com.datatorrent.bufferserver.internal.DataList$Block@51c9c3b0{identifier=54.output.55,
 data=1048576, readingOffset=0, writingOffset=96, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1f44bbd9[identifier=54.output.55]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@1ddbb06eidentifier=tcp://localhost:41333/105.output.106, 
upstream=105.output.106, group=stream119/106.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5cc704c6{da=com.datatorrent.bufferserver.internal.DataList$Block@3f2ec06{identifier=105.output.106,
 data=1048576, readingOffset=0, writingOffset=108, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1cb96b8b[identifier=105.output.106]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@f13557fidentifier=tcp://localhost:41333/78.output.79, 
upstream=78.output.79, group=stream117/79.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@261981b6{da=com.datatorrent.bufferserver.internal.DataList$Block@421c5087{identifier=78.output.79,
 data=1048576, readingOffset=0, writingOffset=107, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@569a061e[identifier=78.output.79]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@6415dcf0identifier=tcp://localhost:41333/96.output.98, 
upstream=96.output.98, group=stream89/97.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1a8ca75{da=com.datatorrent.bufferserver.internal.DataList$Block@6b56efc7{identifier=96.output.98,
 data=1048576, readingOffset=0, writingOffset=108, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@4bee0242[identifier=96.output.98]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@12d76460identifier=tcp://localhost:41333/104.output.105, 
upstream=104.output.105, group=stream132/105.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4d4247d7{da=com.datatorrent.bufferserver.internal.DataList$Block@afec768{identifier=104.output.105,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@568a2927[identifier=104.output.105]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@46481274identifier=tcp://localhost:41333/75.output.75, 
upstream=75.output.75, group=stream42/76.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6dcddda6{da=com.datatorrent.bufferserver.internal.DataList$Block@326e5337{identifier=75.output.75,
 data=1048576, readingOffset=0, writingOffset=103, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@4ed70795[identifier=75.output.75]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@382a1279identifier=tcp://localhost:41333/75.output.76, 
upstream=75.output.76, group=stream42/82.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4993cc79{da=com.datatorrent.bufferserver.internal.DataList$Block@4ab00800{identifier=75.output.76,
 data=1048576, readingOffset=0, writingOffset=103, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@a871d8a[identifier=75.output.76]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@43b1d04identifier=tcp://localhost:41333/41.output.42, 
upstream=41.output.42, group=stream21/42.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7c1a48e0{da=com.datatorrent.bufferserver.internal.DataList$Block@2b3da31e{identifier=41.output.42,
 data=1048576, readingOffset=0, writingOffset=96, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@61075e71[identifier=41.output.42]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@1e9dc95bidentifier=tcp://localhost:41333/32.output.31, 
upstream=32.output.31, group=stream57/33.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@53de6496{da=com.datatorrent.bufferserver.internal.DataList$Block@7dad7b45{identifier=32.output.31,
 data=1048576, readingOffset=0, writingOffset=22953, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@3b4e02bd[identifier=32.output.31]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@430069e2identifier=tcp://localhost:41333/46.outputPort.47, 
upstream=46.outputPort.47, group=stream70/47.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@60613773{da=com.datatorrent.bufferserver.internal.DataList$Block@403b153d{identifier=46.outputPort.47,
 data=1048576, readingOffset=0, writingOffset=114, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@565a292c[identifier=46.outputPort.47]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@306473a0identifier=tcp://localhost:41333/35.output.35, 
upstream=35.output.35, group=stream82/42.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1dca82b0{da=com.datatorrent.bufferserver.internal.DataList$Block@7479f4d5{identifier=35.output.35,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6cf3959a[identifier=35.output.35]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@2b0cc8bidentifier=tcp://localhost:41333/35.output.34, 
upstream=35.output.34, group=stream82/36.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6be7c261{da=com.datatorrent.bufferserver.internal.DataList$Block@227112af{identifier=35.output.34,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@19159568[identifier=35.output.34]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@73bcc07aidentifier=tcp://localhost:41333/16.out.14, 
upstream=16.out.14, group=stream94/17.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@69ba9c95{da=com.datatorrent.bufferserver.internal.DataList$Block@3c1baf09{identifier=16.out.14,
 data=1048576, readingOffset=0, writingOffset=4550, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1655264f[identifier=16.out.14]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@26899832identifier=tcp://localhost:41333/66.output.67, 
upstream=66.output.67, group=stream37/67.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@23de5f38{da=com.datatorrent.bufferserver.internal.DataList$Block@1e3d21e2{identifier=66.output.67,
 data=1048576, readingOffset=0, writingOffset=104, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@7fbfa6cb[identifier=66.output.67]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@7678690cidentifier=tcp://localhost:41333/47.output.48, 
upstream=47.output.48, group=stream44/48.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@40e7802d{da=com.datatorrent.bufferserver.internal.DataList$Block@11912096{identifier=47.output.48,
 data=1048576, readingOffset=0, writingOffset=118, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@66543177[identifier=47.output.48]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@306dfb52identifier=tcp://localhost:41333/73.output.73, 
upstream=73.output.73, group=stream35/74.input, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@64df4a88{da=com.datatorrent.bufferserver.internal.DataList$Block@18c548d6{identifier=73.output.73,
 data=1048576, readingOffset=0, writingOffset=1976, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@485ec8[identifier=73.output.73]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@3d22b924identifier=tcp://localhost:41333/82.out.84, 
upstream=82.out.84, group=stream130/83.inputPort, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4750183f{da=com.datatorrent.bufferserver.internal.DataList$Block@59459157{identifier=82.out.84,
 data=1048576, readingOffset=0, writingOffset=103, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6b74f151[identifier=82.out.84]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@2010488identifier=tcp://localhost:41333/81.output.83, 
upstream=81.output.83, group=stream51/82.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@29085ce9{da=com.datatorrent.bufferserver.internal.DataList$Block@6e5e3817{identifier=81.output.83,
 data=1048576, readingOffset=0, writingOffset=96, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1b64d3a2[identifier=81.output.83]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@a05b361identifier=tcp://localhost:41333/5.output.4, 
upstream=5.output.4, group=stream134/6.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@575647e6{da=com.datatorrent.bufferserver.internal.DataList$Block@3c52b6f1{identifier=5.output.4,
 data=1048576, readingOffset=0, writingOffset=2378, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@2353bfec[identifier=5.output.4]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@1782d883identifier=tcp://localhost:41333/7.output.5, 
upstream=7.output.5, group=stream48/9.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1e1781e7{da=com.datatorrent.bufferserver.internal.DataList$Block@7b9b8cb4{identifier=7.output.5,
 data=1048576, readingOffset=0, writingOffset=2378, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@52575808[identifier=7.output.5]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@1a130c11identifier=tcp://localhost:41333/6.out.7, upstream=6.out.7, 
group=stream53/10.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6c452171{da=com.datatorrent.bufferserver.internal.DataList$Block@4e7f9da7{identifier=6.out.7,
 data=1048576, readingOffset=0, writingOffset=4678, 
starting_window=5b22b5ad00000001, ending_window=5b22b5ad00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@692656f0[identifier=6.out.7]
    Jun 14, 2018 6:36:33 PM com.datatorrent.bufferserver.server.Server$1 run
    INFO: Server stopped listening at /0:0:0:0:0:0:0:0:41333
    Jun 14, 2018 6:36:33 PM 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.331 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.223 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 
11,5,main]) completed. Took 27 mins 51.607 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 40s
32 actionable tasks: 28 executed, 4 from cache

Publishing build scan...
https://gradle.com/s/smi2qu5g3vfak

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 apill...@google.com
Not sending mail to unregistered user robbe.sneyd...@ml6.eu
Not sending mail to unregistered user git...@alasdairhodge.co.uk
Not sending mail to unregistered user aal...@gmail.com
Not sending mail to unregistered user sweg...@google.com
Not sending mail to unregistered user 
robi...@rodete-desktop-imager.corp.google.com
Not sending mail to unregistered user jiang...@gmail.com
Not sending mail to unregistered user fvoich...@gmail.com

Reply via email to