See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/181/display/redirect>
------------------------------------------
[...truncated 14.74 MB...]
INFO: Deploy request:
[OperatorDeployInfo[id=9,name=PAssert$171/GroupGlobally/GatherAllOutputs/GroupByKey,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream2,sourceNodeId=8,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream12,bufferServer=localhost]]]]
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=2.output.2, windowId=ffffffffffffffff}
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:36073/1.output.1, windowId=ffffffffffffffff,
type=stream7/2.input, upstreamIdentifier=1.output.1, mask=0, partitions=null,
bufferSize=1024}
Apr 24, 2018 12:52:25 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=14,name=PAssert$171/GroupGlobally/WindowIntoDummy/Window.Assign,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream8,sourceNodeId=13,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream9,bufferServer=localhost]]]]
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=9.output.9, windowId=ffffffffffffffff}
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:36073/8.outputPort.8, windowId=ffffffffffffffff,
type=stream2/9.input, upstreamIdentifier=8.outputPort.8, mask=0,
partitions=null, bufferSize=1024}
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:36073/13.output.12, windowId=ffffffffffffffff,
type=stream8/14.inputPort, upstreamIdentifier=13.output.12, mask=0,
partitions=null, bufferSize=1024}
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=14.outputPort.14, windowId=ffffffffffffffff}
Apr 24, 2018 12:52:25 AM com.datatorrent.stram.engine.Node emitEndStream
INFO: 1 sending EndOfStream
Apr 24, 2018 12:52:25 AM com.datatorrent.stram.engine.Node emitEndStream
INFO: 13 sending EndOfStream
Apr 24, 2018 12:52:25 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=15,name=PAssert$171/GroupGlobally/FlattenDummyAndContents,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=data1,streamId=stream0,sourceNodeId=12,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>],
OperatorDeployInfo.InputDeployInfo[portName=data2,streamId=stream9,sourceNodeId=14,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=out,streamId=stream19,bufferServer=localhost]]]]
Apr 24, 2018 12:52:25 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=16,name=PAssert$171/GroupGlobally/GroupDummyAndContents,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream19,sourceNodeId=15,sourcePortName=out,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream6,bufferServer=localhost]]]]
Apr 24, 2018 12:52:25 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=10,name=PAssert$171/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous),type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream12,sourceNodeId=9,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream14,bufferServer=<null>]]],
OperatorDeployInfo[id=12,name=PAssert$171/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream5,sourceNodeId=11,sourcePortName=outputPort,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream0,bufferServer=localhost]]],
OperatorDeployInfo[id=11,name=PAssert$171/GroupGlobally/RewindowActuals/Window.Assign,type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream14,sourceNodeId=10,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream5,bufferServer=<null>]]]]
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:36073/14.outputPort.14, windowId=ffffffffffffffff,
type=stream9/15.data2, upstreamIdentifier=14.outputPort.14, mask=0,
partitions=null, bufferSize=1024}
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=15.out.15, windowId=ffffffffffffffff}
Apr 24, 2018 12:52:25 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=21,name=PAssert$171/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream17,sourceNodeId=20,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[]],
OperatorDeployInfo[id=19,name=PAssert$171/GetPane/Map/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream3,sourceNodeId=18,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream1,bufferServer=<null>]]],
OperatorDeployInfo[id=17,name=PAssert$171/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous),type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream6,sourceNodeId=16,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream15,bufferServer=<null>]]],
OperatorDeployInfo[id=18,name=PAssert$171/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream15,sourceNodeId=17,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream3,bufferServer=<null>]]],
OperatorDeployInfo[id=20,name=PAssert$171/RunChecks/ParMultiDo(GroupedValuesChecker),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream1,sourceNodeId=19,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream17,bufferServer=<null>]]]]
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:36073/12.output.13, windowId=ffffffffffffffff,
type=stream0/15.data1, upstreamIdentifier=12.output.13, mask=0,
partitions=null, bufferSize=1024}
Apr 24, 2018 12:52:25 AM com.datatorrent.stram.engine.Node emitEndStream
INFO: 14 sending EndOfStream
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=16.output.16, windowId=ffffffffffffffff}
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:36073/15.out.15, windowId=ffffffffffffffff,
type=stream19/16.input, upstreamIdentifier=15.out.15, mask=0, partitions=null,
bufferSize=1024}
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:36073/9.output.9, windowId=ffffffffffffffff,
type=stream12/10.input, upstreamIdentifier=9.output.9, mask=0, partitions=null,
bufferSize=1024}
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=12.output.13, windowId=ffffffffffffffff}
Apr 24, 2018 12:52:25 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:36073/16.output.16, windowId=ffffffffffffffff,
type=stream6/17.input, upstreamIdentifier=16.output.16, mask=0,
partitions=null, bufferSize=1024}
Apr 24, 2018 12:52:25 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:26 AM com.datatorrent.bufferserver.internal.DataList
newBuffer
SEVERE: Tuple size 104857629 exceeds buffer server current block size
1048576. Please decrease tuple size. Proceeding with allocating larger block
that may cause out of memory exception.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Undeploy request: [13]
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Undeploy request: [14]
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Undeploy request: [1]
Apr 24, 2018 12:52:28 AM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 24, 2018 12:52:32 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@3f8598e2identifier=tcp://localhost:36073/1.output.1,
upstream=1.output.1, group=stream7/2.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1742375d{da=com.datatorrent.bufferserver.internal.DataList$Block@48b42ef5{identifier=1.output.1,
data=1048576, readingOffset=0, writingOffset=123,
starting_window=5ade7fc700000001, ending_window=5ade7fc700000003, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@7903a904 {1.output.1}
Apr 24, 2018 12:52:32 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@3c7f440eidentifier=tcp://localhost:36073/14.outputPort.14,
upstream=14.outputPort.14, group=stream9/15.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5eb0d7c2{da=com.datatorrent.bufferserver.internal.DataList$Block@584eeb96{identifier=14.outputPort.14,
data=1048576, readingOffset=0, writingOffset=77,
starting_window=5ade7fc700000001, ending_window=5ade7fc700000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@31e4b5ec {14.outputPort.14}
Apr 24, 2018 12:52:32 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@5a722602identifier=tcp://localhost:36073/13.output.12,
upstream=13.output.12, group=stream8/14.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@55cb615d{da=com.datatorrent.bufferserver.internal.DataList$Block@d9db2e1{identifier=13.output.12,
data=1048576, readingOffset=0, writingOffset=77,
starting_window=5ade7fc700000001, ending_window=5ade7fc700000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@2220ea9f {13.output.12}
Apr 24, 2018 12:52:38 AM com.datatorrent.bufferserver.internal.DataList
newBuffer
SEVERE: Tuple size 104857629 exceeds buffer server current block size
1048576. Please decrease tuple size. Proceeding with allocating larger block
that may cause out of memory exception.
Apr 24, 2018 12:52:41 AM com.datatorrent.stram.engine.Node emitEndStream
INFO: 2 sending EndOfStream
Apr 24, 2018 12:52:41 AM com.datatorrent.bufferserver.internal.DataList
newBuffer
SEVERE: Tuple size 104857629 exceeds buffer server current block size
1048576. Please decrease tuple size. Proceeding with allocating larger block
that may cause out of memory exception.
Apr 24, 2018 12:52:42 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 24, 2018 12:52:42 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Undeploy request: [2]
Apr 24, 2018 12:52:42 AM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 24, 2018 12:52:42 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@4ffc3a28identifier=tcp://localhost:36073/2.output.2,
upstream=2.output.2, group=stream10/3.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@38b02ee9{da=com.datatorrent.bufferserver.internal.DataList$Block@58da99a4{identifier=2.output.2,
data=1048576, readingOffset=0, writingOffset=24,
starting_window=5ade7fc700000002, ending_window=5ade7fc700000003, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@7d8bf432 {2.output.2}
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-5 msg: [container-5] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-5 terminating.
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-9 msg: [container-9] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-8 msg: [container-8] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-0 msg: [container-0] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-2 msg: [container-2] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-2 terminating.
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-6 msg: [container-6] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-3 msg: [container-3] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-3 terminating.
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-7 msg: [container-7] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-10 msg: [container-10] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-1 msg: [container-1] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-1 terminating.
Apr 24, 2018 12:52:44 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Received shutdown request type ABORT
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-4 msg: [container-4] Exiting heartbeat loop..
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-8 terminating.
Apr 24, 2018 12:52:44 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@a2e85b1identifier=tcp://localhost:36073/15.out.15,
upstream=15.out.15, group=stream19/16.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@30bee301{da=com.datatorrent.bufferserver.internal.DataList$Block@9c04499{identifier=15.out.15,
data=1048576, readingOffset=0, writingOffset=38,
starting_window=5ade7fc700000001, ending_window=5ade7fc700000001, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@55bfbbc {15.out.15}
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-6 terminating.
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-7 terminating.
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-0 terminating.
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-9 terminating.
Apr 24, 2018 12:52:44 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-4 terminating.
Apr 24, 2018 12:52:44 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@64f87d83identifier=tcp://localhost:36073/16.output.16,
upstream=16.output.16, group=stream6/17.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2753b541{da=com.datatorrent.bufferserver.internal.DataList$Block@6032fc41{identifier=16.output.16,
data=1048576, readingOffset=0, writingOffset=12,
starting_window=5ade7fc700000001, ending_window=5ade7fc700000001, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@6b5d8852 {16.output.16}
Apr 24, 2018 12:52:44 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@49a3f55cidentifier=tcp://localhost:36073/8.outputPort.8,
upstream=8.outputPort.8, group=stream2/9.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3101189e{da=com.datatorrent.bufferserver.internal.DataList$Block@b424a42{identifier=8.outputPort.8,
data=1048576, readingOffset=0, writingOffset=27,
starting_window=5ade7fc700000001, ending_window=5ade7fc700000001, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@7ce56f9f {8.outputPort.8}
Apr 24, 2018 12:52:44 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@77f627b5identifier=tcp://localhost:36073/12.output.13,
upstream=12.output.13, group=stream0/15.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7b7d6749{da=com.datatorrent.bufferserver.internal.DataList$Block@42015550{identifier=12.output.13,
data=1048576, readingOffset=0, writingOffset=27,
starting_window=5ade7fc700000001, ending_window=5ade7fc700000001, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@5b081708 {12.output.13}
Apr 24, 2018 12:52:44 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@a3aa272identifier=tcp://localhost:36073/9.output.9,
upstream=9.output.9, group=stream12/10.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@cc61261{da=com.datatorrent.bufferserver.internal.DataList$Block@1c917b9f{identifier=9.output.9,
data=1048576, readingOffset=0, writingOffset=27,
starting_window=5ade7fc700000001, ending_window=5ade7fc700000001, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@54720688 {9.output.9}
Apr 24, 2018 12:52:45 AM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-10 terminating.
Apr 24, 2018 12:52:45 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@ec13013identifier=tcp://localhost:36073/3.output.3,
upstream=3.output.3, group=stream4/4.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4fd9eb59{da=com.datatorrent.bufferserver.internal.DataList$Block@73b0add9{identifier=3.output.3,
data=1048576, readingOffset=0, writingOffset=27,
starting_window=5ade7fc700000001, ending_window=5ade7fc700000001, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@646a6db3 {3.output.3}
Apr 24, 2018 12:52:45 AM com.datatorrent.stram.StramLocalCluster run
INFO: Application finished.
Apr 24, 2018 12:52:45 AM com.datatorrent.bufferserver.server.Server$1 run
INFO: Server stopped listening at /0.0.0.0:36073
org.apache.beam.sdk.transforms.GroupByKeyTest > testGroupByKeyAndWindows
STANDARD_ERROR
Apr 24, 2018 12:52:46 AM com.datatorrent.common.util.AsyncFSStorageAgent
save
INFO: using /tmp/chkp7739191312284716563 as the basepath for checkpointing.
#
Java HotSpot(TM) 64-Bit Server VM warning: INFO:
os::commit_memory(0x000000074e780000, 289931264, 0) failed; error='Cannot
allocate memory' (errno=12)
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 289931264 bytes for committing
reserved memory.
# An error report file with more information is saved as:
#
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/ws/src/runners/apex/hs_err_pid32645.log>
:beam-runners-apex:validatesRunnerBatch FAILED
:beam-runners-apex:validatesRunnerBatch (Thread[Task worker for ':',5,main])
completed. Took 20 mins 54.932 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-apex:validatesRunnerBatch'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at
https://docs.gradle.org/4.6/userguide/java_plugin.html#sec:test_execution
* 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.6/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 22m 1s
32 actionable tasks: 28 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/vdyznm3nb3mkk
Build cache (/home/jenkins/.gradle/caches/build-cache-1) has not been cleaned
up in 4 days
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Recording test results
ERROR: Step ‘Publish JUnit test result report’ failed: No test report files
were found. Configuration error?
