See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/103/display/redirect>
------------------------------------------
[...truncated 18.63 MB...]
INFO: Undeploy request: [20, 21, 22, 23, 24]
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:47 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
heartbeatLoop
INFO: Waiting for pending request.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=20,name=PAssert$211/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous),type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream10,sourceNodeId=19,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream0,bufferServer=<null>]]],
OperatorDeployInfo[id=23,name=PAssert$211/RunChecks/ParMultiDo(GroupedValuesChecker),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream6,sourceNodeId=22,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream17,bufferServer=<null>]]],
OperatorDeployInfo[id=22,name=PAssert$211/GetPane/Map/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream21,sourceNodeId=21,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream6,bufferServer=<null>]]],
OperatorDeployInfo[id=21,name=PAssert$211/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream0,sourceNodeId=20,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream21,bufferServer=<null>]]],
OperatorDeployInfo[id=24,name=PAssert$211/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream17,sourceNodeId=23,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[]]]
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:39744/19.output.19, windowId=ffffffffffffffff,
type=stream10/20.input, upstreamIdentifier=19.output.19, mask=0,
partitions=null, bufferSize=1024}
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=14,name=PAssert$211/GroupGlobally/RewindowActuals/Window.Assign,type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream14,sourceNodeId=13,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream8,bufferServer=<null>]]],
OperatorDeployInfo[id=15,name=PAssert$211/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream8,sourceNodeId=14,sourcePortName=outputPort,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream4,bufferServer=localhost]]],
OperatorDeployInfo[id=13,name=PAssert$211/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous),type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream16,sourceNodeId=12,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream14,bufferServer=<null>]]]]
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=19,name=PAssert$211/GroupGlobally/GroupDummyAndContents,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream19,sourceNodeId=18,sourcePortName=out,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream10,bufferServer=localhost]]]]
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=12,name=PAssert$211/GroupGlobally/GatherAllOutputs/GroupByKey,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream1,sourceNodeId=11,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream16,bufferServer=localhost]]]]
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=5,name=WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/GroupByKey,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream13,sourceNodeId=4,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream22,bufferServer=localhost]]]]
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:39744/18.out.18, windowId=ffffffffffffffff,
type=stream19/19.input, upstreamIdentifier=18.out.18, mask=0, partitions=null,
bufferSize=1024}
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=19.output.19, windowId=ffffffffffffffff}
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:39744/11.outputPort.11, windowId=ffffffffffffffff,
type=stream1/12.input, upstreamIdentifier=11.outputPort.11, mask=0,
partitions=null, bufferSize=1024}
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=12.output.12, windowId=ffffffffffffffff}
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=15.output.16, windowId=ffffffffffffffff}
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=5.output.5, windowId=ffffffffffffffff}
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:39744/4.output.4, windowId=ffffffffffffffff,
type=stream13/5.input, upstreamIdentifier=4.output.4, mask=0, partitions=null,
bufferSize=1024}
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:39744/12.output.12, windowId=ffffffffffffffff,
type=stream16/13.input, upstreamIdentifier=12.output.12, mask=0,
partitions=null, bufferSize=1024}
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=2,name=Create.TimestampedValues/ParDo(ConvertTimestamps)/ParMultiDo(ConvertTimestamps),type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream12,sourceNodeId=1,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream7,bufferServer=<null>]]],
OperatorDeployInfo[id=3,name=WindowingTest.WindowedCount/Window/Window.Assign,type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream7,sourceNodeId=2,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream15,bufferServer=<null>]]],
OperatorDeployInfo[id=4,name=WindowingTest.WindowedCount/Count.PerElement/Init/Map/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream15,sourceNodeId=3,sourcePortName=outputPort,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream13,bufferServer=localhost]]]]
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=4.output.4, windowId=ffffffffffffffff}
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:39744/1.output.1, windowId=ffffffffffffffff,
type=stream12/2.input, upstreamIdentifier=1.output.1, mask=0, partitions=null,
bufferSize=1024}
Apr 16, 2018 12:36:48 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@68b70aeidentifier=tcp://localhost:39744/1.output.1,
upstream=1.output.1, group=stream12/2.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@1baed376{da=com.datatorrent.bufferserver.internal.DataList$Block@368e2923{identifier=1.output.1,
data=1048576, readingOffset=0, writingOffset=186,
starting_window=5ad3f01000000001, ending_window=5ad3f01000000004, refCount=3,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@61890272 {1.output.1}
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=10,name=PAssert$211/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream9,sourceNodeId=9,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream18,bufferServer=<null>]]],
OperatorDeployInfo[id=9,name=PAssert$211/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream5,sourceNodeId=8,sourcePortName=outputPort,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream9,bufferServer=<null>]]],
OperatorDeployInfo[id=7,name=WindowingTest.WindowedCount/FormatCounts/ParMultiDo(FormatCounts),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream2,sourceNodeId=6,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream3,bufferServer=<null>]]],
OperatorDeployInfo[id=6,name=WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous),type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream22,sourceNodeId=5,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream2,bufferServer=<null>]]],
OperatorDeployInfo[id=11,name=PAssert$211/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign,type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream18,sourceNodeId=10,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream1,bufferServer=localhost]]],
OperatorDeployInfo[id=8,name=PAssert$211/GroupGlobally/Window.Into()/Window.Assign,type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream3,sourceNodeId=7,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream5,bufferServer=<null>]]]]
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer$2
run
SEVERE: Operator set
[OperatorDeployInfo[id=4,name=WindowingTest.WindowedCount/Count.PerElement/Init/Map/ParMultiDo(Anonymous),type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream15,sourceNodeId=3,sourcePortName=outputPort,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream13,bufferServer=localhost]]],
OperatorDeployInfo[id=3,name=WindowingTest.WindowedCount/Window/Window.Assign,type=OIO,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=inputPort,streamId=stream7,sourceNodeId=2,sourcePortName=output,locality=THREAD_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=stream15,bufferServer=<null>]]],
OperatorDeployInfo[id=2,name=Create.TimestampedValues/ParDo(ConvertTimestamps)/ParMultiDo(ConvertTimestamps),type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=stream12,sourceNodeId=1,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=stream7,bufferServer=<null>]]]]
stopped running due to an exception.
org.apache.beam.sdk.util.UserCodeException:
java.lang.IllegalArgumentException: Cannot output with timestamp
1970-01-01T00:00:00.001Z. Output timestamps must be no earlier than the
timestamp of the current input (2018-04-16T00:36:34.648Z) minus the allowed
skew (0 milliseconds). See the DoFn#getAllowedTimestampSkew() Javadoc for
details on changing the allowed skew.
at
org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:36)
at
org.apache.beam.sdk.transforms.Create$TimestampedValues$ConvertTimestamps$DoFnInvoker.invokeProcessElement(Unknown
Source)
at
org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:182)
at
org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at
org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:78)
at
org.apache.beam.runners.apex.translation.operators.ApexParDoOperator.processElementInReadyWindows(ApexParDoOperator.java:322)
at
org.apache.beam.runners.apex.translation.operators.ApexParDoOperator.access$400(ApexParDoOperator.java:97)
at
org.apache.beam.runners.apex.translation.operators.ApexParDoOperator$1.process(ApexParDoOperator.java:209)
at
org.apache.beam.runners.apex.translation.operators.ApexParDoOperator$1.process(ApexParDoOperator.java:200)
at com.datatorrent.api.DefaultInputPort.put(DefaultInputPort.java:79)
at
com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:288)
at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:269)
at
com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1428)
Caused by: java.lang.IllegalArgumentException: Cannot output with timestamp
1970-01-01T00:00:00.001Z. Output timestamps must be no earlier than the
timestamp of the current input (2018-04-16T00:36:34.648Z) minus the allowed
skew (0 milliseconds). See the DoFn#getAllowedTimestampSkew() Javadoc for
details on changing the allowed skew.
at
org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.checkTimestamp(SimpleDoFnRunner.java:468)
at
org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.outputWithTimestamp(SimpleDoFnRunner.java:434)
at
org.apache.beam.sdk.transforms.Create$TimestampedValues$ConvertTimestamps.processElement(Create.java:607)
Apr 16, 2018 12:36:48 AM
com.datatorrent.stram.StramLocalCluster$UmbilicalProtocolLocalImpl log
INFO: container-13 msg: Stopped running due to an exception.
org.apache.beam.sdk.util.UserCodeException: java.lang.IllegalArgumentException:
Cannot output with timestamp 1970-01-01T00:00:00.001Z. Output timestamps must
be no earlier than the timestamp of the current input
(2018-04-16T00:36:34.648Z) minus the allowed skew (0 milliseconds). See the
DoFn#getAllowedTimestampSkew() Javadoc for details on changing the allowed skew.
at
org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:36)
at
org.apache.beam.sdk.transforms.Create$TimestampedValues$ConvertTimestamps$DoFnInvoker.invokeProcessElement(Unknown
Source)
at
org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:182)
at
org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at
org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:78)
at
org.apache.beam.runners.apex.translation.operators.ApexParDoOperator.processElementInReadyWindows(ApexParDoOperator.java:322)
at
org.apache.beam.runners.apex.translation.operators.ApexParDoOperator.access$400(ApexParDoOperator.java:97)
at
org.apache.beam.runners.apex.translation.operators.ApexParDoOperator$1.process(ApexParDoOperator.java:209)
at
org.apache.beam.runners.apex.translation.operators.ApexParDoOperator$1.process(ApexParDoOperator.java:200)
at com.datatorrent.api.DefaultInputPort.put(DefaultInputPort.java:79)
at
com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:288)
at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:269)
at
com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1428)
Caused by: java.lang.IllegalArgumentException: Cannot output with timestamp
1970-01-01T00:00:00.001Z. Output timestamps must be no earlier than the
timestamp of the current input (2018-04-16T00:36:34.648Z) minus the allowed
skew (0 milliseconds). See the DoFn#getAllowedTimestampSkew() Javadoc for
details on changing the allowed skew.
at
org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.checkTimestamp(SimpleDoFnRunner.java:468)
at
org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.outputWithTimestamp(SimpleDoFnRunner.java:434)
at
org.apache.beam.sdk.transforms.Create$TimestampedValues$ConvertTimestamps.processElement(Create.java:607)
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:39744/5.output.5, windowId=ffffffffffffffff,
type=stream22/6.input, upstreamIdentifier=5.output.5, mask=0, partitions=null,
bufferSize=1024}
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=11.outputPort.11, windowId=ffffffffffffffff}
Apr 16, 2018 12:36:48 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Deploy request:
[OperatorDeployInfo[id=18,name=PAssert$211/GroupGlobally/FlattenDummyAndContents,type=GENERIC,checkpoint={ffffffffffffffff,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=data1,streamId=stream4,sourceNodeId=15,sourcePortName=output,locality=<null>,partitionMask=0,partitionKeys=<null>],
OperatorDeployInfo.InputDeployInfo[portName=data2,streamId=stream20,sourceNodeId=17,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=out,streamId=stream19,bufferServer=localhost]]]]
Apr 16, 2018 12:36:48 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received publisher request: PublishRequestTuple{version=1.0,
identifier=18.out.18, windowId=ffffffffffffffff}
Apr 16, 2018 12:36:49 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:39744/15.output.16, windowId=ffffffffffffffff,
type=stream4/18.data1, upstreamIdentifier=15.output.16, mask=0,
partitions=null, bufferSize=1024}
Apr 16, 2018 12:36:49 AM
com.datatorrent.bufferserver.server.Server$UnidentifiedClient onMessage
INFO: Received subscriber request: SubscribeRequestTuple{version=1.0,
identifier=tcp://localhost:39744/17.outputPort.17, windowId=ffffffffffffffff,
type=stream20/18.data2, upstreamIdentifier=17.outputPort.17, mask=0,
partitions=null, bufferSize=1024}
Apr 16, 2018 12:36:49 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@537431a2identifier=tcp://localhost:39744/17.outputPort.17,
upstream=17.outputPort.17, group=stream20/18.data2, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@212b5ea{da=com.datatorrent.bufferserver.internal.DataList$Block@2f7f05ed{identifier=17.outputPort.17,
data=1048576, readingOffset=0, writingOffset=77,
starting_window=5ad3f01000000001, ending_window=5ad3f01000000002, refCount=3,
uniqueIdentifier=0, next=null, future=null}}} from dl
com.datatorrent.bufferserver.internal.DataList@5c6a321c {17.outputPort.17}
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:49 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:50 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:50 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:50 AM com.datatorrent.stram.StreamingContainerManager
processOperatorFailure
WARNING: Operator failure:
PTOperator[id=2,name=Create.TimestampedValues/ParDo(ConvertTimestamps)/ParMultiDo(ConvertTimestamps),state=INACTIVE]
count: 4
Apr 16, 2018 12:36:50 AM com.datatorrent.stram.StreamingContainerManager
processOperatorFailure
SEVERE: Initiating container restart after operator failure
PTOperator[id=2,name=Create.TimestampedValues/ParDo(ConvertTimestamps)/ParMultiDo(ConvertTimestamps),state=INACTIVE]
Apr 16, 2018 12:36:50 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:50 AM com.datatorrent.stram.Journal write
WARNING: Journal output stream is null. Skipping write to the WAL.
Apr 16, 2018 12:36:50 AM com.datatorrent.stram.engine.StreamingContainer
processHeartbeatResponse
INFO: Undeploy request: [2, 3, 4]
Apr 16, 2018 12:36:50 AM com.datatorrent.stram.engine.StreamingContainer
undeploy
INFO: Undeploy complete.
Apr 16, 2018 12:36:50 AM com.datatorrent.bufferserver.server.Server$3 run
INFO: Removing ln
LogicalNode@3df7a7b2identifier=tcp://localhost:39744/4.output.4,
upstream=4.output.4, group=stream13/5.input, partitions=[],
iterator=com.datatorrent.bufferserver.internal.DataList$DataListIterator@3709407a{da=com.datatorrent.bufferserver.internal.DataList$Block@28156b77{identifier=4.output.4,
data=1048576, readingOffset=0, writingOffset=27,
starting_window=5ad3f01000000001, ending_window=5ad3f01000000001, refCount=2,
uniqueIdentifier=0, next=null, future=Done}}} from dl
com.datatorrent.bufferserver.internal.DataList@7bcf0814 {4.output.4}
170 tests completed, 1 failed, 1 skipped
:beam-runners-apex:validatesRunnerBatch FAILED
:beam-runners-apex:validatesRunnerBatch (Thread[Task worker for ':' Thread
2,5,main]) completed. Took 30 mins 16.079 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-apex:validatesRunnerBatch'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 137
* 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.5.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 32m 42s
32 actionable tasks: 32 executed
Publishing build scan...
https://gradle.com/s/3wl6lrmvumwfi
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Recording test results
ERROR: Step ‘Publish JUnit test result report’ failed: No test report files
were found. Configuration error?
Not sending mail to unregistered user git...@alasdairhodge.co.uk
Not sending mail to unregistered user sid...@google.com
