See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/711/display/redirect?page=changes>
Changes:
[lcwik] [BEAM-4540] Migrate junit/hamcrest to provided scope.
------------------------------------------
[...truncated 27.64 MB...]
INFO: Container container-14 terminating.
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@64b4ad18identifier=tcp://localhost:42693/18.out.18,
upstream=18.out.18, group=stream37/19.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5f0bfc3{da=com.datatorrent.bufferserver.internal.DataList$Block@774d3bb7{identifier=18.out.18,
data=1048576, readingOffset=0, writingOffset=4687,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@5d6be505[identifier=18.out.18]
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@4182e75cidentifier=tcp://localhost:42693/15.out.17,
upstream=15.out.17, group=stream14/19.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2ea0120f{da=com.datatorrent.bufferserver.internal.DataList$Block@2eaebebf{identifier=15.out.17,
data=1048576, readingOffset=0, writingOffset=18359,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@3020a85e[identifier=15.out.17]
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@cf416d5identifier=tcp://localhost:42693/23.output.24,
upstream=23.output.24, group=stream92/24.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@32e12092{da=com.datatorrent.bufferserver.internal.DataList$Block@1cff6cab{identifier=23.output.24,
data=1048576, readingOffset=0, writingOffset=110,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@47ff62cd[identifier=23.output.24]
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@57ea0130identifier=tcp://localhost:42693/23.output.25,
upstream=23.output.25, group=stream92/55.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@72a84034{da=com.datatorrent.bufferserver.internal.DataList$Block@49f60b43{identifier=23.output.25,
data=1048576, readingOffset=0, writingOffset=110,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2e0bace2[identifier=23.output.25]
Jun 13, 2018 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-39 terminating.
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@2b53c4a8identifier=tcp://localhost:42693/77.output.78,
upstream=77.output.78, group=stream109/78.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@12de4ae4{da=com.datatorrent.bufferserver.internal.DataList$Block@22c7016b{identifier=77.output.78,
data=1048576, readingOffset=0, writingOffset=109,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@5b92aa63[identifier=77.output.78]
Jun 13, 2018 4:07:34 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 4:07:34 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 4:07:34 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 4:07:34 PM 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 13, 2018 4:07:34 PM 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 13, 2018 4:07:34 PM
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 13, 2018 4:07:34 PM 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 13, 2018 4:07:34 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 13, 2018 4:07:34 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 13, 2018 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-30 terminating.
Jun 13, 2018 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-25 terminating.
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@21bdacd2identifier=tcp://localhost:42693/2.output.2,
upstream=2.output.2, group=stream80/3.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@288d714f{da=com.datatorrent.bufferserver.internal.DataList$Block@48e497d0{identifier=2.output.2,
data=1048576, readingOffset=0, writingOffset=2387,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@52b21bfe[identifier=2.output.2]
Jun 13, 2018 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-26 terminating.
Jun 13, 2018 4:07:34 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 4:07:34 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 4:07:34 PM 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 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@16d1ac71identifier=tcp://localhost:42693/5.output.4,
upstream=5.output.4, group=stream143/6.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1cbd6279{da=com.datatorrent.bufferserver.internal.DataList$Block@5ff97fa8{identifier=5.output.4,
data=1048576, readingOffset=0, writingOffset=2387,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@334f2990[identifier=5.output.4]
Jun 13, 2018 4:07:34 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 4:07:34 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=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 13, 2018 4:07:34 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=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 13, 2018 4:07:34 PM
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 13, 2018 4:07:34 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 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@3c48afc2identifier=tcp://localhost:42693/11.output.9,
upstream=11.output.9, group=stream71/13.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@71e0a9ec{da=com.datatorrent.bufferserver.internal.DataList$Block@639b303{identifier=11.output.9,
data=1048576, readingOffset=0, writingOffset=2387,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@12299853[identifier=11.output.9]
Jun 13, 2018 4:07:34 PM
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 13, 2018 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-51 terminating.
Jun 13, 2018 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-38 terminating.
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@5f48efeaidentifier=tcp://localhost:42693/17.output.16,
upstream=17.output.16, group=stream139/18.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5860202f{da=com.datatorrent.bufferserver.internal.DataList$Block@2c3b5d06{identifier=17.output.16,
data=1048576, readingOffset=0, writingOffset=2387,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@67d15229[identifier=17.output.16]
Jun 13, 2018 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-73 terminating.
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@535845b7identifier=tcp://localhost:42693/8.output.7,
upstream=8.output.7, group=stream53/10.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@39e4b580{da=com.datatorrent.bufferserver.internal.DataList$Block@605c9bcb{identifier=8.output.7,
data=1048576, readingOffset=0, writingOffset=2287,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@167929ab[identifier=8.output.7]
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@4c76c8identifier=tcp://localhost:42693/1.output.1,
upstream=1.output.1, group=stream3/3.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7bd46157{da=com.datatorrent.bufferserver.internal.DataList$Block@67009318{identifier=1.output.1,
data=1048576, readingOffset=0, writingOffset=2387,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@6306cef0[identifier=1.output.1]
Jun 13, 2018 4:07:34 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 4:07:34 PM 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 13, 2018 4:07:34 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 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-67 terminating.
Jun 13, 2018 4:07:34 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 4:07:34 PM 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 13, 2018 4:07:34 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 13, 2018 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-11 terminating.
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@669bbb48identifier=tcp://localhost:42693/9.output.8,
upstream=9.output.8, group=stream95/10.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3c6d874a{da=com.datatorrent.bufferserver.internal.DataList$Block@646b8749{identifier=9.output.8,
data=1048576, readingOffset=0, writingOffset=2359,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@710508f[identifier=9.output.8]
Jun 13, 2018 4:07:34 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 4:07:34 PM 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 13, 2018 4:07:34 PM
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 13, 2018 4:07:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-20 terminating.
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@66111c54identifier=tcp://localhost:42693/4.output.3,
upstream=4.output.3, group=stream56/6.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@52346fd3{da=com.datatorrent.bufferserver.internal.DataList$Block@233e508{identifier=4.output.3,
data=1048576, readingOffset=0, writingOffset=2387,
starting_window=5b21414100000001, ending_window=5b2141410000000b, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@3ada7bc8[identifier=4.output.3]
Jun 13, 2018 4:07:34 PM com.datatorrent.bufferserver.server.Server$1 run
INFO: Server stopped listening at /0:0:0:0:0:0:0:0:42693
Jun 13, 2018 4:07:34 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.262 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
13,5,main]) completed. Took 28 mins 4.571 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 18s
32 actionable tasks: 29 executed, 3 from cache
Publishing build scan...
https://gradle.com/s/tmre47udovn6o
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Recording test results
