See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/93/display/redirect?page=changes>
Changes: [sidhom] [BEAM-3994] Use typed client pool sinks and sources [sidhom] [BEAM-3966] Move functional utilities into shared module [sidhom] Use general functional interfaces in ControlClientPool [sidhom] Rename createLinked() to createBuffered() in QueueControlClientPool ------------------------------------------ [...truncated 14.71 MB...] WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Started container container-2 Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-2 msg: [container-2] Entering heartbeat loop.. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Started container container-3 Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-3 msg: [container-3] Entering heartbeat loop.. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Started container container-4 Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-4 msg: [container-4] Entering heartbeat loop.. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Started container container-5 Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-5 msg: [container-5] Entering heartbeat loop.. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Started container container-6 Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-6 msg: [container-6] Entering heartbeat loop.. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Started container container-7 Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-7 msg: [container-7] Entering heartbeat loop.. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Started container container-8 Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-8 msg: [container-8] Entering heartbeat loop.. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Started container container-9 Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-9 msg: [container-9] Entering heartbeat loop.. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Started container container-10 Apr 13, 2018 10:49:33 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-10 msg: [container-10] Entering heartbeat loop.. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer heartbeatLoop INFO: Waiting for pending request. Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.StreamingContainer processHeartbeatResponse INFO: Deploy request: [OperatorDeployInfo[id=12,name=PAssert$171/GroupGlobally/Create.Values,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream0,bufferServer=localhost]]]] Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.WindowGenerator activate INFO: Catching up from 1523659773500 to 1523659774565 Apr 13, 2018 10:49:34 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received publisher request: PublishRequestTuple{version=1.0, identifier=12.output.11, windowId=ffffffffffffffff} Apr 13, 2018 10:49:34 PM com.datatorrent.stram.engine.Node emitEndStream INFO: 12 sending EndOfStream Apr 13, 2018 10:49:35 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=stream2,sourceNodeId=1,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream15,bufferServer=localhost]]]] Apr 13, 2018 10:49:35 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=stream13,sourceNodeId=8,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream3,bufferServer=localhost]]]] Apr 13, 2018 10:49:35 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:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/1.output.1, windowId=ffffffffffffffff, type=stream2/2.input, upstreamIdentifier=1.output.1, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 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:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/8.outputPort.8, windowId=ffffffffffffffff, type=stream13/9.input, upstreamIdentifier=8.outputPort.8, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 PM com.datatorrent.stram.engine.StreamingContainer processHeartbeatResponse INFO: Deploy request: [OperatorDeployInfo[id=14,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=stream19,bufferServer=localhost]]], 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=stream3,sourceNodeId=9,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream8,bufferServer=<null>]]], OperatorDeployInfo[id=11,name=PAssert$171/GroupGlobally/RewindowActuals/Window.Assign,type=OIO,checkpoint={ffffffffffffffff, 0, 0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream8,sourceNodeId=10,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream5,bufferServer=<null>]]]] Apr 13, 2018 10:49:35 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=data2,streamId=stream14,sourceNodeId=13,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>], OperatorDeployInfo.InputDeployInfo[portName=data1,streamId=stream19,sourceNodeId=14,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=out,streamId=stream1,bufferServer=localhost]]]] Apr 13, 2018 10:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/9.output.9, windowId=ffffffffffffffff, type=stream3/10.input, upstreamIdentifier=9.output.9, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received publisher request: PublishRequestTuple{version=1.0, identifier=14.output.14, windowId=ffffffffffffffff} Apr 13, 2018 10:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/13.outputPort.13, windowId=ffffffffffffffff, type=stream14/15.data2, upstreamIdentifier=13.outputPort.13, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 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:49:35 PM com.datatorrent.stram.engine.StreamingContainer processHeartbeatResponse INFO: Deploy request: [OperatorDeployInfo[id=13,name=PAssert$171/GroupGlobally/WindowIntoDummy/Window.Assign,type=GENERIC,checkpoint={ffffffffffffffff, 0, 0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream0,sourceNodeId=12,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream14,bufferServer=localhost]]]] Apr 13, 2018 10:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/14.output.14, windowId=ffffffffffffffff, type=stream19/15.data1, upstreamIdentifier=14.output.14, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 PM com.datatorrent.stram.engine.StreamingContainer processHeartbeatResponse INFO: Deploy request: [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=stream11,sourceNodeId=6,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream6,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=stream6,sourceNodeId=7,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream13,bufferServer=localhost]]], OperatorDeployInfo[id=4,name=Count/ParMultiDo(Anonymous),type=GENERIC,checkpoint={ffffffffffffffff, 0, 0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream10,sourceNodeId=3,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream18,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=stream18,sourceNodeId=4,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream4,bufferServer=<null>]]], 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=stream4,sourceNodeId=5,sourcePortName=outputPort,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream11,bufferServer=<null>]]]] Apr 13, 2018 10:49:35 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=stream15,sourceNodeId=2,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream10,bufferServer=localhost]]]] Apr 13, 2018 10:49:35 PM com.datatorrent.stram.engine.StreamingContainer processHeartbeatResponse INFO: Deploy request: [OperatorDeployInfo[id=17,name=PAssert$171/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous),type=GENERIC,checkpoint={ffffffffffffffff, 0, 0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream12,sourceNodeId=16,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream16,bufferServer=<null>]]], 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=stream9,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=stream9,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=stream7,sourceNodeId=18,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream17,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=stream16,sourceNodeId=17,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream7,bufferServer=<null>]]]] Apr 13, 2018 10:49:35 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:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/12.output.11, windowId=ffffffffffffffff, type=stream0/13.inputPort, upstreamIdentifier=12.output.11, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received publisher request: PublishRequestTuple{version=1.0, identifier=13.outputPort.13, windowId=ffffffffffffffff} Apr 13, 2018 10:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/2.output.2, windowId=ffffffffffffffff, type=stream15/3.input, upstreamIdentifier=2.output.2, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 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=stream1,sourceNodeId=15,sourcePortName=out,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream12,bufferServer=localhost]]]] Apr 13, 2018 10:49:35 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:49:35 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=stream2,bufferServer=localhost]]]] Apr 13, 2018 10:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/15.out.15, windowId=ffffffffffffffff, type=stream1/16.input, upstreamIdentifier=15.out.15, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 PM com.datatorrent.stram.engine.Node emitEndStream INFO: 13 sending EndOfStream Apr 13, 2018 10:49:35 PM com.datatorrent.stram.engine.WindowGenerator activate INFO: Catching up from 1523659773500 to 1523659775111 Apr 13, 2018 10:49:35 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:49:35 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:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/3.output.3, windowId=ffffffffffffffff, type=stream10/4.input, upstreamIdentifier=3.output.3, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 PM com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage INFO: Received subscriber request: SubscribeRequestTuple{version=1.0, identifier=tcp://localhost:59341/16.output.16, windowId=ffffffffffffffff, type=stream12/17.input, upstreamIdentifier=16.output.16, mask=0, partitions=null, bufferSize=1024} Apr 13, 2018 10:49:35 PM com.datatorrent.stram.engine.Node emitEndStream INFO: 1 sending EndOfStream Apr 13, 2018 10:49:35 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 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:49:36 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:36 PM com.datatorrent.stram.engine.StreamingContainer processHeartbeatResponse INFO: Undeploy request: [12] Apr 13, 2018 10:49:36 PM com.datatorrent.stram.engine.StreamingContainer undeploy INFO: Undeploy complete. Apr 13, 2018 10:49:36 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@21454fa3identifier=tcp://localhost:59341/12.output.11, upstream=12.output.11, group=stream0/13.inputPort, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5fa6170d{da=com.datatorrent.bufferserver.internal.DataList$Block@4d00ef02{identifier=12.output.11, data=1048576, readingOffset=0, writingOffset=77, starting_window=5ad133fd00000001, ending_window=5ad133fd00000002, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl com.datatorrent.bufferserver.internal.DataList@207b3231 {12.output.11} Apr 13, 2018 10:49:37 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:37 PM com.datatorrent.stram.Journal write WARNING: Journal output stream is null. Skipping write to the WAL. Apr 13, 2018 10:49:37 PM com.datatorrent.stram.engine.StreamingContainer processHeartbeatResponse INFO: Undeploy request: [13] Apr 13, 2018 10:49:37 PM com.datatorrent.stram.engine.StreamingContainer processHeartbeatResponse INFO: Undeploy request: [1] Apr 13, 2018 10:49:37 PM com.datatorrent.stram.engine.StreamingContainer undeploy INFO: Undeploy complete. Apr 13, 2018 10:49:37 PM com.datatorrent.stram.engine.StreamingContainer undeploy INFO: Undeploy complete. Apr 13, 2018 10:49:37 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@2969298identifier=tcp://localhost:59341/1.output.1, upstream=1.output.1, group=stream2/2.input, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5ac5057b{da=com.datatorrent.bufferserver.internal.DataList$Block@35b46f51{identifier=1.output.1, data=1048576, readingOffset=0, writingOffset=123, starting_window=5ad133fd00000001, ending_window=5ad133fd00000003, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl com.datatorrent.bufferserver.internal.DataList@7f86ee1a {1.output.1} Apr 13, 2018 10:49:37 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@4f79b97fidentifier=tcp://localhost:59341/13.outputPort.13, upstream=13.outputPort.13, group=stream14/15.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@695b161{da=com.datatorrent.bufferserver.internal.DataList$Block@74099215{identifier=13.outputPort.13, data=1048576, readingOffset=0, writingOffset=77, starting_window=5ad133fd00000001, ending_window=5ad133fd00000002, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl com.datatorrent.bufferserver.internal.DataList@6251a522 {13.outputPort.13} Apr 13, 2018 10:49:38 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. Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x000000070c700000, 539492352, 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 539492352 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_pid11365.log> :beam-runners-apex:validatesRunnerBatch FAILED :beam-runners-apex:validatesRunnerBatch (Thread[Task worker for ':',5,main]) completed. Took 18 mins 52.98 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 20m 29s 32 actionable tasks: 32 executed Publishing build scan... https://gradle.com/s/iwjxcaqica54u 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