See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4022/display/redirect>
------------------------------------------
[...truncated 8.57 MB...]
[INFO] 2017-09-22T07:28:15.788Z: (1c2f90c43fea7e04): Executing operation
input/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+input/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ParDo(SDFWithSideInput)/ParMultiDo(SDFWithSideInput)/Pair
with initial
restriction+ParDo(SDFWithSideInput)/ParMultiDo(SDFWithSideInput)/Split
restriction+ParDo(SDFWithSideInput)/ParMultiDo(SDFWithSideInput)/Explode
windows+ParDo(SDFWithSideInput)/ParMultiDo(SDFWithSideInput)/Assign unique
key/AddKeys/Map+s19/GroupByKeyRaw/WriteStream
[INFO] 2017-09-22T07:28:15.788Z: (263117a702ff1ce6): Executing operation
PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/ReadStream+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/MergeBuckets+PAssert$326/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$326/GroupGlobally/RewindowActuals/Window.Assign+PAssert$326/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$326/GroupGlobally/GroupDummyAndContents/WriteStream
[INFO] 2017-09-22T07:28:15.788Z: (5436ecd8f6f9394f): Executing operation
View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(StreamingPCollectionViewWriter)
[INFO] 2017-09-22T07:28:15.816Z: (1a905f364014439a): Executing operation
s19/GroupByKeyRaw/ReadStream+s19/SplittableProcess+PAssert$326/GroupGlobally/Window.Into()/Window.Assign+PAssert$326/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$326/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$326/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/WriteStream
[INFO] 2017-09-22T07:28:16.072Z: (787ccb1b91400c15): Autoscaling: Resized
worker pool from 1 to 0.
[INFO] 2017-09-22T07:28:16.074Z: (787ccb1b91400c37): Autoscaling: Would further
reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-09-22T07:28:15.325Z: (8629eb666655bb61): Workers have started
successfully.
[INFO] 2017-09-22T07:28:17.637Z: (e9d1c9d1afc0efa6): Executing operation
WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
[INFO] 2017-09-22T07:28:17.673Z: (e9d1c9d1afc0e5de): Executing operation
PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-09-22T07:28:17.760Z: (6f09a451c70330d): Executing operation
WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+WindowingTest.WindowedCount/FormatCounts+PAssert$319/GroupGlobally/Window.Into()/Window.Assign+PAssert$319/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$319/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$319/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-09-22T07:28:16.075Z: (ee4deeb46b6831b2): Autoscaling: Raised the
number of workers to 0 based on the rate of progress in the currently running
step(s).
[INFO] 2017-09-22T07:28:22.675Z: (6f09a451c70367b): Executing operation
PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-09-22T07:28:22.692Z: (6f09a451c703473): Executing operation
PAssert$319/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-09-22T07:28:22.739Z: (6f09a451c703f5f): Executing operation
PAssert$319/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$319/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$319/GroupGlobally/GroupDummyAndContents/Reify+PAssert$319/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-09-22T07:28:22.753Z: (e9d1c9d1afc0e1f9): Executing operation
PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$319/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$319/GroupGlobally/RewindowActuals/Window.Assign+PAssert$319/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$319/GroupGlobally/GroupDummyAndContents/Reify+PAssert$319/GroupGlobally/GroupDummyAndContents/Write
[INFO] Job 2017-09-22_00_25_14-1958800939177319435 finished with status DONE.
[INFO] Success result for Dataflow job 2017-09-22_00_25_14-1958800939177319435.
Found 1 success, 0 failures out of 1 expected assertions.
[INFO] 2017-09-22T07:28:26.558Z: (ee4deeb46b683525): Autoscaling: Raised the
number of workers to 1 based on the rate of progress in the currently running
step(s).
[INFO] 2017-09-22T07:28:26.753Z: (652c34d8e55f2b1): Autoscaling: Raised the
number of workers to 1 based on the rate of progress in the currently running
step(s).
[INFO] 2017-09-22T07:28:30.445Z: (6f09a451c703812): Executing operation
PAssert$319/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-09-22T07:28:30.465Z: (6f09a451c703a4b): Executing operation
PAssert$319/GroupGlobally/GroupDummyAndContents/Read+PAssert$319/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$319/GroupGlobally/Values/Values/Map+PAssert$319/GroupGlobally/ParDo(Concat)+PAssert$319/GetPane/Map+PAssert$319/RunChecks+PAssert$319/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-09-22T07:28:36.651Z: (b98b4a6e4515e887): Cleaning up.
[INFO] 2017-09-22T07:28:36.655Z: (b98b4a6e4515e5fb): Stopping worker pool...
[INFO] 2017-09-22T07:28:55.488Z: (f9be92bb9aed3a59): Workers have started
successfully.
[INFO] 2017-09-22T07:28:54.192Z: (b959f6653f390897): Workers have started
successfully.
[INFO] 2017-09-22T07:28:53.731Z: (3245af39a4b34ed): Workers have started
successfully.
[INFO] 2017-09-22T07:28:58.872Z: (13a29644559ac20c): Workers have started
successfully.
[INFO] 2017-09-22T07:28:58.197Z: (e2ee049d3d59b1f): Workers have started
successfully.
[INFO] 2017-09-22T07:28:57.365Z: (feecab37e9fc7733): Workers have started
successfully.
[INFO] 2017-09-22T07:28:58.741Z: (144e06b03b5adaba): Executing operation
WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
[INFO] 2017-09-22T07:28:58.777Z: (4817256475ec660c): Executing operation
PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-09-22T07:28:58.861Z: (4817256475ec60dd): Executing operation
WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+WindowingTest.WindowedCount/FormatCounts+PAssert$320/GroupGlobally/Window.Into()/Window.Assign+PAssert$320/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$320/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$320/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-09-22T07:28:59.344Z: (a208e5e354fda2fe): Workers have started
successfully.
[INFO] 2017-09-22T07:29:01.842Z: (1c7c7cb13b24a013): Workers have started
successfully.
[INFO] 2017-09-22T07:29:04.403Z: (4817256475ec6e33): Executing operation
PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-09-22T07:29:04.428Z: (4817256475ec6ecb): Executing operation
PAssert$320/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-09-22T07:29:04.485Z: (4817256475ec699c): Executing operation
PAssert$320/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$320/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$320/GroupGlobally/GroupDummyAndContents/Reify+PAssert$320/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-09-22T07:29:04.504Z: (144e06b03b5ad53e): Executing operation
PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$320/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$320/GroupGlobally/RewindowActuals/Window.Assign+PAssert$320/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$320/GroupGlobally/GroupDummyAndContents/Reify+PAssert$320/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-09-22T07:29:04.035Z: (982aebc21949f559): Autoscaling: Resized
worker pool from 1 to 0.
[INFO] 2017-09-22T07:29:04.037Z: (982aebc21949fde3): Autoscaling: Would further
reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-09-22T07:29:04.042Z: (ef707397f6d588fc): Worker pool stopped.
[INFO] Job 2017-09-22_00_25_40-15728172821080090025 finished with status DONE.
[INFO] Success result for Dataflow job
2017-09-22_00_25_40-15728172821080090025. Found 1 success, 0 failures out of 1
expected assertions.
[INFO] 2017-09-22T07:29:14.130Z: (4817256475ec6093): Executing operation
PAssert$320/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-09-22T07:29:14.158Z: (144e06b03b5ad2dc): Executing operation
PAssert$320/GroupGlobally/GroupDummyAndContents/Read+PAssert$320/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$320/GroupGlobally/Values/Values/Map+PAssert$320/GroupGlobally/ParDo(Concat)+PAssert$320/GetPane/Map+PAssert$320/RunChecks+PAssert$320/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-09-22T07:29:16.846Z: (8175e18630471840): Cleaning up.
[INFO] 2017-09-22T07:29:16.850Z: (8175e18630471984): Stopping worker pool...
[INFO] 2017-09-22T07:29:26.125Z: (3e4e7a46a2238ee8): Autoscaling: Resized
worker pool from 1 to 0.
[INFO] 2017-09-22T07:29:26.128Z: (3e4e7a46a223807a): Autoscaling: Would further
reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-09-22T07:29:32.680Z: (ed9651846fb1eeed): Executing operation
PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-09-22T07:29:32.696Z: (ed9651846fb1ec85): Executing operation
PAssert$325/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-09-22T07:29:32.740Z: (ed9651846fb1e681): Executing operation
PAssert$325/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$325/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$325/GroupGlobally/GroupDummyAndContents/Reify+PAssert$325/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-09-22T07:29:32.752Z: (8659f3fc3d96fcf8): Executing operation
PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$325/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$325/GroupGlobally/RewindowActuals/Window.Assign+PAssert$325/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$325/GroupGlobally/GroupDummyAndContents/Reify+PAssert$325/GroupGlobally/GroupDummyAndContents/Write
[INFO] Job 2017-09-22_00_25_48-2440931619951373729 finished with status DONE.
[INFO] Success result for Dataflow job 2017-09-22_00_25_48-2440931619951373729.
Found 1 success, 0 failures out of 1 expected assertions.
[INFO] 2017-09-22T07:29:39.165Z: (ed9651846fb1e298): Executing operation
PAssert$325/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-09-22T07:29:39.184Z: (ed9651846fb1e07d): Executing operation
PAssert$325/GroupGlobally/GroupDummyAndContents/Read+PAssert$325/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$325/GroupGlobally/Values/Values/Map+PAssert$325/GroupGlobally/ParDo(Concat)+PAssert$325/GetPane/Map+PAssert$325/RunChecks+PAssert$325/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-09-22T07:29:43.751Z: (ea68e37945e07fb6): Cleaning up.
[INFO] 2017-09-22T07:29:43.756Z: (ea68e37945e07c8a): Stopping worker pool...
[INFO] 2017-09-22T07:29:49.266Z: (8a05110aa338ad4): Executing operation
PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-09-22T07:29:49.284Z: (8a05110aa338c4c): Executing operation
PAssert$327/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-09-22T07:29:49.333Z: (8a05110aa338ff8): Executing operation
PAssert$327/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$327/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$327/GroupGlobally/GroupDummyAndContents/Reify+PAssert$327/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-09-22T07:29:49.346Z: (2baf64ba291143f0): Executing operation
PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$327/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$327/GroupGlobally/RewindowActuals/Window.Assign+PAssert$327/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$327/GroupGlobally/GroupDummyAndContents/Reify+PAssert$327/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-09-22T07:30:00.473Z: (8a05110aa33865b): Executing operation
PAssert$327/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-09-22T07:30:00.494Z: (8a05110aa3383a4): Executing operation
PAssert$327/GroupGlobally/GroupDummyAndContents/Read+PAssert$327/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$327/GroupGlobally/Values/Values/Map+PAssert$327/GroupGlobally/ParDo(Concat)+PAssert$327/GetPane/Map+PAssert$327/RunChecks+PAssert$327/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-09-22T07:30:08.198Z: (2d40e1fb35c6bf8b): Autoscaling: Resized
worker pool from 1 to 0.
[INFO] 2017-09-22T07:30:08.201Z: (2d40e1fb35c6b09d): Autoscaling: Would further
reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-09-22T07:30:09.297Z: (84fb9f701bc668e3): Cleaning up.
[INFO] 2017-09-22T07:30:09.304Z: (84fb9f701bc66d07): Stopping worker pool...
[INFO] Job 2017-09-22_00_27_12-12312660302547818962 finished with status DONE.
[INFO] Success result for Dataflow job
2017-09-22_00_27_12-12312660302547818962. Found 1 success, 0 failures out of 1
expected assertions.
[INFO] 2017-09-22T07:30:16.804Z: (1ec748616a2ddbd2): Cleaning up.
[INFO] 2017-09-22T07:30:16.834Z: (1ec748616a2dd3f3): Stopping worker pool...
[INFO] 2017-09-22T07:30:19.420Z: (ad4724e958fa8820): Cleaning up.
[INFO] 2017-09-22T07:30:19.449Z: (ad4724e958fa8caf): Stopping worker pool...
[INFO] 2017-09-22T07:30:18.898Z: (80ff62f9ffdcdc93): Cleaning up.
[INFO] 2017-09-22T07:30:18.934Z: (80ff62f9ffdcdfb0): Stopping worker pool...
[INFO] 2017-09-22T07:30:21.974Z: (98b7a9c572bc459f): Cleaning up.
[INFO] 2017-09-22T07:30:22.021Z: (98b7a9c572bc4136): Stopping worker pool...
[INFO] 2017-09-22T07:30:23.589Z: (b8bcf51fe64c4189): Cleaning up.
[INFO] 2017-09-22T07:30:23.693Z: (b8bcf51fe64c4ea0): Stopping worker pool...
[INFO] 2017-09-22T07:30:37.984Z: (ee4deeb46b683bd0): Autoscaling: Resized
worker pool from 1 to 0.
[INFO] 2017-09-22T07:30:37.986Z: (ee4deeb46b683a56): Autoscaling: Would further
reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-09-22_00_27_58-2151273508256632034 finished with status DONE.
[INFO] Success result for Dataflow job 2017-09-22_00_27_58-2151273508256632034.
Found 1 success, 0 failures out of 1 expected assertions.
[INFO] 2017-09-22T07:30:54.586Z: (a96fd64592e70ead): Cleaning up.
[INFO] 2017-09-22T07:30:54.617Z: (a96fd64592e70a40): Stopping worker pool...
[INFO] 2017-09-22T07:31:03.362Z: (652c34d8e55f0e6): Autoscaling: Resized worker
pool from 1 to 0.
[INFO] 2017-09-22T07:31:03.364Z: (652c34d8e55ff28): Autoscaling: Would further
reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-09-22T07:31:05.863Z: (ad4724e958fa88d0): Worker pool stopped.
[INFO] 2017-09-22T07:31:10.316Z: (80ff62f9ffdcd1a3): Worker pool stopped.
[INFO] 2017-09-22T07:31:10.425Z: (98b7a9c572bc48cf): Worker pool stopped.
[INFO] Job 2017-09-22_00_27_54-14431148807045324038 finished with status DONE.
[INFO] Success result for Dataflow job
2017-09-22_00_27_54-14431148807045324038. Found 1 success, 0 failures out of 1
expected assertions.
[INFO] Job 2017-09-22_00_28_05-8728058531365501222 finished with status DONE.
[WARNING] Dataflow job 2017-09-22_00_28_05-8728058531365501222 did not output a
success or failure metric.
[INFO] 2017-09-22T07:31:14.219Z: (1ec748616a2dd222): Worker pool stopped.
[INFO] Job 2017-09-22_00_27_57-4537766772764684209 finished with status DONE.
[WARNING] Dataflow job 2017-09-22_00_27_57-4537766772764684209 did not output a
success or failure metric.
[INFO] Job 2017-09-22_00_28_00-4391779429414186675 finished with status DONE.
[WARNING] Dataflow job 2017-09-22_00_28_00-4391779429414186675 did not output a
success or failure metric.
[INFO] 2017-09-22T07:31:19.638Z: (b8bcf51fe64c4cb9): Worker pool stopped.
[INFO] Job 2017-09-22_00_27_44-18218499034056288885 finished with status DONE.
[WARNING] Dataflow job 2017-09-22_00_27_44-18218499034056288885 did not output
a success or failure metric.
[INFO] Job 2017-09-22_00_28_00-5486918511597036156 finished with status DONE.
[WARNING] Dataflow job 2017-09-22_00_28_00-5486918511597036156 did not output a
success or failure metric.
[INFO] 2017-09-22T07:31:53.878Z: (a96fd64592e7009d): Worker pool stopped.
[INFO] Job 2017-09-22_00_28_02-14335947033071013261 finished with status DONE.
[WARNING] Dataflow job 2017-09-22_00_28_02-14335947033071013261 did not output
a success or failure metric.
2017-09-22T07:32:03.288 [INFO] Running org.apache.beam.sdk.transforms.ParDoTest
2017-09-22T07:32:03.322 [ERROR] Tests run: 43, Failures: 0, Errors: 1, Skipped:
0, Time elapsed: 851.465 s <<< FAILURE! - in
org.apache.beam.sdk.transforms.ParDoTest
2017-09-22T07:32:03.322 [ERROR]
testBagState(org.apache.beam.sdk.transforms.ParDoTest) Time elapsed: 224.869 s
<<< ERROR!
java.lang.RuntimeException:
(4a1b1908507e992): java.lang.AssertionError: expected:<4> but was:<5>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:631)
at
org.apache.beam.sdk.transforms.ParDoTest$57.processElement(ParDoTest.java:1996)
(4a1b1908507e34b): java.lang.AssertionError: expected:<4> but was:<5>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:631)
at
org.apache.beam.sdk.transforms.ParDoTest$57.processElement(ParDoTest.java:1996)
(4a1b1908507ed04): java.lang.AssertionError: expected:<4> but was:<5>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:631)
at
org.apache.beam.sdk.transforms.ParDoTest$57.processElement(ParDoTest.java:1996)
(4a1b1908507e6bd): java.lang.AssertionError: expected:<4> but was:<5>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:631)
at
org.apache.beam.sdk.transforms.ParDoTest$57.processElement(ParDoTest.java:1996)
(4d316c648ea89962): Workflow failed. Causes: (4d316c648ea8941a):
S05:ParDo(Anonymous)/BatchStatefulParDoOverrides.GbkBeforeStatefulParDo/PartitionKeys/Read+ParDo(Anonymous)/ParDo(BatchStateful)+PAssert$105/GroupGlobally/Window.Into()/Window.Assign+PAssert$105/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$105/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$105/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$105/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$105/GroupGlobally/GatherAllOutputs/GroupByKey/Write
failed., (5ee93de85c64be25): A work item was attempted 4 times without
success. Each time the worker eventually lost contact with the service. The
work item was attempted on:
pardotest0testbagstate-je-09212341-6f41-harness-lrwx,
pardotest0testbagstate-je-09212341-6f41-harness-lrwx,
pardotest0testbagstate-je-09212341-6f41-harness-lrwx,
pardotest0testbagstate-je-09212341-6f41-harness-lrwx
at
org.apache.beam.runners.dataflow.TestDataflowRunner.run(TestDataflowRunner.java:133)
at
org.apache.beam.runners.dataflow.TestDataflowRunner.run(TestDataflowRunner.java:89)
at
org.apache.beam.runners.dataflow.TestDataflowRunner.run(TestDataflowRunner.java:54)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:303)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:356)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:338)
at
org.apache.beam.sdk.transforms.ParDoTest.testBagState(ParDoTest.java:2013)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:327)
at
org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:239)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at
org.apache.maven.surefire.junitcore.pc.Scheduler$1.run(Scheduler.java:393)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2017-09-22T07:32:03.322 [INFO] Running
org.apache.beam.sdk.transforms.SplittableDoFnTest
2017-09-22T07:32:03.461 [INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped:
0, Time elapsed: 271.828 s - in
org.apache.beam.sdk.transforms.SplittableDoFnTest
2017-09-22T07:32:03.461 [INFO] Running org.apache.beam.sdk.values.PDoneTest
2017-09-22T07:32:03.466 [WARNING] Tests run: 1, Failures: 0, Errors: 0,
Skipped: 1, Time elapsed: 0 s - in org.apache.beam.sdk.values.PDoneTest
2017-09-22T07:32:03.466 [INFO] Running org.apache.beam.sdk.transforms.KvSwapTest
2017-09-22T07:32:03.497 [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped:
0, Time elapsed: 214.534 s - in org.apache.beam.sdk.transforms.KvSwapTest
2017-09-22T07:32:03.497 [INFO] Running org.apache.beam.sdk.transforms.FilterTest
2017-09-22T07:32:03.501 [INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped:
0, Time elapsed: 213.792 s - in org.apache.beam.sdk.transforms.FilterTest
2017-09-22T07:32:03.501 [INFO] Running
org.apache.beam.sdk.transforms.windowing.WindowingTest
2017-09-22T07:32:03.505 [INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped:
0, Time elapsed: 307.626 s - in
org.apache.beam.sdk.transforms.windowing.WindowingTest
2017-09-22T07:32:03.509 [INFO]
2017-09-22T07:32:03.509 [INFO] Results:
2017-09-22T07:32:03.509 [INFO]
2017-09-22T07:32:03.509 [ERROR] Errors:
2017-09-22T07:32:03.511 [ERROR] ParDoTest.testBagState:2013 ยป Runtime
(4a1b1908507e992): java.lang.AssertionEr...
2017-09-22T07:32:03.511 [INFO]
2017-09-22T07:32:03.511 [ERROR] Tests run: 257, Failures: 0, Errors: 1,
Skipped: 1
2017-09-22T07:32:03.512 [INFO]
2017-09-22T07:32:03.842 [ERROR] There are test failures.
Please refer to
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/ws/runners/google-cloud-dataflow-java/target/surefire-reports>
for the individual test results.
Please refer to dump files (if any exist) [date]-jvmRun[N].dump,
[date].dumpstream and [date]-jvmRun[N].dumpstream.
[JENKINS] Recording test results
2017-09-22T07:32:04.931 [INFO]
2017-09-22T07:32:04.931 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only
(default) @ beam-runners-google-cloud-dataflow-java ---
2017-09-22T07:32:05.048 [INFO] No dependency problems found
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
2017-09-22T07:32:17.568 [INFO]
------------------------------------------------------------------------
2017-09-22T07:32:17.568 [INFO] Reactor Summary:
2017-09-22T07:32:17.568 [INFO]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: Parent
.............................. SUCCESS [ 20.727 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: SDKs :: Java :: Build Tools
......... SUCCESS [ 9.984 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: SDKs
................................ SUCCESS [ 4.037 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: SDKs :: Common
...................... SUCCESS [ 2.085 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: SDKs :: Common :: Runner API
........ SUCCESS [ 13.951 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: SDKs :: Common :: Fn API
............ SUCCESS [ 7.075 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: SDKs :: Java
........................ SUCCESS [ 2.178 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: SDKs :: Java :: Core
................ SUCCESS [01:15 min]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: Runners
............................. SUCCESS [ 2.030 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: Runners :: Core Construction Java
... SUCCESS [ 12.450 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: Runners :: Core Java
................ SUCCESS [ 24.432 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: Runners :: Direct Java
.............. SUCCESS [03:59 min]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: SDKs :: Java :: IO
.................. SUCCESS [ 2.190 s]
2017-09-22T07:32:17.568 [INFO] Apache Beam :: SDKs :: Java :: Extensions
.......... SUCCESS [ 2.055 s]
2017-09-22T07:32:17.569 [INFO] Apache Beam :: SDKs :: Java :: Extensions ::
Google Cloud Platform Core SUCCESS [ 27.334 s]
2017-09-22T07:32:17.569 [INFO] Apache Beam :: SDKs :: Java :: Extensions ::
Protobuf SUCCESS [ 12.920 s]
2017-09-22T07:32:17.569 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google
Cloud Platform SUCCESS [01:17 min]
2017-09-22T07:32:17.569 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow
.... SUCCESS [ 01:20 h]
2017-09-22T07:32:17.569 [INFO]
------------------------------------------------------------------------
2017-09-22T07:32:17.569 [INFO] BUILD SUCCESS
2017-09-22T07:32:17.569 [INFO]
------------------------------------------------------------------------
2017-09-22T07:32:17.569 [INFO] Total time: 01:30 h
2017-09-22T07:32:17.569 [INFO] Finished at: 2017-09-22T07:32:17+00:00
2017-09-22T07:32:18.894 [INFO] Final Memory: 369M/2158M
2017-09-22T07:32:18.894 [INFO]
------------------------------------------------------------------------
Waiting for Jenkins to finish collecting data
channel stopped
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user
[email protected]
