See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/92/display/redirect?page=changes>
Changes:
[tgroh] Rename `defaultRegistry` to `javaSdkNativeRegistry`
------------------------------------------
[...truncated 14.73 MB...]
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Started container container-2
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-2 msg: [container-2] Entering heartbeat loop..
Apr 13, 2018 10:24:04 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Started container container-3
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-3 msg: [container-3] Entering heartbeat loop..
Apr 13, 2018 10:24:04 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Started container container-4
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-4 msg: [container-4] Entering heartbeat loop..
Apr 13, 2018 10:24:04 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Started container container-5
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-5 msg: [container-5] Entering heartbeat loop..
Apr 13, 2018 10:24:04 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Started container container-6
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-6 msg: [container-6] Entering heartbeat loop..
Apr 13, 2018 10:24:04 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Started container container-7
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-7 msg: [container-7] Entering heartbeat loop..
Apr 13, 2018 10:24:04 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Started container container-8
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-8 msg: [container-8] Entering heartbeat loop..
Apr 13, 2018 10:24:04 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Started container container-9
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-9 msg: [container-9] Entering heartbeat loop..
Apr 13, 2018 10:24:04 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Started container container-10
Apr 13, 2018 10:24:04 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-10 msg: [container-10] Entering heartbeat loop..
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=9,name=PAssert$171/GroupGlobally/GatherAllOutputs/GroupByKey,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream9,sourceNodeId=8,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream1,bufferServer=localhost]]]]
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=9.output.9, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/8.outputPort.8, windowId=ffffffffffffffff,
type=stream9/9.input, upstreamIdentifier=8.outputPort.8, mask=0,
partitions=null, bufferSize=1024}
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=1,name=Create.Values,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream13,bufferServer=localhost]]]]
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.WindowGenerator
activate
INFO: Catching up from 1523658243500 to 1523658245557
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=1.output.1, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM 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=stream10,sourceNodeId=15,sourcePortName=out,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream11,bufferServer=localhost]]]]
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=16.output.16, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=13,name=PAssert$171/GroupGlobally/Create.Values,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream14,bufferServer=localhost]]]]
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/15.out.15, windowId=ffffffffffffffff,
type=stream10/16.input, upstreamIdentifier=15.out.15, mask=0, partitions=null,
bufferSize=1024}
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.WindowGenerator
activate
INFO: Catching up from 1523658243500 to 1523658245563
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=13.output.12, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=11,name=PAssert$171/GroupGlobally/RewindowActuals/Window.Assign,type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream4,sourceNodeId=10,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream15,bufferServer=<null>]]],
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=stream1,sourceNodeId=9,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream4,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=stream15,sourceNodeId=11,sourcePortName=outputPort,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream5,bufferServer=localhost]]]]
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/9.output.9, windowId=ffffffffffffffff,
type=stream1/10.input, upstreamIdentifier=9.output.9, mask=0, partitions=null,
bufferSize=1024}
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=18,name=PAssert$171/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream3,sourceNodeId=17,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream12,bufferServer=<null>]]],
OperatorDeployInfo[id=21,name=PAssert$171/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream16,sourceNodeId=20,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[]],
OperatorDeployInfo[id=20,name=PAssert$171/RunChecks/ParMultiDo(GroupedValuesChecker),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream17,sourceNodeId=19,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream16,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=stream11,sourceNodeId=16,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream3,bufferServer=<null>]]],
OperatorDeployInfo[id=19,name=PAssert$171/GetPane/Map/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream12,sourceNodeId=18,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream17,bufferServer=<null>]]]]
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=12.output.13, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=6,name=PAssert$171/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream8,sourceNodeId=5,sourcePortName=outputPort,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream2,bufferServer=<null>]]],
OperatorDeployInfo[id=5,name=PAssert$171/GroupGlobally/Window.Into()/Window.Assign,type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream7,sourceNodeId=4,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream8,bufferServer=<null>]]],
OperatorDeployInfo[id=8,name=PAssert$171/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign,type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream0,sourceNodeId=7,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream9,bufferServer=localhost]]],
OperatorDeployInfo[id=4,name=Count/ParMultiDo(Anonymous),type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream19,sourceNodeId=3,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream7,bufferServer=<null>]]],
OperatorDeployInfo[id=7,name=PAssert$171/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream2,sourceNodeId=6,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream0,bufferServer=<null>]]]]
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=2,name=Expand/ParMultiDo(Anonymous),type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream13,sourceNodeId=1,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream18,bufferServer=localhost]]]]
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=2.output.2, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/1.output.1, windowId=ffffffffffffffff,
type=stream13/2.input, upstreamIdentifier=1.output.1, mask=0, partitions=null,
bufferSize=1024}
Apr 13, 2018 10:24:05 PM 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=stream5,sourceNodeId=12,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>],
OperatorDeployInfo.InputDeployInfo[portName=data2,streamId=stream6,sourceNodeId=14,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=out,streamId=stream10,bufferServer=localhost]]]]
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.Node emitEndStream
INFO: 1 sending EndOfStream
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.Node emitEndStream
INFO: 13 sending EndOfStream
Apr 13, 2018 10:24:05 PM 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=stream14,sourceNodeId=13,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream6,bufferServer=localhost]]]]
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=3,name=GroupByKey,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream18,sourceNodeId=2,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream19,bufferServer=localhost]]]]
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/16.output.16, windowId=ffffffffffffffff,
type=stream11/17.input, upstreamIdentifier=16.output.16, mask=0,
partitions=null, bufferSize=1024}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/13.output.12, windowId=ffffffffffffffff,
type=stream14/14.inputPort, upstreamIdentifier=13.output.12, mask=0,
partitions=null, bufferSize=1024}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=3.output.3, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/2.output.2, windowId=ffffffffffffffff,
type=stream18/3.input, upstreamIdentifier=2.output.2, mask=0, partitions=null,
bufferSize=1024}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=8.outputPort.8, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/3.output.3, windowId=ffffffffffffffff,
type=stream19/4.input, upstreamIdentifier=3.output.3, mask=0, partitions=null,
bufferSize=1024}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=14.outputPort.14, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=15.out.15, windowId=ffffffffffffffff}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/12.output.13, windowId=ffffffffffffffff,
type=stream5/15.data1, upstreamIdentifier=12.output.13, mask=0,
partitions=null, bufferSize=1024}
Apr 13, 2018 10:24:05 PM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:60275/14.outputPort.14, windowId=ffffffffffffffff,
type=stream6/15.data2, upstreamIdentifier=14.outputPort.14, mask=0,
partitions=null, bufferSize=1024}
Apr 13, 2018 10:24:05 PM com.datatorrent.stram.engine.Node emitEndStream
INFO: 14 sending EndOfStream
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:06 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:07 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:07 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Undeploy request: [1]
Apr 13, 2018 10:24:07 PM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 13, 2018 10:24:07 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:07 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Undeploy request: [13]
Apr 13, 2018 10:24:07 PM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 13, 2018 10:24:07 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@eb579e7identifier=tcp://localhost:60275/1.output.1,
upstream=1.output.1, group=stream13/2.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3cb7966{da=com.datatorrent.bufferserver.internal.DataList$Block@271bfafe{identifier=1.output.1,
data=1048576, readingOffset=0, writingOffset=129,
starting_window=5ad12e0300000001, ending_window=5ad12e0300000004, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@1b585775 {1.output.1}
Apr 13, 2018 10:24:07 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@7e37f2f4identifier=tcp://localhost:60275/13.output.12,
upstream=13.output.12, group=stream14/14.inputPort, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@53e80a19{da=com.datatorrent.bufferserver.internal.DataList$Block@b30594b{identifier=13.output.12,
data=1048576, readingOffset=0, writingOffset=77,
starting_window=5ad12e0300000001, ending_window=5ad12e0300000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@73849ed9 {13.output.12}
Apr 13, 2018 10:24:07 PM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 13, 2018 10:24:07 PM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Undeploy request: [14]
Apr 13, 2018 10:24:07 PM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 13, 2018 10:24:07 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1092e21identifier=tcp://localhost:60275/14.outputPort.14,
upstream=14.outputPort.14, group=stream6/15.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2abe8c23{da=com.datatorrent.bufferserver.internal.DataList$Block@3995e3af{identifier=14.outputPort.14,
data=1048576, readingOffset=0, writingOffset=77,
starting_window=5ad12e0300000001, ending_window=5ad12e0300000002, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@30e61fd7 {14.outputPort.14}
Apr 13, 2018 10:24:10 PM 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 13, 2018 10:24:14 PM 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.
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 252182528 bytes for committing
reserved memory.
Java HotSpot(TM) 64-Bit Server VM warning: INFO:
os::commit_memory(0x000000072bd00000, 252182528, 0) failed; error='Cannot
allocate memory' (errno=12)
# 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_pid26191.log>
:beam-runners-apex:validatesRunnerBatch FAILED
:beam-runners-apex:validatesRunnerBatch (Thread[Task worker for ':' Thread
2,5,main]) completed. Took 19 mins 31.43 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
* 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.5.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 21m 47s
32 actionable tasks: 32 executed
Publishing build scan...
https://gradle.com/s/rvkckss65he3k
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?
Not sending mail to unregistered user sid...@google.com
