See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/744/display/redirect?page=changes>
Changes:
[echauchot] [BEAM-4283] Export nexmark query execution times to BigQuery
[echauchot] [BEAM-4283] Make BigQueryIO Services classes public and
experimental and
[echauchot] [BEAM-4283] Fix PerfsToBigQueryTest and serialization issue in
------------------------------------------
[...truncated 27.61 MB...]
SEVERE: Operator set
[OperatorDeployInfo[id=5,name=split7,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream134,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 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-52 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 4:36:31 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 15, 2018 4:36:31 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=1,name=split9,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream0,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 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-52 terminating.
Jun 15, 2018 4:36:31 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 15, 2018 4:36:31 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@4a96529aidentifier=tcp://localhost:40621/5.output.4,
upstream=5.output.4, group=stream134/6.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@334f2990{da=com.datatorrent.bufferserver.internal.DataList$Block@71e0a9ec{identifier=5.output.4,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b23eb0b00000001, ending_window=5b23eb0b0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@639b303[identifier=5.output.4]
Jun 15, 2018 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-21 terminating.
Jun 15, 2018 4:36:31 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@24a52e99identifier=tcp://localhost:40621/1.output.1,
upstream=1.output.1, group=stream0/3.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@12299853{da=com.datatorrent.bufferserver.internal.DataList$Block@5860202f{identifier=1.output.1,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b23eb0b00000001, ending_window=5b23eb0b0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@2c3b5d06[identifier=1.output.1]
Jun 15, 2018 4:36:31 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 15, 2018 4:36:31 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=7,name=split4,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream48,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 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-41 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 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-41 terminating.
Jun 15, 2018 4:36:31 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@79b2cc4didentifier=tcp://localhost:40621/7.output.5,
upstream=7.output.5, group=stream48/9.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@67d15229{da=com.datatorrent.bufferserver.internal.DataList$Block@39e4b580{identifier=7.output.5,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b23eb0b00000001, ending_window=5b23eb0b0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@605c9bcb[identifier=7.output.5]
Jun 15, 2018 4:36:31 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 15, 2018 4:36:31 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=14,name=split1,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream76,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 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-39 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 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-39 terminating.
Jun 15, 2018 4:36:31 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@49f78d19identifier=tcp://localhost:40621/14.output.11,
upstream=14.output.11, group=stream76/16.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@167929ab{da=com.datatorrent.bufferserver.internal.DataList$Block@7bd46157{identifier=14.output.11,
data=1048576, readingOffset=0, writingOffset=2353,
starting_window=5b23eb0b00000001, ending_window=5b23eb0b0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@67009318[identifier=14.output.11]
Jun 15, 2018 4:36:31 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 15, 2018 4:36:31 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 15, 2018 4:36:31 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=12,name=split3,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream135,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 4:36:31 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=stream4,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 4:36:31 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 15, 2018 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-33 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 4:36:31 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 15, 2018 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-33 terminating.
Jun 15, 2018 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-57 terminating.
Jun 15, 2018 4:36:31 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=8,name=split5,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream72,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 4:36:31 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@243842aaidentifier=tcp://localhost:40621/4.output.3,
upstream=4.output.3, group=stream4/6.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@6306cef0{da=com.datatorrent.bufferserver.internal.DataList$Block@3c6d874a{identifier=4.output.3,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b23eb0b00000001, ending_window=5b23eb0b0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@646b8749[identifier=4.output.3]
Jun 15, 2018 4:36:31 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 15, 2018 4:36:31 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@39957dc3identifier=tcp://localhost:40621/12.output.10,
upstream=12.output.10, group=stream135/13.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@710508f{da=com.datatorrent.bufferserver.internal.DataList$Block@52346fd3{identifier=12.output.10,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b23eb0b00000001, ending_window=5b23eb0b0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@233e508[identifier=12.output.10]
Jun 15, 2018 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-27 terminating.
Jun 15, 2018 4:36:31 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@560e52feidentifier=tcp://localhost:40621/8.output.6,
upstream=8.output.6, group=stream72/9.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3ada7bc8{da=com.datatorrent.bufferserver.internal.DataList$Block@3fcbd034{identifier=8.output.6,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b23eb0b00000001, ending_window=5b23eb0b0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@4e706ae9[identifier=8.output.6]
Jun 15, 2018 4:36:31 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 15, 2018 4:36:31 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=15,name=split0,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 15, 2018 4:36:31 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 15, 2018 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-4 terminating.
Jun 15, 2018 4:36:31 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@50a7dcf3identifier=tcp://localhost:40621/15.output.12,
upstream=15.output.12, group=stream91/16.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@53f6cd8a{da=com.datatorrent.bufferserver.internal.DataList$Block@3a9bf807{identifier=15.output.12,
data=1048576, readingOffset=0, writingOffset=2281,
starting_window=5b23eb0b00000001, ending_window=5b23eb0b0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@5bb0c510[identifier=15.output.12]
Jun 15, 2018 4:36:31 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 15, 2018 4:36:31 PM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=11,name=split2,type=INPUT,checkpoint={ffffffffffffffff,
0,
0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream65,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 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-35 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 4:36:31 PM
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
INFO: Container container-35 terminating.
Jun 15, 2018 4:36:31 PM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@7c97e495identifier=tcp://localhost:40621/11.output.9,
upstream=11.output.9, group=stream65/13.data1, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@16dacbad{da=com.datatorrent.bufferserver.internal.DataList$Block@73a5ce61{identifier=11.output.9,
data=1048576, readingOffset=0, writingOffset=2381,
starting_window=5b23eb0b00000001, ending_window=5b23eb0b0000000a, refCount=2,
uniqueIdentifier=0, next=null, future=null}}} from dl
DataList@161b4bd2[identifier=11.output.9]
Jun 15, 2018 4:36:31 PM com.datatorrent.bufferserver.server.Server$1 run
INFO: Server stopped listening at /0:0:0:0:0:0:0:0:40621
Jun 15, 2018 4:36:31 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.301 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.22 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 28 mins 5.223 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 6s
32 actionable tasks: 28 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/7ivhalzipyxv6
Build cache (/home/jenkins/.gradle/caches/build-cache-1) remove files older
than Fri Jun 08 16:07:30 UTC 2018.
Build cache (/home/jenkins/.gradle/caches/build-cache-1) removing 102 cache
entries (55 MB reclaimed).
Build cache (/home/jenkins/.gradle/caches/build-cache-1) cleaned up in 0.038
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 [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user
[email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
