See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/715/display/redirect?page=changes>
Changes:
[robbe.sneyders] Futurize utils subpackage
[aaltay] Futurize portability subpackage (#5385)
[altay] Futurize unpackaged files
[altay] resolved six.string_types equivalency
------------------------------------------
[...truncated 27.66 MB...]
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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-20 terminating.
Jun 13, 2018 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@7bf83242identifier=tcp://localhost:37375/9.output.8,
upstream=9.output.8, group=stream67/10.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@574ff02a{da=com.datatorrent.bufferserver.internal.DataList$Block@53b24a44{identifier=9.output.8,
data=1048576, readingOffset=0, writingOffset=2375,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@4d273825[identifier=9.output.8]
Jun 13, 2018 7:08: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 7:08:34 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=5,name=split7,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream91,bufferServer=localhost]]]]
stopped running due to an exception.
com.datatorrent.api.Operator$ShutdownException
at
com.datatorrent.common.util.BaseOperator.shutdown(BaseOperator.java:96)
at
org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.endWindow(ApexReadUnboundedInputOperator.java:116)
at com.datatorrent.stram.engine.InputNode.run(InputNode.java:229)
at
com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1429)
Jun 13, 2018 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-34 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 7:08: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 7:08:34 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=2,name=split5,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream130,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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-34 terminating.
Jun 13, 2018 7:08: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 7:08:34 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 7:08:34 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=11,name=split1,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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-27 terminating.
Jun 13, 2018 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@61d1460eidentifier=tcp://localhost:37375/5.output.4,
upstream=5.output.4, group=stream91/6.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5c7fe680{da=com.datatorrent.bufferserver.internal.DataList$Block@74999385{identifier=5.output.4,
data=1048576, readingOffset=0, writingOffset=2375,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@35380738[identifier=5.output.4]
Jun 13, 2018 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-54 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 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@ae854e3identifier=tcp://localhost:37375/2.output.2,
upstream=2.output.2, group=stream130/3.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@412ae7aa{da=com.datatorrent.bufferserver.internal.DataList$Block@624242e9{identifier=2.output.2,
data=1048576, readingOffset=0, writingOffset=2375,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@5a7ff09f[identifier=2.output.2]
Jun 13, 2018 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-54 terminating.
Jun 13, 2018 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@36e7ac97identifier=tcp://localhost:37375/11.output.9,
upstream=11.output.9, group=stream12/13.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2f0b3d2f{da=com.datatorrent.bufferserver.internal.DataList$Block@390a98d3{identifier=11.output.9,
data=1048576, readingOffset=0, writingOffset=2347,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@492fc011[identifier=11.output.9]
Jun 13, 2018 7:08: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 7:08: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 7:08:34 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=12,name=split0,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream42,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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-15 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 7:08:34 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=17,name=split9,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream121,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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-15 terminating.
Jun 13, 2018 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-7 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 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1e296e6bidentifier=tcp://localhost:37375/12.output.10,
upstream=12.output.10, group=stream42/13.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6c713aa3{da=com.datatorrent.bufferserver.internal.DataList$Block@1ae58047{identifier=12.output.10,
data=1048576, readingOffset=0, writingOffset=2275,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@77445fc8[identifier=12.output.10]
Jun 13, 2018 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-7 terminating.
Jun 13, 2018 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@3eee4088identifier=tcp://localhost:37375/17.output.16,
upstream=17.output.16, group=stream121/18.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@405c2679{da=com.datatorrent.bufferserver.internal.DataList$Block@259db8f3{identifier=17.output.16,
data=1048576, readingOffset=0, writingOffset=2375,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@13ccf3bf[identifier=17.output.16]
Jun 13, 2018 7:08: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 7:08:34 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=4,name=split6,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream16,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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-22 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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-22 terminating.
Jun 13, 2018 7:08: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 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@37d62715identifier=tcp://localhost:37375/4.output.3,
upstream=4.output.3, group=stream16/6.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@46a35411{da=com.datatorrent.bufferserver.internal.DataList$Block@67edcd52{identifier=4.output.3,
data=1048576, readingOffset=0, writingOffset=2375,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2fffab7c[identifier=4.output.3]
Jun 13, 2018 7:08:34 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=1,name=split4,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream73,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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-69 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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-69 terminating.
Jun 13, 2018 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@23384fdfidentifier=tcp://localhost:37375/1.output.1,
upstream=1.output.1, group=stream73/3.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5bdae437{da=com.datatorrent.bufferserver.internal.DataList$Block@7052081{identifier=1.output.1,
data=1048576, readingOffset=0, writingOffset=2375,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@e0bfa6e[identifier=1.output.1]
Jun 13, 2018 7:08: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 7:08:34 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=8,name=split3,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream14,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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-23 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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-23 terminating.
Jun 13, 2018 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1ce3ad7cidentifier=tcp://localhost:37375/8.output.7,
upstream=8.output.7, group=stream14/10.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@5cfd0498{da=com.datatorrent.bufferserver.internal.DataList$Block@500ab86c{identifier=8.output.7,
data=1048576, readingOffset=0, writingOffset=2375,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@7e258bc4[identifier=8.output.7]
Jun 13, 2018 7:08: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 7:08:34 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=16,name=split8,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream107,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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-63 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 7:08:34 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-63 terminating.
Jun 13, 2018 7:08:34 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@6ce094f7identifier=tcp://localhost:37375/16.output.15,
upstream=16.output.15, group=stream107/18.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2f2cc6e4{da=com.datatorrent.bufferserver.internal.DataList$Block@1bc1de5d{identifier=16.output.15,
data=1048576, readingOffset=0, writingOffset=2375,
starting_window=5b216bae00000001, ending_window=5b216bae00000009, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@1e8dcc91[identifier=16.output.15]
Jun 13, 2018 7:08:34 PM com.datatorrent.bufferserver.server.Server$1 run
INFO: Server stopped listening at /0:0:0:0:0:0:0:0:37375
Jun 13, 2018 7:08: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.281 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.265 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
6,5,main]) completed. Took 28 mins 2.009 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 57s
32 actionable tasks: 28 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/en7s7ji4gxdbu
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
