See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/714/display/redirect>
------------------------------------------ [...truncated 27.67 MB...] Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@5721a7cfidentifier=tcp://localhost:33003/133.output.144, upstream=133.output.144, group=stream139/144.input, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@42c3f6ec{da=com.datatorrent.bufferserver.internal.DataList$Block@3bab612c{identifier=133.output.144, data=1048576, readingOffset=0, writingOffset=95, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@2a19406f[identifier=133.output.144] Jun 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-69 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@4cef54f0identifier=tcp://localhost:33003/47.output.48, upstream=47.output.48, group=stream49/48.input, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3e3debcd{da=com.datatorrent.bufferserver.internal.DataList$Block@63941e70{identifier=47.output.48, data=1048576, readingOffset=0, writingOffset=106, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@356b12f[identifier=47.output.48] Jun 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-25 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@2471915bidentifier=tcp://localhost:33003/78.output.79, upstream=78.output.79, group=stream91/79.input, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@63ac9312{da=com.datatorrent.bufferserver.internal.DataList$Block@329e6f29{identifier=78.output.79, data=1048576, readingOffset=0, writingOffset=95, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@713a8094[identifier=78.output.79] Jun 13, 2018 6:39:14 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 13, 2018 6:39:14 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=8,name=split0,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream35,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 13, 2018 6:39:14 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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-56 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@64fa7692identifier=tcp://localhost:33003/8.output.7, upstream=8.output.7, group=stream35/10.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@47539855{da=com.datatorrent.bufferserver.internal.DataList$Block@40e0b7ae{identifier=8.output.7, data=1048576, readingOffset=0, writingOffset=2269, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@1467fbc[identifier=8.output.7] Jun 13, 2018 6:39:14 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 13, 2018 6:39:14 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=stream12,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 13, 2018 6:39:14 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 13, 2018 6:39:14 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 13, 2018 6:39:14 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 13, 2018 6:39:14 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=5,name=split6,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream108,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 13, 2018 6:39:14 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=2,name=split4,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream118,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 13, 2018 6:39:14 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 13, 2018 6:39:14 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 13, 2018 6:39:14 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=4,name=split7,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream29,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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-5 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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-12 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@1db506f8identifier=tcp://localhost:33003/2.output.2, upstream=2.output.2, group=stream118/3.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@24dd6120{da=com.datatorrent.bufferserver.internal.DataList$Block@7f17d4de{identifier=2.output.2, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@3a0f5155[identifier=2.output.2] Jun 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-67 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@1ff2ae78identifier=tcp://localhost:33003/5.output.4, upstream=5.output.4, group=stream108/6.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@8866237{da=com.datatorrent.bufferserver.internal.DataList$Block@471dc666{identifier=5.output.4, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@6ed4b7f[identifier=5.output.4] Jun 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-5 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@42296215identifier=tcp://localhost:33003/11.output.9, upstream=11.output.9, group=stream12/13.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@46a8270e{da=com.datatorrent.bufferserver.internal.DataList$Block@7d846236{identifier=11.output.9, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@5483a516[identifier=11.output.9] Jun 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-27 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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-27 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@7b40403bidentifier=tcp://localhost:33003/4.output.3, upstream=4.output.3, group=stream29/6.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@38d9ba4a{da=com.datatorrent.bufferserver.internal.DataList$Block@3f4e7a08{identifier=4.output.3, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@61053a05[identifier=4.output.3] Jun 13, 2018 6:39:14 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 13, 2018 6:39:14 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=12,name=split3,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream120,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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-13 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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-13 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@2a2299e9identifier=tcp://localhost:33003/12.output.10, upstream=12.output.10, group=stream120/13.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@28679826{da=com.datatorrent.bufferserver.internal.DataList$Block@5d997c8a{identifier=12.output.10, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@114bc30b[identifier=12.output.10] Jun 13, 2018 6:39:14 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 13, 2018 6:39:14 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=1,name=split5,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream109,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 13, 2018 6:39:14 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 13, 2018 6:39:14 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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-51 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=16,name=split9,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream71,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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-78 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 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@360774eidentifier=tcp://localhost:33003/1.output.1, upstream=1.output.1, group=stream109/3.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@59561635{da=com.datatorrent.bufferserver.internal.DataList$Block@4de41391{identifier=1.output.1, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@5b8f4b8b[identifier=1.output.1] Jun 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-78 terminating. Jun 13, 2018 6:39:14 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 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@408136fcidentifier=tcp://localhost:33003/16.output.15, upstream=16.output.15, group=stream71/18.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1413886a{da=com.datatorrent.bufferserver.internal.DataList$Block@7d1dc363{identifier=16.output.15, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@10082fca[identifier=16.output.15] Jun 13, 2018 6:39:14 PM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=17,name=split8,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream128,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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-42 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 13, 2018 6:39:14 PM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-42 terminating. Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@647c0f78identifier=tcp://localhost:33003/17.output.16, upstream=17.output.16, group=stream128/18.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@31faed53{da=com.datatorrent.bufferserver.internal.DataList$Block@39a263de{identifier=17.output.16, data=1048576, readingOffset=0, writingOffset=2369, starting_window=5b2164cf00000001, ending_window=5b2164cf00000008, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@2a37b952[identifier=17.output.16] Jun 13, 2018 6:39:14 PM com.datatorrent.bufferserver.server.Server$1 run INFO: Server stopped listening at /0:0:0:0:0:0:0:0:33003 Jun 13, 2018 6:39:14 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.32 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.289 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/ws/src/runners/apex/build/reports/tests/validatesRunnerBatch> :beam-runners-apex:validatesRunnerBatch (Thread[Task worker for ':' Thread 15,5,main]) completed. Took 27 mins 47.131 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 29m 16s 32 actionable tasks: 29 executed, 3 from cache Publishing build scan... https://gradle.com/s/2irlk6cp4ksz2 Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure Recording test results Not sending mail to unregistered user git...@alasdairhodge.co.uk