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

Changes:

[kedin] [SQL] Make field names case-sensitive

------------------------------------------
[...truncated 27.66 MB...]
    Jun 15, 2018 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-57 terminating.
    Jun 15, 2018 1:29:54 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-4 terminating.
    Jun 15, 2018 1:29:54 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@6c92cb14identifier=tcp://localhost:37479/12.output.10, 
upstream=12.output.10, group=stream135/13.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@55119dfd{da=com.datatorrent.bufferserver.internal.DataList$Block@437822b4{identifier=12.output.10,
 data=1048576, readingOffset=0, writingOffset=2375, 
starting_window=5b23bf4e00000001, ending_window=5b23bf4e00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@35330720[identifier=12.output.10]
    Jun 15, 2018 1:29:54 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@81830f7identifier=tcp://localhost:37479/15.output.12, 
upstream=15.output.12, group=stream91/16.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@7dd462d8{da=com.datatorrent.bufferserver.internal.DataList$Block@24f3e6ea{identifier=15.output.12,
 data=1048576, readingOffset=0, writingOffset=2275, 
starting_window=5b23bf4e00000001, ending_window=5b23bf4e00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@261c1d42[identifier=15.output.12]
    Jun 15, 2018 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-21 terminating.
    Jun 15, 2018 1:29:54 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 1:29:54 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 1:29:54 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@4bd267bfidentifier=tcp://localhost:37479/1.output.1, 
upstream=1.output.1, group=stream0/3.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@bbb14a6{da=com.datatorrent.bufferserver.internal.DataList$Block@55a765ab{identifier=1.output.1,
 data=1048576, readingOffset=0, writingOffset=2375, 
starting_window=5b23bf4e00000001, ending_window=5b23bf4e00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@6e581d43[identifier=1.output.1]
    Jun 15, 2018 1:29:54 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-27 terminating.
    Jun 15, 2018 1:29:54 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@443e2e4eidentifier=tcp://localhost:37479/8.output.6, 
upstream=8.output.6, group=stream72/9.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@2868ebc7{da=com.datatorrent.bufferserver.internal.DataList$Block@7b25c448{identifier=8.output.6,
 data=1048576, readingOffset=0, writingOffset=2375, 
starting_window=5b23bf4e00000001, ending_window=5b23bf4e00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@15c16cba[identifier=8.output.6]
    Jun 15, 2018 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-35 terminating.
    Jun 15, 2018 1:29:54 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-33 terminating.
    Jun 15, 2018 1:29:54 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@29904042identifier=tcp://localhost:37479/11.output.9, 
upstream=11.output.9, group=stream65/13.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3bddc944{da=com.datatorrent.bufferserver.internal.DataList$Block@54042b2b{identifier=11.output.9,
 data=1048576, readingOffset=0, writingOffset=2375, 
starting_window=5b23bf4e00000001, ending_window=5b23bf4e00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@1d6b267[identifier=11.output.9]
    Jun 15, 2018 1:29:54 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@57c8a679identifier=tcp://localhost:37479/4.output.3, 
upstream=4.output.3, group=stream4/6.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1fecaa5b{da=com.datatorrent.bufferserver.internal.DataList$Block@4aaec70b{identifier=4.output.3,
 data=1048576, readingOffset=0, writingOffset=2375, 
starting_window=5b23bf4e00000001, ending_window=5b23bf4e00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@3f06e006[identifier=4.output.3]
    Jun 15, 2018 1:29:54 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 1:29:54 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=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 1:29:54 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 1:29:54 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-52 terminating.
    Jun 15, 2018 1:29:54 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@52980c95identifier=tcp://localhost:37479/5.output.4, 
upstream=5.output.4, group=stream134/6.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@bf7380b{da=com.datatorrent.bufferserver.internal.DataList$Block@71b3f55c{identifier=5.output.4,
 data=1048576, readingOffset=0, writingOffset=2375, 
starting_window=5b23bf4e00000001, ending_window=5b23bf4e00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@4d19e2fe[identifier=5.output.4]
    Jun 15, 2018 1:29:54 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 1:29:54 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 1:29:54 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 1:29:54 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-41 terminating.
    Jun 15, 2018 1:29:54 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 1:29:54 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@67bb9a3eidentifier=tcp://localhost:37479/7.output.5, 
upstream=7.output.5, group=stream48/9.data1, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@45972d8b{da=com.datatorrent.bufferserver.internal.DataList$Block@77127252{identifier=7.output.5,
 data=1048576, readingOffset=0, writingOffset=2375, 
starting_window=5b23bf4e00000001, ending_window=5b23bf4e00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@196560f9[identifier=7.output.5]
    Jun 15, 2018 1:29:54 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 1:29:54 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 1:29:54 PM 
com.datatorrent.stram.StramLocalCluster$LocalStreamingContainerLauncher run
    INFO: Container container-39 terminating.
    Jun 15, 2018 1:29:54 PM com.datatorrent.bufferserver.server.Server$3 run
    INFO: Removing ln 
LogicalNode@6d893251identifier=tcp://localhost:37479/14.output.11, 
upstream=14.output.11, group=stream76/16.data2, partitions=[], 
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1b696f39{da=com.datatorrent.bufferserver.internal.DataList$Block@676ef2aa{identifier=14.output.11,
 data=1048576, readingOffset=0, writingOffset=2347, 
starting_window=5b23bf4e00000001, ending_window=5b23bf4e00000009, refCount=2, 
uniqueIdentifier=0, next=null, future=null}}} from dl 
DataList@38a9cf7[identifier=14.output.11]
    Jun 15, 2018 1:29:54 PM com.datatorrent.bufferserver.server.Server$1 run
    INFO: Server stopped listening at /0:0:0:0:0:0:0:0:37479
    Jun 15, 2018 1:29:54 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.252 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.207 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[Daemon worker,5,main]) 
completed. Took 27 mins 56.915 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 46s
32 actionable tasks: 28 executed, 4 from cache

Publishing build scan...
https://gradle.com/s/67iojf2aat3w4

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]

Reply via email to