You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2017/01/21 04:30:31 UTC

Build failed in Jenkins: beam_PostCommit_Python_Verify #1059

See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/1059/changes>

Changes:

[dhalperi] Clean *.pyc files with mvn clean.

------------------------------------------
[...truncated 18927 lines...]
      }
    }, 
    {
      "kind": "GroupByKey", 
      "name": "s8", 
      "properties": {
        "display_data": [], 
        "output_info": [
          {
            "encoding": {
              "@type": "kind:windowed_value", 
              "component_encodings": [
                {
                  "@type": "kind:pair", 
                  "component_encodings": [
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": [
                        {
                          "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                          "component_encodings": []
                        }, 
                        {
                          "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                          "component_encodings": []
                        }
                      ], 
                      "is_pair_like": true
                    }, 
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": [
                        {
                          "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                          "component_encodings": []
                        }, 
                        {
                          "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                          "component_encodings": []
                        }
                      ], 
                      "is_pair_like": true
                    }
                  ], 
                  "is_pair_like": true
                }, 
                {
                  "@type": "kind:global_window"
                }
              ], 
              "is_wrapper": true
            }, 
            "output_name": "out", 
            "user_name": "assert_that/Group.out"
          }
        ], 
        "parallel_input": {
          "@type": "OutputReference", 
          "output_name": "out", 
          "step_name": "s7"
        }, 
        "serialized_fn": "<string of 252 bytes>", 
        "user_name": "assert_that/Group"
      }
    }, 
    {
      "kind": "ParallelDo", 
      "name": "s9", 
      "properties": {
        "display_data": [
          {
            "key": "fn", 
            "label": "Transform Function", 
            "namespace": "apache_beam.transforms.core.CallableWrapperDoFn", 
            "type": "STRING", 
            "value": "<lambda>"
          }, 
          {
            "key": "fn", 
            "label": "Transform Function", 
            "namespace": "apache_beam.transforms.core.ParDo", 
            "shortValue": "CallableWrapperDoFn", 
            "type": "STRING", 
            "value": "apache_beam.transforms.core.CallableWrapperDoFn"
          }
        ], 
        "non_parallel_inputs": {}, 
        "output_info": [
          {
            "encoding": {
              "@type": "kind:windowed_value", 
              "component_encodings": [
                {
                  "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                  "component_encodings": [
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": []
                    }, 
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": []
                    }
                  ], 
                  "is_pair_like": true
                }, 
                {
                  "@type": "kind:global_window"
                }
              ], 
              "is_wrapper": true
            }, 
            "output_name": "out", 
            "user_name": "assert_that/UnKey.out"
          }
        ], 
        "parallel_input": {
          "@type": "OutputReference", 
          "output_name": "out", 
          "step_name": "s8"
        }, 
        "serialized_fn": "<string of 1060 bytes>", 
        "user_name": "assert_that/UnKey"
      }
    }, 
    {
      "kind": "ParallelDo", 
      "name": "s10", 
      "properties": {
        "display_data": [
          {
            "key": "fn", 
            "label": "Transform Function", 
            "namespace": "apache_beam.transforms.core.CallableWrapperDoFn", 
            "type": "STRING", 
            "value": "_equal"
          }, 
          {
            "key": "fn", 
            "label": "Transform Function", 
            "namespace": "apache_beam.transforms.core.ParDo", 
            "shortValue": "CallableWrapperDoFn", 
            "type": "STRING", 
            "value": "apache_beam.transforms.core.CallableWrapperDoFn"
          }
        ], 
        "non_parallel_inputs": {}, 
        "output_info": [
          {
            "encoding": {
              "@type": "kind:windowed_value", 
              "component_encodings": [
                {
                  "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                  "component_encodings": [
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": []
                    }, 
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": []
                    }
                  ], 
                  "is_pair_like": true
                }, 
                {
                  "@type": "kind:global_window"
                }
              ], 
              "is_wrapper": true
            }, 
            "output_name": "out", 
            "user_name": "assert_that/Match.out"
          }
        ], 
        "parallel_input": {
          "@type": "OutputReference", 
          "output_name": "out", 
          "step_name": "s9"
        }, 
        "serialized_fn": "<string of 1248 bytes>", 
        "user_name": "assert_that/Match"
      }
    }
  ], 
  "type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
 id: u'2017-01-20_20_26_15-18426858165806089191'
 projectId: u'apache-beam-testing'
 steps: []
 tempFiles: []
 type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-01-20_20_26_15-18426858165806089191]
root: INFO: To access the Dataflow monitoring console, please navigate to https://console.developers.google.com/project/apache-beam-testing/dataflow/job/2017-01-20_20_26_15-18426858165806089191
root: INFO: Job 2017-01-20_20_26_15-18426858165806089191 is in state JOB_STATE_RUNNING
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4674dc: 2017-01-21T04:26:22.812Z: JOB_MESSAGE_DETAILED: (caed3591c44d3219): Checking required Cloud APIs are enabled.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4676de: 2017-01-21T04:26:23.326Z: JOB_MESSAGE_DEBUG: (caed3591c44d3af0): Combiner lifting skipped for step assert_that/Group: GroupByKey not followed by a combiner.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4676e0: 2017-01-21T04:26:23.328Z: JOB_MESSAGE_DEBUG: (caed3591c44d3eae): Combiner lifting skipped for step CountWords/GroupCounts: GroupByKey not followed by a combiner.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4676e3: 2017-01-21T04:26:23.331Z: JOB_MESSAGE_DETAILED: (caed3591c44d326c): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4676e6: 2017-01-21T04:26:23.334Z: JOB_MESSAGE_DETAILED: (caed3591c44d362a): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4676ec: 2017-01-21T04:26:23.340Z: JOB_MESSAGE_DETAILED: (caed3591c44d3164): Annotating graph with Autotuner information.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4676f7: 2017-01-21T04:26:23.351Z: JOB_MESSAGE_DETAILED: (caed3591c44d32bf): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4676fc: 2017-01-21T04:26:23.356Z: JOB_MESSAGE_DETAILED: (caed3591c44d3a3b): Fusing consumer CountWords/GroupCounts/Reify into CountWords/AddCount
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4676ff: 2017-01-21T04:26:23.359Z: JOB_MESSAGE_DETAILED: (caed3591c44d3df9): Fusing consumer assert_that/WindowInto into CountWords/AddCounts
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467701: 2017-01-21T04:26:23.361Z: JOB_MESSAGE_DETAILED: (caed3591c44d31b7): Fusing consumer CountWords/AddCounts into CountWords/GroupCounts/GroupByWindow
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467703: 2017-01-21T04:26:23.363Z: JOB_MESSAGE_DETAILED: (caed3591c44d3575): Fusing consumer assert_that/UnKey into assert_that/Group/GroupByWindow
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467705: 2017-01-21T04:26:23.365Z: JOB_MESSAGE_DETAILED: (caed3591c44d3933): Fusing consumer assert_that/Match into assert_that/UnKey
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467707: 2017-01-21T04:26:23.367Z: JOB_MESSAGE_DETAILED: (caed3591c44d3cf1): Fusing consumer assert_that/Group/GroupByWindow into assert_that/Group/Read
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf46770a: 2017-01-21T04:26:23.370Z: JOB_MESSAGE_DETAILED: (caed3591c44d30af): Fusing consumer assert_that/Group/Write into assert_that/Group/Reify
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf46770c: 2017-01-21T04:26:23.372Z: JOB_MESSAGE_DETAILED: (caed3591c44d346d): Fusing consumer assert_that/Group/Reify into assert_that/ToVoidKey
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf46770e: 2017-01-21T04:26:23.374Z: JOB_MESSAGE_DETAILED: (caed3591c44d382b): Fusing consumer assert_that/ToVoidKey into assert_that/WindowInto
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467711: 2017-01-21T04:26:23.377Z: JOB_MESSAGE_DETAILED: (caed3591c44d3be9): Fusing consumer CountWords/AddCount into GetWords
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467713: 2017-01-21T04:26:23.379Z: JOB_MESSAGE_DETAILED: (caed3591c44d3fa7): Fusing consumer CountWords/GroupCounts/Write into CountWords/GroupCounts/Reify
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467715: 2017-01-21T04:26:23.381Z: JOB_MESSAGE_DETAILED: (caed3591c44d3365): Fusing consumer CountWords/GroupCounts/GroupByWindow into CountWords/GroupCounts/Read
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf46774b: 2017-01-21T04:26:23.435Z: JOB_MESSAGE_DEBUG: (caed3591c44d3977): Workflow config is missing a default resource spec.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf46774d: 2017-01-21T04:26:23.437Z: JOB_MESSAGE_DETAILED: (caed3591c44d3d35): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf46775d: 2017-01-21T04:26:23.453Z: JOB_MESSAGE_DEBUG: (feac9caff899d618): Adding workflow start and stop steps.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467767: 2017-01-21T04:26:23.463Z: JOB_MESSAGE_DEBUG: (64a5a7dad3b4334e): Assigning stage ids.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4677d6: 2017-01-21T04:26:23.574Z: JOB_MESSAGE_DEBUG: (e2af96bf5ea305ff): Executing wait step start2
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4677e0: 2017-01-21T04:26:23.584Z: JOB_MESSAGE_DEBUG: (782fd9a142f80a2a): Executing operation SomeWords
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467808: 2017-01-21T04:26:23.624Z: JOB_MESSAGE_DEBUG: (bf0c13e277a35c86): Value "SomeWords.out" materialized.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf467813: 2017-01-21T04:26:23.635Z: JOB_MESSAGE_BASIC: S01: (feac9caff899dcd2): Executing operation CountWords/GroupCounts/Create
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4678de: 2017-01-21T04:26:23.838Z: JOB_MESSAGE_DEBUG: (a1e64b3790725c8c): Starting worker pool setup.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4678e0: 2017-01-21T04:26:23.840Z: JOB_MESSAGE_BASIC: (a1e64b3790725e52): Starting 1 workers...
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4678f3: 2017-01-21T04:26:23.859Z: JOB_MESSAGE_DEBUG: (c280df6bcbce8d66): Value "CountWords/GroupCounts/Session" materialized.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4678fd: 2017-01-21T04:26:23.869Z: JOB_MESSAGE_BASIC: S02: (df98994761bf6b2f): Executing operation GetWords+CountWords/AddCount+CountWords/GroupCounts/Reify+CountWords/GroupCounts/Write
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf480c20: 2017-01-21T04:28:07.072Z: JOB_MESSAGE_DETAILED: (c34aedc4d67ca51c): Workers have started successfully.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48f91f: 2017-01-21T04:29:07.743Z: JOB_MESSAGE_BASIC: S03: (e2af96bf5ea3073b): Executing operation CountWords/GroupCounts/Close
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48f937: 2017-01-21T04:29:07.767Z: JOB_MESSAGE_BASIC: S04: (df98994761bf6b9c): Executing operation assert_that/Group/Create
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48f9e9: 2017-01-21T04:29:07.945Z: JOB_MESSAGE_DEBUG: (caed3591c44d324e): Value "assert_that/Group/Session" materialized.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48f9f4: 2017-01-21T04:29:07.956Z: JOB_MESSAGE_BASIC: S05: (c280df6bcbce8803): Executing operation CountWords/GroupCounts/Read+CountWords/GroupCounts/GroupByWindow+CountWords/AddCounts+assert_that/WindowInto+assert_that/ToVoidKey+assert_that/Group/Reify+assert_that/Group/Write
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48fc8c: 2017-01-21T04:29:08.620Z: JOB_MESSAGE_BASIC: S06: (e2af96bf5ea30964): Executing operation assert_that/Group/Close
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48fca5: 2017-01-21T04:29:08.645Z: JOB_MESSAGE_BASIC: S07: (c280df6bcbce8a29): Executing operation assert_that/Group/Read+assert_that/Group/GroupByWindow+assert_that/UnKey+assert_that/Match
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48fe86: 2017-01-21T04:29:09.126Z: JOB_MESSAGE_DEBUG: (7ae86fbd388e0f8e): Executing success step success0
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48fed1: 2017-01-21T04:29:09.201Z: JOB_MESSAGE_DETAILED: (92b8928b3bd49502): Cleaning up.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48ff44: 2017-01-21T04:29:09.316Z: JOB_MESSAGE_DEBUG: (92b8928b3bd49ef8): Starting worker pool teardown.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf48ff46: 2017-01-21T04:29:09.318Z: JOB_MESSAGE_BASIC: (92b8928b3bd498ee): Stopping worker pool...
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4a2445: 2017-01-21T04:30:24.325Z: JOB_MESSAGE_BASIC: (92b8928b3bd497df): Worker pool stopped.
root: INFO: 2017-01-20_20_26_15-18426858165806089191_00000159bf4a2468: 2017-01-21T04:30:24.360Z: JOB_MESSAGE_DEBUG: (92b8928b3bd495c1): Tearing down pending resources...
root: INFO: Job 2017-01-20_20_26_15-18426858165806089191 is in state JOB_STATE_DONE
--------------------- >> end captured logging << ---------------------

----------------------------------------------------------------------
Ran 20 tests in 5311.384s

FAILED (errors=19)
Build step 'Execute shell' marked build as failure

Build failed in Jenkins: beam_PostCommit_Python_Verify #1060

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/1060/>

------------------------------------------
[...truncated 18888 lines...]
      }
    }, 
    {
      "kind": "GroupByKey", 
      "name": "s8", 
      "properties": {
        "display_data": [], 
        "output_info": [
          {
            "encoding": {
              "@type": "kind:windowed_value", 
              "component_encodings": [
                {
                  "@type": "kind:pair", 
                  "component_encodings": [
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": [
                        {
                          "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                          "component_encodings": []
                        }, 
                        {
                          "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                          "component_encodings": []
                        }
                      ], 
                      "is_pair_like": true
                    }, 
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": [
                        {
                          "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                          "component_encodings": []
                        }, 
                        {
                          "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                          "component_encodings": []
                        }
                      ], 
                      "is_pair_like": true
                    }
                  ], 
                  "is_pair_like": true
                }, 
                {
                  "@type": "kind:global_window"
                }
              ], 
              "is_wrapper": true
            }, 
            "output_name": "out", 
            "user_name": "assert_that/Group.out"
          }
        ], 
        "parallel_input": {
          "@type": "OutputReference", 
          "output_name": "out", 
          "step_name": "s7"
        }, 
        "serialized_fn": "<string of 252 bytes>", 
        "user_name": "assert_that/Group"
      }
    }, 
    {
      "kind": "ParallelDo", 
      "name": "s9", 
      "properties": {
        "display_data": [
          {
            "key": "fn", 
            "label": "Transform Function", 
            "namespace": "apache_beam.transforms.core.CallableWrapperDoFn", 
            "type": "STRING", 
            "value": "<lambda>"
          }, 
          {
            "key": "fn", 
            "label": "Transform Function", 
            "namespace": "apache_beam.transforms.core.ParDo", 
            "shortValue": "CallableWrapperDoFn", 
            "type": "STRING", 
            "value": "apache_beam.transforms.core.CallableWrapperDoFn"
          }
        ], 
        "non_parallel_inputs": {}, 
        "output_info": [
          {
            "encoding": {
              "@type": "kind:windowed_value", 
              "component_encodings": [
                {
                  "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                  "component_encodings": [
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": []
                    }, 
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": []
                    }
                  ], 
                  "is_pair_like": true
                }, 
                {
                  "@type": "kind:global_window"
                }
              ], 
              "is_wrapper": true
            }, 
            "output_name": "out", 
            "user_name": "assert_that/UnKey.out"
          }
        ], 
        "parallel_input": {
          "@type": "OutputReference", 
          "output_name": "out", 
          "step_name": "s8"
        }, 
        "serialized_fn": "<string of 1060 bytes>", 
        "user_name": "assert_that/UnKey"
      }
    }, 
    {
      "kind": "ParallelDo", 
      "name": "s10", 
      "properties": {
        "display_data": [
          {
            "key": "fn", 
            "label": "Transform Function", 
            "namespace": "apache_beam.transforms.core.CallableWrapperDoFn", 
            "type": "STRING", 
            "value": "_equal"
          }, 
          {
            "key": "fn", 
            "label": "Transform Function", 
            "namespace": "apache_beam.transforms.core.ParDo", 
            "shortValue": "CallableWrapperDoFn", 
            "type": "STRING", 
            "value": "apache_beam.transforms.core.CallableWrapperDoFn"
          }
        ], 
        "non_parallel_inputs": {}, 
        "output_info": [
          {
            "encoding": {
              "@type": "kind:windowed_value", 
              "component_encodings": [
                {
                  "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                  "component_encodings": [
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": []
                    }, 
                    {
                      "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", 
                      "component_encodings": []
                    }
                  ], 
                  "is_pair_like": true
                }, 
                {
                  "@type": "kind:global_window"
                }
              ], 
              "is_wrapper": true
            }, 
            "output_name": "out", 
            "user_name": "assert_that/Match.out"
          }
        ], 
        "parallel_input": {
          "@type": "OutputReference", 
          "output_name": "out", 
          "step_name": "s9"
        }, 
        "serialized_fn": "<string of 1248 bytes>", 
        "user_name": "assert_that/Match"
      }
    }
  ], 
  "type": "JOB_TYPE_BATCH"
}
root: INFO: Create job: <Job
 id: u'2017-01-20_21_55_34-3625888022585888023'
 projectId: u'apache-beam-testing'
 steps: []
 tempFiles: []
 type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
root: INFO: Created job with id: [2017-01-20_21_55_34-3625888022585888023]
root: INFO: To access the Dataflow monitoring console, please navigate to https://console.developers.google.com/project/apache-beam-testing/dataflow/job/2017-01-20_21_55_34-3625888022585888023
root: INFO: Job 2017-01-20_21_55_34-3625888022585888023 is in state JOB_STATE_RUNNING
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982405: 2017-01-21T05:55:36.069Z: JOB_MESSAGE_DETAILED: (efc26194e50337ad): Checking required Cloud APIs are enabled.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982603: 2017-01-21T05:55:36.579Z: JOB_MESSAGE_DEBUG: (efc26194e50334cc): Combiner lifting skipped for step assert_that/Group: GroupByKey not followed by a combiner.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982605: 2017-01-21T05:55:36.581Z: JOB_MESSAGE_DEBUG: (efc26194e503309a): Combiner lifting skipped for step CountWords/GroupCounts: GroupByKey not followed by a combiner.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982607: 2017-01-21T05:55:36.583Z: JOB_MESSAGE_DETAILED: (efc26194e5033c68): Expanding GroupByKey operations into optimizable parts.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982609: 2017-01-21T05:55:36.585Z: JOB_MESSAGE_DETAILED: (efc26194e5033836): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98260f: 2017-01-21T05:55:36.591Z: JOB_MESSAGE_DETAILED: (efc26194e5033ba0): Annotating graph with Autotuner information.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982617: 2017-01-21T05:55:36.599Z: JOB_MESSAGE_DETAILED: (efc26194e5033123): Fusing adjacent ParDo, Read, Write, and Flatten operations
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98261a: 2017-01-21T05:55:36.602Z: JOB_MESSAGE_DETAILED: (efc26194e50338bf): Fusing consumer CountWords/GroupCounts/Reify into CountWords/AddCount
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98261c: 2017-01-21T05:55:36.604Z: JOB_MESSAGE_DETAILED: (efc26194e503348d): Fusing consumer assert_that/WindowInto into CountWords/AddCounts
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98261e: 2017-01-21T05:55:36.606Z: JOB_MESSAGE_DETAILED: (efc26194e503305b): Fusing consumer CountWords/AddCounts into CountWords/GroupCounts/GroupByWindow
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982620: 2017-01-21T05:55:36.608Z: JOB_MESSAGE_DETAILED: (efc26194e5033c29): Fusing consumer assert_that/UnKey into assert_that/Group/GroupByWindow
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982622: 2017-01-21T05:55:36.610Z: JOB_MESSAGE_DETAILED: (efc26194e50337f7): Fusing consumer assert_that/Match into assert_that/UnKey
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982624: 2017-01-21T05:55:36.612Z: JOB_MESSAGE_DETAILED: (efc26194e50333c5): Fusing consumer assert_that/Group/GroupByWindow into assert_that/Group/Read
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982626: 2017-01-21T05:55:36.614Z: JOB_MESSAGE_DETAILED: (efc26194e5033f93): Fusing consumer assert_that/Group/Write into assert_that/Group/Reify
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982628: 2017-01-21T05:55:36.616Z: JOB_MESSAGE_DETAILED: (efc26194e5033b61): Fusing consumer assert_that/Group/Reify into assert_that/ToVoidKey
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98262a: 2017-01-21T05:55:36.618Z: JOB_MESSAGE_DETAILED: (efc26194e503372f): Fusing consumer assert_that/ToVoidKey into assert_that/WindowInto
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98262c: 2017-01-21T05:55:36.620Z: JOB_MESSAGE_DETAILED: (efc26194e50332fd): Fusing consumer CountWords/AddCount into GetWords
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98262e: 2017-01-21T05:55:36.622Z: JOB_MESSAGE_DETAILED: (efc26194e5033ecb): Fusing consumer CountWords/GroupCounts/Write into CountWords/GroupCounts/Reify
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982630: 2017-01-21T05:55:36.624Z: JOB_MESSAGE_DETAILED: (efc26194e5033a99): Fusing consumer CountWords/GroupCounts/GroupByWindow into CountWords/GroupCounts/Read
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98265d: 2017-01-21T05:55:36.669Z: JOB_MESSAGE_DEBUG: (efc26194e5033a1b): Workflow config is missing a default resource spec.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98265f: 2017-01-21T05:55:36.671Z: JOB_MESSAGE_DETAILED: (efc26194e50335e9): Adding StepResource setup and teardown to workflow graph.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982696: 2017-01-21T05:55:36.726Z: JOB_MESSAGE_DEBUG: (d276bac930f41061): Adding workflow start and stop steps.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9826c8: 2017-01-21T05:55:36.776Z: JOB_MESSAGE_DEBUG: (246dbe442e3fb619): Assigning stage ids.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982735: 2017-01-21T05:55:36.885Z: JOB_MESSAGE_DEBUG: (f5775ea2d8eac2c6): Executing wait step start2
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98273e: 2017-01-21T05:55:36.894Z: JOB_MESSAGE_DEBUG: (ead1c80c897e5f8a): Executing operation SomeWords
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982748: 2017-01-21T05:55:36.904Z: JOB_MESSAGE_DEBUG: (80d9256e69c46fa3): Value "SomeWords.out" materialized.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98275e: 2017-01-21T05:55:36.926Z: JOB_MESSAGE_BASIC: S01: (7c2a38ed316ae956): Executing operation CountWords/GroupCounts/Create
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982829: 2017-01-21T05:55:37.129Z: JOB_MESSAGE_DEBUG: (68c4d47e8ffeba63): Starting worker pool setup.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf98282b: 2017-01-21T05:55:37.131Z: JOB_MESSAGE_BASIC: (68c4d47e8ffeb28d): Starting 1 workers...
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982839: 2017-01-21T05:55:37.145Z: JOB_MESSAGE_DEBUG: (16ffe9de6b02b900): Value "CountWords/GroupCounts/Session" materialized.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf982842: 2017-01-21T05:55:37.154Z: JOB_MESSAGE_BASIC: S02: (ead1c80c897e54c2): Executing operation GetWords+CountWords/AddCount+CountWords/GroupCounts/Reify+CountWords/GroupCounts/Write
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf99ee71: 2017-01-21T05:57:33.425Z: JOB_MESSAGE_DETAILED: (2307381aeb84cf87): Workers have started successfully.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9ac9f4: 2017-01-21T05:58:29.620Z: JOB_MESSAGE_BASIC: S03: (cc0f45fa1e0c52c2): Executing operation CountWords/GroupCounts/Close
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9aca08: 2017-01-21T05:58:29.640Z: JOB_MESSAGE_BASIC: S04: (a684e98fb1313a10): Executing operation assert_that/Group/Create
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9acabe: 2017-01-21T05:58:29.822Z: JOB_MESSAGE_DEBUG: (f5775ea2d8eac1b2): Value "assert_that/Group/Session" materialized.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9acac7: 2017-01-21T05:58:29.831Z: JOB_MESSAGE_BASIC: S05: (a684e98fb1313678): Executing operation CountWords/GroupCounts/Read+CountWords/GroupCounts/GroupByWindow+CountWords/AddCounts+assert_that/WindowInto+assert_that/ToVoidKey+assert_that/Group/Reify+assert_that/Group/Write
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9acd88: 2017-01-21T05:58:30.536Z: JOB_MESSAGE_BASIC: S06: (d276bac930f41fd5): Executing operation assert_that/Group/Close
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9acd9c: 2017-01-21T05:58:30.556Z: JOB_MESSAGE_BASIC: S07: (b6fdddcf016c8cc2): Executing operation assert_that/Group/Read+assert_that/Group/GroupByWindow+assert_that/UnKey+assert_that/Match
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9acf73: 2017-01-21T05:58:31.027Z: JOB_MESSAGE_DEBUG: (246dbe442e3fb69f): Executing success step success0
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9acfb9: 2017-01-21T05:58:31.097Z: JOB_MESSAGE_DETAILED: (3976714a73c0a4f3): Cleaning up.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9ad032: 2017-01-21T05:58:31.218Z: JOB_MESSAGE_DEBUG: (3976714a73c0aef9): Starting worker pool teardown.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9ad034: 2017-01-21T05:58:31.220Z: JOB_MESSAGE_BASIC: (3976714a73c0a8ff): Stopping worker pool...
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9be1aa: 2017-01-21T05:59:41.226Z: JOB_MESSAGE_BASIC: (3976714a73c0a008): Worker pool stopped.
root: INFO: 2017-01-20_21_55_34-3625888022585888023_00000159bf9be1bf: 2017-01-21T05:59:41.247Z: JOB_MESSAGE_DEBUG: (3976714a73c0ae1a): Tearing down pending resources...
root: INFO: Job 2017-01-20_21_55_34-3625888022585888023 is in state JOB_STATE_DONE
--------------------- >> end captured logging << ---------------------

----------------------------------------------------------------------
Ran 20 tests in 5031.886s

FAILED (errors=19)
Build step 'Execute shell' marked build as failure