See 
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/736/display/redirect?page=changes>

Changes:

[kirpichov] [BEAM-4291] Implements distributed artifact retrieval

[kirpichov] Deletes ArtifactSource

------------------------------------------
[...truncated 27.62 MB...]
    Jun 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 AM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-20 terminating.
    Jun 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@575459a9identifier=tcp://localhost:36377/4.output.3, 
upstream=4.output.3, group=stream56/6.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7b682d1c{da=com.datatorrent.bufferserver.internal.DataList$Block@70936025{identifier=4.output.3,
 data=1048576, readingOffset=0, writingOffset=2381, 
starting_window=5b2327dd00000001, ending_window=5b2327dd0000000a, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1b5fe65f[identifier=4.output.3]
    Jun 15, 2018 2:43:45 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 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@5f2715bfidentifier=tcp://localhost:36377/1.output.1, 
upstream=1.output.1, group=stream3/3.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@391c81d1{da=com.datatorrent.bufferserver.internal.DataList$Block@3264b23{identifier=1.output.1,
 data=1048576, readingOffset=0, writingOffset=2381, 
starting_window=5b2327dd00000001, ending_window=5b2327dd0000000a, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@68df912a[identifier=1.output.1]
    Jun 15, 2018 2:43:45 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 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@5b726583identifier=tcp://localhost:36377/12.output.10, 
upstream=12.output.10, group=stream84/13.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@cd6ef70{da=com.datatorrent.bufferserver.internal.DataList$Block@5119f532{identifier=12.output.10,
 data=1048576, readingOffset=0, writingOffset=2381, 
starting_window=5b2327dd00000001, ending_window=5b2327dd0000000a, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6057c361[identifier=12.output.10]
    Jun 15, 2018 2:43:45 AM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-67 terminating.
    Jun 15, 2018 2:43:45 AM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-73 terminating.
    Jun 15, 2018 2:43:45 AM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-30 terminating.
    Jun 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@5b3a0680identifier=tcp://localhost:36377/2.output.2, 
upstream=2.output.2, group=stream80/3.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@74954880{da=com.datatorrent.bufferserver.internal.DataList$Block@4f83840d{identifier=2.output.2,
 data=1048576, readingOffset=0, writingOffset=2381, 
starting_window=5b2327dd00000001, ending_window=5b2327dd0000000a, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@512d48aa[identifier=2.output.2]
    Jun 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 AM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-26 terminating.
    Jun 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@676027f6identifier=tcp://localhost:36377/11.output.9, 
upstream=11.output.9, group=stream71/13.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@f3fd525{da=com.datatorrent.bufferserver.internal.DataList$Block@51305d0a{identifier=11.output.9,
 data=1048576, readingOffset=0, writingOffset=2381, 
starting_window=5b2327dd00000001, ending_window=5b2327dd0000000a, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@24018cd[identifier=11.output.9]
    Jun 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 AM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-38 terminating.
    Jun 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@527b0e15identifier=tcp://localhost:36377/17.output.16, 
upstream=17.output.16, group=stream139/18.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@39937837{da=com.datatorrent.bufferserver.internal.DataList$Block@487414dd{identifier=17.output.16,
 data=1048576, readingOffset=0, writingOffset=2381, 
starting_window=5b2327dd00000001, ending_window=5b2327dd0000000a, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1b7fc8d4[identifier=17.output.16]
    Jun 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 AM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-11 terminating.
    Jun 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@28cc0344identifier=tcp://localhost:36377/9.output.8, 
upstream=9.output.8, group=stream95/10.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@197b2d06{da=com.datatorrent.bufferserver.internal.DataList$Block@3b8bbcde{identifier=9.output.8,
 data=1048576, readingOffset=0, writingOffset=2353, 
starting_window=5b2327dd00000001, ending_window=5b2327dd0000000a, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@53b1858e[identifier=9.output.8]
    Jun 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 AM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-51 terminating.
    Jun 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@43d0dcedidentifier=tcp://localhost:36377/8.output.7, 
upstream=8.output.7, group=stream53/10.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@36edde44{da=com.datatorrent.bufferserver.internal.DataList$Block@763ed682{identifier=8.output.7,
 data=1048576, readingOffset=0, writingOffset=2281, 
starting_window=5b2327dd00000001, ending_window=5b2327dd0000000a, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@10b5e9d7[identifier=8.output.7]
    Jun 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 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 15, 2018 2:43:45 AM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-25 terminating.
    Jun 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@1345f906identifier=tcp://localhost:36377/5.output.4, 
upstream=5.output.4, group=stream143/6.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@4ff783ba{da=com.datatorrent.bufferserver.internal.DataList$Block@17b07bfe{identifier=5.output.4,
 data=1048576, readingOffset=0, writingOffset=2381, 
starting_window=5b2327dd00000001, ending_window=5b2327dd0000000a, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@173a254c[identifier=5.output.4]
    Jun 15, 2018 2:43:45 AM com.datatorrent.bufferserver.server.Server$1 run
    INFO: Server stopped listening at /0:0:0:0:0:0:0:0:36377
    Jun 15, 2018 2:43:45 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.38 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.271 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 
13,5,main]) completed. Took 28 mins 17.004 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 38s
32 actionable tasks: 28 executed, 4 from cache

Publishing build scan...
https://gradle.com/s/bjywdwoa3nreo

Build cache (/home/jenkins/.gradle/caches/build-cache-1) remove files older 
than Fri Jun 08 02:14:12 UTC 2018.
Build cache (/home/jenkins/.gradle/caches/build-cache-1) removing 7688 cache 
entries (467 MB reclaimed).
Build cache (/home/jenkins/.gradle/caches/build-cache-1) cleaned up in 0.639 
secs.
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 apill...@google.com
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 ringw...@google.com
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
Not sending mail to unregistered user jiang...@gmail.com
Not sending mail to unregistered user kirpic...@google.com
Not sending mail to unregistered user fvoich...@gmail.com

Reply via email to