See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/721/display/redirect?page=changes>
Changes: [swegner] Revert "Merge pull request #5611: [BEAM-4445] Filter pre-commit ------------------------------------------ [...truncated 27.60 MB...] Jun 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-14 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@7f74f52fidentifier=tcp://localhost:33933/23.output.24, upstream=23.output.24, group=stream92/24.input, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2c02098b{da=com.datatorrent.bufferserver.internal.DataList$Block@63930320{identifier=23.output.24, data=1048576, readingOffset=0, writingOffset=98, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@72233497[identifier=23.output.24] Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@62484c89identifier=tcp://localhost:33933/23.output.25, upstream=23.output.25, group=stream92/55.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@51578ea1{da=com.datatorrent.bufferserver.internal.DataList$Block@6d259b51{identifier=23.output.25, data=1048576, readingOffset=0, writingOffset=98, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@16541fd6[identifier=23.output.25] Jun 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=5,name=split4,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream143,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 14, 2018 5:57:35 AM 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=stream139,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 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-38 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 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=4,name=split5,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream56,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 14, 2018 5:57:35 AM 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=stream53,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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-20 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 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-25 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@4c518035identifier=tcp://localhost:33933/17.output.16, upstream=17.output.16, group=stream139/18.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7db80607{da=com.datatorrent.bufferserver.internal.DataList$Block@1077bd97{identifier=17.output.16, data=1048576, readingOffset=0, writingOffset=2375, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@51c953db[identifier=17.output.16] Jun 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-51 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-20 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@17a650eaidentifier=tcp://localhost:33933/5.output.4, upstream=5.output.4, group=stream143/6.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@67555c9b{da=com.datatorrent.bufferserver.internal.DataList$Block@5ae0e648{identifier=5.output.4, data=1048576, readingOffset=0, writingOffset=2375, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@77d67386[identifier=5.output.4] Jun 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-38 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@66aff889identifier=tcp://localhost:33933/4.output.3, upstream=4.output.3, group=stream56/6.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6c9ab12c{da=com.datatorrent.bufferserver.internal.DataList$Block@21e699a0{identifier=4.output.3, data=1048576, readingOffset=0, writingOffset=2375, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@7c69e972[identifier=4.output.3] Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@13f8729didentifier=tcp://localhost:33933/8.output.7, upstream=8.output.7, group=stream53/10.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3867ef3a{da=com.datatorrent.bufferserver.internal.DataList$Block@14d2acb{identifier=8.output.7, data=1048576, readingOffset=0, writingOffset=2275, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@147398db[identifier=8.output.7] Jun 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=9,name=split1,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream95,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 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-11 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@2db45273identifier=tcp://localhost:33933/9.output.8, upstream=9.output.8, group=stream95/10.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2762c15e{da=com.datatorrent.bufferserver.internal.DataList$Block@207be4b7{identifier=9.output.8, data=1048576, readingOffset=0, writingOffset=2347, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@48088901[identifier=9.output.8] Jun 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=11,name=split3,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 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-26 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@7e7e928identifier=tcp://localhost:33933/11.output.9, upstream=11.output.9, group=stream71/13.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4035759b{da=com.datatorrent.bufferserver.internal.DataList$Block@716c34f2{identifier=11.output.9, data=1048576, readingOffset=0, writingOffset=2375, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@ecd2834[identifier=11.output.9] Jun 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=12,name=split2,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream84,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 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-67 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@7fdc970cidentifier=tcp://localhost:33933/12.output.10, upstream=12.output.10, group=stream84/13.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@281e86d{da=com.datatorrent.bufferserver.internal.DataList$Block@6973dc0b{identifier=12.output.10, data=1048576, readingOffset=0, writingOffset=2375, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@7928be73[identifier=12.output.10] Jun 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=2,name=split6,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream80,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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-30 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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-30 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@4c060b60identifier=tcp://localhost:33933/2.output.2, upstream=2.output.2, group=stream80/3.data1, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1ec3a5ea{da=com.datatorrent.bufferserver.internal.DataList$Block@130cf4df{identifier=2.output.2, data=1048576, readingOffset=0, writingOffset=2375, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@6468f131[identifier=2.output.2] Jun 14, 2018 5:57:35 AM 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 14, 2018 5:57:35 AM com.datatorrent.stram.engine.StreamingContainer$2 run SEVERE: Operator set [OperatorDeployInfo[id=1,name=split7,type=INPUT,checkpoint={ffffffffffffffff, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream3,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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log INFO: container-73 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 14, 2018 5:57:35 AM com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run INFO: Container container-73 terminating. Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$3 run INFO: Removing ln LogicalNode@4d9be75fidentifier=tcp://localhost:33933/1.output.1, upstream=1.output.1, group=stream3/3.data2, partitions=[], iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@580f00e9{da=com.datatorrent.bufferserver.internal.DataList$Block@5b6002f7{identifier=1.output.1, data=1048576, readingOffset=0, writingOffset=2375, starting_window=5b2203cb00000001, ending_window=5b2203cb00000009, refCount=2, uniqueIdentifier=0, next=null, future=null}}} from dl DataList@2f3eaf48[identifier=1.output.1] Jun 14, 2018 5:57:35 AM com.datatorrent.bufferserver.server.Server$1 run INFO: Server stopped listening at /0:0:0:0:0:0:0:0:33933 Jun 14, 2018 5:57:35 AM 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.325 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.277 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 28 mins 1.448 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 54s 32 actionable tasks: 28 executed, 4 from cache Publishing build scan... https://gradle.com/s/2dmq4utldo2ba 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 robbe.sneyd...@ml6.eu Not sending mail to unregistered user git...@alasdairhodge.co.uk Not sending mail to unregistered user aal...@gmail.com Not sending mail to unregistered user sweg...@google.com Not sending mail to unregistered user robi...@rodete-desktop-imager.corp.google.com