See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/729/display/redirect?page=changes>
Changes:
[robertwb] Implement BeamFileSystemArtifactSource
[robertwb] Add job submission capabilities to Flink runner.
[robertwb] Update to new JobInvoker/Invocation interface.
[robertwb] Remove references to Flink distributed file cache.
[robertwb] A bit more documentation.
[robertwb] Address comments on Flink code.
------------------------------------------
[...truncated 27.89 MB...]
INFO: Container container-43 terminating.
Jun 14, 2018 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@148e74c9identifier=tcp://localhost:44177/12.output.10,
upstream=12.output.10, group=stream115/13.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@37d243d8{da=com.datatorrent.bufferserver.internal.DataList$Block@1099799f{identifier=12.output.10,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@246919d8[identifier=12.output.10]
Jun 14, 2018 10:42:58 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 14, 2018 10:42:58 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 14, 2018 10:42:58 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 14, 2018 10:42:58 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 14, 2018 10:42:58 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 14, 2018 10:42:58 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=7,name=split3,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream17,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 10:42:58 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=14,name=split7,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream98,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 10:42:58 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 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-21 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 10:42:58 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=1,name=split8,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream37,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 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-32 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 10:42:58 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=15,name=split6,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream106,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 10:42:58 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 14, 2018 10:42:58 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=5,name=split1,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream97,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 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-32 terminating.
Jun 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-37 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 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@65597844identifier=tcp://localhost:44177/14.output.11,
upstream=14.output.11, group=stream98/16.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@52d2b6f7{da=com.datatorrent.bufferserver.internal.DataList$Block@773be3f6{identifier=14.output.11,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2c35290f[identifier=14.output.11]
Jun 14, 2018 10:42:58 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=11,name=split4,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream40,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 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@2da3d59bidentifier=tcp://localhost:44177/1.output.1,
upstream=1.output.1, group=stream37/3.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@40fe4288{da=com.datatorrent.bufferserver.internal.DataList$Block@7dc316e{identifier=1.output.1,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2fd05630[identifier=1.output.1]
Jun 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-57 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 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@422dae63identifier=tcp://localhost:44177/5.output.4,
upstream=5.output.4, group=stream97/6.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2aa86f94{da=com.datatorrent.bufferserver.internal.DataList$Block@1870924b{identifier=5.output.4,
data=1048576, readingOffset=0, writingOffset=2353,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@7e41976a[identifier=5.output.4]
Jun 14, 2018 10:42:58 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 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-21 terminating.
Jun 14, 2018 10:42:58 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 14, 2018 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@6f74b8b2identifier=tcp://localhost:44177/11.output.9,
upstream=11.output.9, group=stream40/13.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@530d3f44{da=com.datatorrent.bufferserver.internal.DataList$Block@3a303e7e{identifier=11.output.9,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@26ce11b9[identifier=11.output.9]
Jun 14, 2018 10:42:58 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=8,name=split2,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream52,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 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@78f52bd2identifier=tcp://localhost:44177/15.output.12,
upstream=15.output.12, group=stream106/16.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@54c628cd{da=com.datatorrent.bufferserver.internal.DataList$Block@6e8bda0e{identifier=15.output.12,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@55f3da6f[identifier=15.output.12]
Jun 14, 2018 10:42:58 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 14, 2018 10:42:58 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 14, 2018 10:42:58 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=4,name=split0,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream96,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 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-26 terminating.
Jun 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-47 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 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-11 terminating.
Jun 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-51 terminating.
Jun 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-47 terminating.
Jun 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-57 terminating.
Jun 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-37 terminating.
Jun 14, 2018 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@469caa15identifier=tcp://localhost:44177/8.output.6,
upstream=8.output.6, group=stream52/9.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3e65ab1{da=com.datatorrent.bufferserver.internal.DataList$Block@66838a40{identifier=8.output.6,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@56e87734[identifier=8.output.6]
Jun 14, 2018 10:42:58 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 14, 2018 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@14bf7d50identifier=tcp://localhost:44177/7.output.5,
upstream=7.output.5, group=stream17/9.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1d83ff24{da=com.datatorrent.bufferserver.internal.DataList$Block@2c011df7{identifier=7.output.5,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@56aa53bd[identifier=7.output.5]
Jun 14, 2018 10:42:58 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=2,name=split9,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream79,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 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@18b80fe5identifier=tcp://localhost:44177/4.output.3,
upstream=4.output.3, group=stream96/6.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@43eecf8b{da=com.datatorrent.bufferserver.internal.DataList$Block@4196720d{identifier=4.output.3,
data=1048576, readingOffset=0, writingOffset=2281,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@65dc216d[identifier=4.output.3]
Jun 14, 2018 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-4 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 10:42:58 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-4 terminating.
Jun 14, 2018 10:42:58 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@1e3baef0identifier=tcp://localhost:44177/2.output.2,
upstream=2.output.2, group=stream79/3.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@616fa1d0{da=com.datatorrent.bufferserver.internal.DataList$Block@5448b8e1{identifier=2.output.2,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b22ef6e00000001, ending_window=5b22ef6e0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@263cae7f[identifier=2.output.2]
Jun 14, 2018 10:42:58 PM com.datatorrent.bufferserver.server.Server$1 run
INFO: Server stopped listening at /0:0:0:0:0:0:0:0:44177
Jun 14, 2018 10:42:58 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.314 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.287 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
12,5,main]) completed. Took 30 mins 11.337 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 31m 26s
32 actionable tasks: 28 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/k57npfv3tynjo
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 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 fvoich...@gmail.com
