See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/760/display/redirect>
------------------------------------------ [...truncated 27.65 MB...] INFO: Container container-74 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@c93c042identifier=tcp://localhost:40255/81.output.83, upstream=81.output.83, group=stream51/82.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@233eb81c{da=com.datatorrent.bufferserver.internal.DataList$Block@329392d7{identifier=81.output.83, data=1048576, readingOffset=0, writingOffset=84, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@49d32cb9[identifier=81.output.83] Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@58be36f8identifier=tcp://localhost:40255/41.output.42, upstream=41.output.42, group=stream21/42.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@209d536a{da=com.datatorrent.bufferserver.internal.DataList$Block@76b5f13d{identifier=41.output.42, data=1048576, readingOffset=0, writingOffset=84, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@589ec016[identifier=41.output.42] Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@7fdf3940identifier=tcp://localhost:40255/137.output.139, upstream=137.output.139, group=stream55/138.sideInput1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@8788958{da=com.datatorrent.bufferserver.internal.DataList$Block@42b49d3e{identifier=137.output.139, data=1048576, readingOffset=0, writingOffset=96, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@1bd1b04c[identifier=137.output.139] Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@24f01644identifier=tcp://localhost:40255/67.output.68, upstream=67.output.68, group=stream81/68.input, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@35615d50{da=com.datatorrent.bufferserver.internal.DataList$Block@791f20ed{identifier=67.output.68, data=1048576, readingOffset=0, writingOffset=96, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@1fa41f9d[identifier=67.output.68] Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@3733b240identifier=tcp://localhost:40255/18.out.18, upstream=18.out.18, group=stream133/19.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@9618ff5{da=com.datatorrent.bufferserver.internal.DataList$Block@36d5d854{identifier=18.out.18, data=1048576, readingOffset=0, writingOffset=18341, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@364d8e2b[identifier=18.out.18] Jun 17, 2018 7:34:12 PM com.datatorrent.stram.util.LoggerUtil getFileAppender WARNING: Log information is unavailable. To enable log information log4j/logging should be configured with single FileAppender that has immediateFlush set to true and log level set to ERROR or greater. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=1,name=split9,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream0,bufferServer=localhost]]]] stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-25 msg: Stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-25 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@65f779cidentifier=tcp://localhost:40255/1.output.1, upstream=1.output.1, group=stream0/3.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@9aa3788{da=com.datatorrent.bufferserver.internal.DataList$Block@cb10f6f{identifier=1.output.1, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@143e61d5[identifier=1.output.1] Jun 17, 2018 7:34:12 PM com.datatorrent.stram.util.LoggerUtil getFileAppender WARNING: Log information is unavailable. To enable log information log4j/logging should be configured with single FileAppender that has immediateFlush set to true and log level set to ERROR or greater. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=7,name=split4,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream48,bufferServer=localhost]]]] stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-26 msg: Stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-26 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@51b557dfidentifier=tcp://localhost:40255/7.output.5, upstream=7.output.5, group=stream48/9.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4ed899af{da=com.datatorrent.bufferserver.internal.DataList$Block@1696f18b{identifier=7.output.5, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@12d84e41[identifier=7.output.5] Jun 17, 2018 7:34:12 PM com.datatorrent.stram.util.LoggerUtil getFileAppender WARNING: Log information is unavailable. To enable log information log4j/logging should be configured with single FileAppender that has immediateFlush set to true and log level set to ERROR or greater. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=15,name=split0,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream91,bufferServer=localhost]]]] stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-12 msg: Stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-12 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@673681b4identifier=tcp://localhost:40255/15.output.12, upstream=15.output.12, group=stream91/16.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@758fa506{da=com.datatorrent.bufferserver.internal.DataList$Block@7f104ff9{identifier=15.output.12, data=1048576, readingOffset=0, writingOffset=2269, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@5eabf339[identifier=15.output.12] Jun 17, 2018 7:34:12 PM com.datatorrent.stram.util.LoggerUtil getFileAppender WARNING: Log information is unavailable. To enable log information log4j/logging should be configured with single FileAppender that has immediateFlush set to true and log level set to ERROR or greater. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=5,name=split7,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream134,bufferServer=localhost]]]] stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-11 msg: Stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-11 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@5a8bd5e4identifier=tcp://localhost:40255/5.output.4, upstream=5.output.4, group=stream134/6.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@e5104eb{da=com.datatorrent.bufferserver.internal.DataList$Block@67e27b2{identifier=5.output.4, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@7beccf03[identifier=5.output.4] Jun 17, 2018 7:34:12 PM com.datatorrent.stram.util.LoggerUtil getFileAppender WARNING: Log information is unavailable. To enable log information log4j/logging should be configured with single FileAppender that has immediateFlush set to true and log level set to ERROR or greater. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=14,name=split1,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream76,bufferServer=localhost]]]] stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-4 msg: Stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.util.LoggerUtil getFileAppender WARNING: Log information is unavailable. To enable log information log4j/logging should be configured with single FileAppender that has immediateFlush set to true and log level set to ERROR or greater. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-4 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=4,name=split6,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream4,bufferServer=localhost]]]] stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@2fdd6351identifier=tcp://localhost:40255/14.output.11, upstream=14.output.11, group=stream76/16.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7a5fd97c{da=com.datatorrent.bufferserver.internal.DataList$Block@7c2ffc80{identifier=14.output.11, data=1048576, readingOffset=0, writingOffset=2341, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@b9b0700[identifier=14.output.11] Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-51 msg: Stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-51 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@347fc0c3identifier=tcp://localhost:40255/4.output.3, upstream=4.output.3, group=stream4/6.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@169255a7{da=com.datatorrent.bufferserver.internal.DataList$Block@1282fa30{identifier=4.output.3, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@114adf1c[identifier=4.output.3] Jun 17, 2018 7:34:12 PM com.datatorrent.stram.util.LoggerUtil getFileAppender WARNING: Log information is unavailable. To enable log information log4j/logging should be configured with single FileAppender that has immediateFlush set to true and log level set to ERROR or greater. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.util.LoggerUtil getFileAppender WARNING: Log information is unavailable. To enable log information log4j/logging should be configured with single FileAppender that has immediateFlush set to true and log level set to ERROR or greater. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=8,name=split5,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream72,bufferServer=localhost]]]] stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=11,name=split2,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream65,bufferServer=localhost]]]] stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-67 msg: Stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-56 msg: Stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-67 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-56 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@7f0be9fdidentifier=tcp://localhost:40255/11.output.9, upstream=11.output.9, group=stream65/13.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@42ba6932{da=com.datatorrent.bufferserver.internal.DataList$Block@460123af{identifier=11.output.9, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@43d70225[identifier=11.output.9] Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@6784d7dcidentifier=tcp://localhost:40255/8.output.6, upstream=8.output.6, group=stream72/9.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4a2977c{da=com.datatorrent.bufferserver.internal.DataList$Block@15409d23{identifier=8.output.6, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@5a13d87f[identifier=8.output.6] Jun 17, 2018 7:34:12 PM com.datatorrent.stram.util.LoggerUtil getFileAppender WARNING: Log information is unavailable. To enable log information log4j/logging should be configured with single FileAppender that has immediateFlush set to true and log level set to ERROR or greater. Jun 17, 2018 7:34:12 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=2,name=split8,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream8,bufferServer=localhost]]]] stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-28 msg: Stopped running due to an exception. com.datatorrent.api.Operator$ShutdownException at com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96) at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116) at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429) Jun 17, 2018 7:34:12 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-28 terminating. Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@6220f087identifier=tcp://localhost:40255/2.output.2, upstream=2.output.2, group=stream8/3.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@21ae3f32{da=com.datatorrent.bufferserver.internal.DataList$Block@31a7550c{identifier=2.output.2, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b26b7b100000001, ending_window=5b26b7b100000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@201f7f9e[identifier=2.output.2] Jun 17, 2018 7:34:12 PM com.datatorrent.bufferserver.server.Server$1 run INFO: Server stopped listening at /0:0:0:0:0:0:0:0:40255 Jun 17, 2018 7:34:12 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.307 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.236 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 ':',5,main]) completed. Took 27 mins 50.722 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/liouumpmltuvm Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure Recording test results