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

Changes:

[mxm] [BEAM-8742] Add stateful and timely processing benchmarks

[mxm] [BEAM-9900] Remove shutdownSourcesOnFinalWatermark flag

[github] [BEAM-9913] remove license dir if exists (#11630)

[github] Merge pull request #11624 from [BEAM-9767] Make streaming_wordcount use


------------------------------------------
[...truncated 149.96 KB...]
                          "pipeline_proto_coder_id": 
"ref_Coder_FastPrimitivesCoder_5"
                        }
                      ],
                      "is_pair_like": true,
                      "pipeline_proto_coder_id": 
"ref_Coder_FastPrimitivesCoder_5"
                    },
                    {
                      "@type": "kind:global_window"
                    }
                  ],
                  "is_wrapper": true
                }
              ],
              "is_stream_like": {
                "value": true
              }
            },
            "output_name": "out",
            "user_name": 
"write/Write/WriteImpl/FinalizeWrite/_UnpickledSideInput(PreFinalize.out.0).output"
          }
        ],
        "parallel_input": {
          "@type": "OutputReference",
          "output_name": "None",
          "step_name": "s17"
        },
        "user_name": 
"write/Write/WriteImpl/FinalizeWrite/_UnpickledSideInput(PreFinalize.out.0)",
        "windowing_strategy": 
"%0AB%22%40%0A%1Dref_Coder_GlobalWindowCoder_1%12%1F%0A%1D%0A%1Bbeam%3Acoder%3Aglobal_window%3Av1jQ%0A%22%0A%20beam%3Awindow_fn%3Aglobal_windows%3Av1%10%01%1A%1Dref_Coder_GlobalWindowCoder_1%22%02%3A%00%28%010%018%01H%01"
      }
    },
    {
      "kind": "ParallelDo",
      "name": "s21",
      "properties": {
        "display_data": [
          {
            "key": "fn",
            "label": "Transform Function",
            "namespace": "apache_beam.transforms.core.ParDo",
            "shortValue": "CallableWrapperDoFn",
            "type": "STRING",
            "value": "apache_beam.transforms.core.CallableWrapperDoFn"
          },
          {
            "key": "fn",
            "label": "Transform Function",
            "namespace": "apache_beam.transforms.core.CallableWrapperDoFn",
            "type": "STRING",
            "value": "_finalize_write"
          }
        ],
        "non_parallel_inputs": {
          "python_side_input0-write/Write/WriteImpl/FinalizeWrite": {
            "@type": "OutputReference",
            "output_name": "out",
            "step_name": "SideInput-s18"
          },
          "python_side_input1-write/Write/WriteImpl/FinalizeWrite": {
            "@type": "OutputReference",
            "output_name": "out",
            "step_name": "SideInput-s19"
          },
          "python_side_input2-write/Write/WriteImpl/FinalizeWrite": {
            "@type": "OutputReference",
            "output_name": "out",
            "step_name": "SideInput-s20"
          }
        },
        "output_info": [
          {
            "encoding": {
              "@type": "kind:windowed_value",
              "component_encodings": [
                {
                  "@type": 
"FastPrimitivesCoder$eNprYE5OLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqYIfgYGhvi0xJycpMTk7HiwlkJ8pgVkJmfnpEJNYQGawlpbyJZUnKQHACYlLgM=",
                  "component_encodings": [
                    {
                      "@type": 
"FastPrimitivesCoder$eNprYE5OLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqYIfgYGhvi0xJycpMTk7HiwlkJ8pgVkJmfnpEJNYQGawlpbyJZUnKQHACYlLgM=",
                      "component_encodings": [],
                      "pipeline_proto_coder_id": 
"ref_Coder_FastPrimitivesCoder_5"
                    },
                    {
                      "@type": 
"FastPrimitivesCoder$eNprYE5OLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqYIfgYGhvi0xJycpMTk7HiwlkJ8pgVkJmfnpEJNYQGawlpbyJZUnKQHACYlLgM=",
                      "component_encodings": [],
                      "pipeline_proto_coder_id": 
"ref_Coder_FastPrimitivesCoder_5"
                    }
                  ],
                  "is_pair_like": true,
                  "pipeline_proto_coder_id": "ref_Coder_FastPrimitivesCoder_5"
                },
                {
                  "@type": "kind:global_window"
                }
              ],
              "is_wrapper": true
            },
            "output_name": "None",
            "user_name": "write/Write/WriteImpl/FinalizeWrite.out"
          }
        ],
        "parallel_input": {
          "@type": "OutputReference",
          "output_name": "out",
          "step_name": "s7"
        },
        "serialized_fn": 
"eNrNWHd8FMcV3rsTbQEbQ0xMnHIh4Jwc7o4SDCGO2wkMPnMoKxk2iclmb3fuZtGWezOzEnJYbJAlEezE6dXpvfeeOL33YsepTpwep1en4jezdxKnCIX8Zf8QO9qZfW/fe9/3vpnVdbmCY7dshxKrTuygJJgd8kbEAl5yIkb0iu37dt0n+5jdahHWF+0IddB6j0AmgWzBXKBpWotFDuEccl2OvAh/6jYnutXwQtv3riHWCPME0aHHXIxmlhhtEYt6oeAwz3E93y9Z8qpbDiO2IFZoB8QVcctHk/nKZNeeQbTZqUwWqBkvbMVCeeKw0FyCM1EspqcWmfPlFPOaXgj6JCw283jflS8+p2IouQQTtkXEOCyZhKUGnFGr7YczJ2GZAWeZORlxI4TltEe9xmrEWBjW5C3iwIpaXN8P9yvMLIAgB4UX6dYgjgNeOKTD2Vi5lQncv2AuQydOFLQYls6LQhUwnGP2yPhiEcEqVVuLEtslDB5QM8/CW05t5qrCWBIjW8C55hqcL64ttJfioHf9ZrcYNXAKbyw1zeUcPNDU8dHpSXhQVTNXdntt+lG94/rBarF4/qzOHqISaHh+ipPF40bDOwj5rhJELUw/5KVh24+JhTwZ9jAZfUDYwnP2ysn+zhw8FCuzOoGHFVSUqYWqyZoubviR7ap5HdYqULhgcN44PNyAgjmvYwm9Jv6qwflx3VwlyyjJG6Ihsz3fC5tWSEZwRIY84piyciJZ5XVd0as53h70weiyUUF4JVLRFjHaUgLl+nQZWragmCORZVhPZTobEthYoGtogfaae/CxJt9WLgsStIocaWY3SRErXcS4iiJKB8IFL7dGi54oOn4Uu+WUzeUNm7du3bpl66YtmzduWV9GysQ+tsAmzG4R+g28oF2rR6riSdqVW76NnN8c17tJGQrCsBtLsfB8/VLWjAMSin7fdgiNfJXaBRj5FiqvW6sZNT6KJLBtPzy6YF4g231UUOQrR9gs1X7ri6qvy/umr7uCll/e0W57NQMXdsXRUjDp1lVhy3OGfOIOoLtd0psOj0ngooKi+4gXutGIFSB6EjRsv4tPJVYyHBUN1xWJbd/6L2sdLqFzQbxPGRBXMbMN9KWY/2UJVArmChmQUkHXSumZkqZvDo87bC76mRd4whue4s52dLkjgcvNM5WOoMDWbWeo7W3nHN76VanaXnahlysSqNZ5XTkSSAIu7KDVdnTlXFzuPNv2tRt91RLYU1fS1q5b6qZ/DjeXqzqnVWt7eix6MhIYULqblgkGT4VZ+qIuNzpchR72JrBPKaGFXQFml70kLi9NZTudiw6PQ9PHJ/AE9fLAc1jE4erjC2+/uXDnXSdOXMvr8h/2jPTs2sKG/bNxcoqJffiIDk9Ep1YCT0r3umGPjEge2rNtWI04dKTg6VAv0LXmQnxelkXuWeCMg2sAKVQzVQ3/56orKkuPadohTTuW0cay2gA0auPQ7FVW2C9MbrpAx8EzGc6UaRSQ8gESDnkh74xF7tvDpDwSsSGOeZCyTMPqJ0wJeOiQQakn1r6IuZUoDsWuQat/dNPmMmdOmbtDUmlkK5dPKkI5LUKpNQoHVCgX+nZQd+2LYGj38UxFA988WwoeiwKLoUupPFPRBoo+qkRt5YdwAqJeAS0DoKtiTSIsWwhkDFOvqceeLzAl4KrMuCxXQUxAbMBwl6kXtCImrCByY3kyGDGXz9jS0xTg4DiMGnCNcm+hrSMsC548AYcMSOhQbTYAHYI3cJgifIhUFpHKVRdUK5WjAvsrox3ISrxchddYRkvwNqvxDdohXMppblYTPdqYptAU8+QaPuTmtKGsxqry1u3RVg2I+Zo7T5taFws6K9M3OXXTyGkrcTiKPjSkx7WFWjWriuOSho36D9dJLpmHcaa/Evk+UdzLR408R9HNr3XzI56g+QBPcXlBbVwJSZ74RAp+3nbkkY24eZvnbTQImz4RaC3BK+V3eIyLvBiJOs/zPAkdSSHCpA16XL2Wr16nriU4IuBoQXWV73EBY2pTkqwQUeRzuF71o8d9zyEwrjZtxBcmzDPwt+1BS4xOtRxMqmWfhHBMbWVKirczFjF4Cj1PwHEzq3zDDaoUHZrdqN4uz0rw1El4Gj2gji7W7DS9affdmcoyLXtOZn5mRWZ5ZmEml8ll4em9SNRnGPBMmtCbaiiHz6oJeLYBzxmH5xrwPHo4geefalt6Ab3kpGPEC6ncNV6UwM0F2kel3L84gZfQnVRq9ksTeBnKEL2SStV9eQKvqNN+KnXzlQm8ig7SvVKj4nF4tQGvmYDXJvA6jOP1BryBXoxvkTVLwZMHDrmZwxvNc2UHIfW3TW/K2zrpbhveAG9Ch5Pw5tm37w2ntX2/heK2/NaCjIGuU/m9LYG3d/J7RwLvxPyumMrrXQm8u5PXexJ4bycvup9KQX1fAu8vULvdaKkkZqoDlZ5DkuofQCX8YC9F8fvQvSV+H+4Wv1t2r85SXxLkIwZ8FAlyiyTIxxCYjxvwCVWU/43CJxUKn5odhY2nhcKnJQqfORmFzybwuQ4Kn0/gC10ofDGBL3VQ+HICX5mBwlcT+NpMFGbZmL6OcHxDwfHNewuOW7vhuA33IurTgOL28i0E5XYDvo2g3Faj903t/o7Ubnqf0evvCvhegY7R6+k4naCT9BhV2vp9egO9kaJ+/oDeOpd+3jG7fv5QtsePDLgTkbhDtsePsT1+YsBPx+FnBvxc6ucvTqWfv+zSz18pZt+VwK87zP5NAr9t6+fvEvj9tH7+IYE/dhj+pwT+fJJ+/sWAv07A3xK4G+P4uwH/OM02/adq03+ROf8skp5WMXod/o2v/k8CJwrpXzU8brU3aKZlsInU8eTkw3lQxw9PxjK4WM0oXqf1aIQsi3P/x2GZ6yyHFr1HWA8OqrTIkziIfVtSSx6RCJuXvkd+puKXhvy8sXCZ4LcvZ/Nnvm/m4bovZsqVzhakL1qIQ8IW4ZVeXdV4+v0pmNdsYqeHTJ8jgfZTel9ancH2LVucel6CQ1wXbCmOpXsAl/Na5w==",
        "user_name": "write/Write/WriteImpl/FinalizeWrite/FinalizeWrite"
      }
    }
  ],
  "type": "JOB_TYPE_BATCH"
}
INFO:apache_beam.runners.dataflow.internal.apiclient:Create job: <Job
 createTime: '2020-05-07T19:06:20.771906Z'
 currentStateTime: '1970-01-01T00:00:00Z'
 id: '2020-05-07_12_06_19-10514987612860321915'
 location: 'us-central1'
 name: 'beamapp-jenkins-0507190616-741187'
 projectId: 'apache-beam-testing'
 stageStates: []
 startTime: '2020-05-07T19:06:20.771906Z'
 steps: []
 tempFiles: []
 type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)>
INFO:apache_beam.runners.dataflow.internal.apiclient:Created job with id: 
[2020-05-07_12_06_19-10514987612860321915]
INFO:apache_beam.runners.dataflow.internal.apiclient:Submitted job: 
2020-05-07_12_06_19-10514987612860321915
INFO:apache_beam.runners.dataflow.internal.apiclient:To access the Dataflow 
monitoring console, please navigate to 
https://console.cloud.google.com/dataflow/jobs/us-central1/2020-05-07_12_06_19-10514987612860321915?project=apache-beam-testing
INFO:apache_beam.runners.dataflow.dataflow_runner:Job 
2020-05-07_12_06_19-10514987612860321915 is in state JOB_STATE_RUNNING
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:22.961Z: 
JOB_MESSAGE_DETAILED: Checking permissions granted to controller Service 
Account.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:23.470Z: 
JOB_MESSAGE_BASIC: Worker configuration: n1-standard-1 in us-central1-a.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.221Z: 
JOB_MESSAGE_DETAILED: Expanding CoGroupByKey operations into optimizable parts.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.258Z: 
JOB_MESSAGE_DEBUG: Combiner lifting skipped for step 
write/Write/WriteImpl/GroupByKey: GroupByKey not followed by a combiner.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.304Z: 
JOB_MESSAGE_DEBUG: Combiner lifting skipped for step group: GroupByKey not 
followed by a combiner.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.335Z: 
JOB_MESSAGE_DETAILED: Expanding GroupByKey operations into optimizable parts.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.368Z: 
JOB_MESSAGE_DETAILED: Lifting ValueCombiningMappingFns into 
MergeBucketsMappingFns
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.462Z: 
JOB_MESSAGE_DEBUG: Annotating graph with Autotuner information.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.512Z: 
JOB_MESSAGE_DETAILED: Fusing adjacent ParDo, Read, Write, and Flatten operations
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.548Z: 
JOB_MESSAGE_DETAILED: Fusing consumer split into read/Read
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.586Z: 
JOB_MESSAGE_DETAILED: Fusing consumer pair_with_one into split
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.617Z: 
JOB_MESSAGE_DETAILED: Fusing consumer group/Reify into pair_with_one
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.657Z: 
JOB_MESSAGE_DETAILED: Fusing consumer group/Write into group/Reify
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.693Z: 
JOB_MESSAGE_DETAILED: Fusing consumer group/GroupByWindow into group/Read
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.731Z: 
JOB_MESSAGE_DETAILED: Fusing consumer count into group/GroupByWindow
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.767Z: 
JOB_MESSAGE_DETAILED: Fusing consumer format into count
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.809Z: 
JOB_MESSAGE_DETAILED: Fusing consumer 
write/Write/WriteImpl/WindowInto(WindowIntoFn) into format
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.843Z: 
JOB_MESSAGE_DETAILED: Fusing consumer 
write/Write/WriteImpl/WriteBundles/WriteBundles into 
write/Write/WriteImpl/WindowInto(WindowIntoFn)
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.876Z: 
JOB_MESSAGE_DETAILED: Fusing consumer write/Write/WriteImpl/Pair into 
write/Write/WriteImpl/WriteBundles/WriteBundles
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.913Z: 
JOB_MESSAGE_DETAILED: Fusing consumer write/Write/WriteImpl/GroupByKey/Reify 
into write/Write/WriteImpl/Pair
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.954Z: 
JOB_MESSAGE_DETAILED: Fusing consumer write/Write/WriteImpl/GroupByKey/Write 
into write/Write/WriteImpl/GroupByKey/Reify
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:24.988Z: 
JOB_MESSAGE_DETAILED: Fusing consumer 
write/Write/WriteImpl/GroupByKey/GroupByWindow into 
write/Write/WriteImpl/GroupByKey/Read
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.023Z: 
JOB_MESSAGE_DETAILED: Fusing consumer write/Write/WriteImpl/Extract into 
write/Write/WriteImpl/GroupByKey/GroupByWindow
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.059Z: 
JOB_MESSAGE_DETAILED: Fusing consumer write/Write/WriteImpl/InitializeWrite 
into write/Write/WriteImpl/DoOnce/Read
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.094Z: 
JOB_MESSAGE_DEBUG: Workflow config is missing a default resource spec.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.132Z: 
JOB_MESSAGE_DEBUG: Adding StepResource setup and teardown to workflow graph.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.168Z: 
JOB_MESSAGE_DEBUG: Adding workflow start and stop steps.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.206Z: 
JOB_MESSAGE_DEBUG: Assigning stage ids.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.522Z: 
JOB_MESSAGE_DEBUG: Executing wait step start26
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.603Z: 
JOB_MESSAGE_BASIC: Executing operation 
write/Write/WriteImpl/DoOnce/Read+write/Write/WriteImpl/InitializeWrite
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.634Z: 
JOB_MESSAGE_BASIC: Executing operation write/Write/WriteImpl/GroupByKey/Create
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.647Z: 
JOB_MESSAGE_DEBUG: Starting worker pool setup.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.665Z: 
JOB_MESSAGE_BASIC: Executing operation group/Create
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.674Z: 
JOB_MESSAGE_BASIC: Starting 10 workers in us-central1-a...
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.739Z: 
JOB_MESSAGE_BASIC: Finished operation write/Write/WriteImpl/GroupByKey/Create
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.740Z: 
JOB_MESSAGE_BASIC: Finished operation group/Create
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.801Z: 
JOB_MESSAGE_DEBUG: Value "group/Session" materialized.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.840Z: 
JOB_MESSAGE_DEBUG: Value "write/Write/WriteImpl/GroupByKey/Session" 
materialized.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:25.866Z: 
JOB_MESSAGE_BASIC: Executing operation 
read/Read+split+pair_with_one+group/Reify+group/Write
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:06:57.915Z: 
JOB_MESSAGE_WARNING: Your project already contains 100 Dataflow-created metric 
descriptors and Stackdriver will not create new Dataflow custom metrics for 
this job. Each unique user-defined metric name (independent of the DoFn in 
which it is defined) produces a new metric descriptor. To delete old / unused 
metric descriptors see 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:07:06.037Z: 
JOB_MESSAGE_DETAILED: Autoscaling: Raised the number of workers to 8 based on 
the rate of progress in the currently running stage(s).
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:07:06.071Z: 
JOB_MESSAGE_DETAILED: Resized worker pool to 8, though goal was 10.  This could 
be a quota issue.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:07:11.475Z: 
JOB_MESSAGE_DETAILED: Autoscaling: Raised the number of workers to 10 based on 
the rate of progress in the currently running stage(s).
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:08:33.143Z: 
JOB_MESSAGE_DETAILED: Workers have started successfully.
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-05-07T19:08:33.176Z: 
JOB_MESSAGE_DETAILED: Workers have started successfully.
Terminated
The message received from the daemon indicates that the daemon has disappeared.
Build request sent: Build{id=d8ebeb3b-8853-4a9f-a009-aacc17dfc0f6, 
currentDir=<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/src}>
Attempting to read last messages from the daemon log...
Daemon pid: 4303
  log file: /home/jenkins/.gradle/daemon/5.2.1/daemon-4303.out.log
----- Last  20 lines from daemon log file - daemon-4303.out.log -----
        at 
org.gradle.process.internal.DefaultExecHandle.execExceptionFor(DefaultExecHandle.java:232)
        at 
org.gradle.process.internal.DefaultExecHandle.setEndStateInfo(DefaultExecHandle.java:209)
        at 
org.gradle.process.internal.DefaultExecHandle.failed(DefaultExecHandle.java:356)
        at 
org.gradle.process.internal.ExecHandleRunner.run(ExecHandleRunner.java:86)
        at 
org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
        at 
org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
        at 
org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at 
org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IllegalStateException: Shutdown in progress
        at 
java.lang.ApplicationShutdownHooks.remove(ApplicationShutdownHooks.java:82)
        at java.lang.Runtime.removeShutdownHook(Runtime.java:239)
        at 
org.gradle.process.internal.shutdown.ShutdownHooks.removeShutdownHook(ShutdownHooks.java:33)
        at 
org.gradle.process.internal.DefaultExecHandle.setEndStateInfo(DefaultExecHandle.java:199)
        at 
org.gradle.process.internal.DefaultExecHandle.aborted(DefaultExecHandle.java:352)
        at 
org.gradle.process.internal.ExecHandleRunner.completed(ExecHandleRunner.java:107)
        at 
org.gradle.process.internal.ExecHandleRunner.run(ExecHandleRunner.java:83)
        ... 7 more
----- End of the daemon log -----


FAILURE: Build failed with an exception.

* What went wrong:
Gradle build daemon disappeared unexpectedly (it may have been killed or may 
have crashed)

* 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

2020-05-07 19:09:08,229 f69ea9c4 MainThread beam_integration_benchmark(1/1) 
ERROR    Error during benchmark beam_integration_benchmark
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
 line 846, in RunBenchmark
    DoRunPhase(spec, collector, detailed_timer)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
 line 689, in DoRunPhase
    samples = spec.BenchmarkRun(spec)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/PerfKitBenchmarker/perfkitbenchmarker/linux_benchmarks/beam_integration_benchmark.py";,>
 line 161, in Run
    job_type=job_type)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/PerfKitBenchmarker/perfkitbenchmarker/providers/gcp/gcp_dpb_dataflow.py";,>
 line 96, in SubmitJob
    assert retcode == 0, "Integration Test Failed."
AssertionError: Integration Test Failed.
2020-05-07 19:09:08,230 f69ea9c4 MainThread beam_integration_benchmark(1/1) 
INFO     Cleaning up benchmark beam_integration_benchmark
2020-05-07 19:09:08,232 f69ea9c4 MainThread beam_integration_benchmark(1/1) 
ERROR    Exception running benchmark
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
 line 995, in RunBenchmarkTask
    RunBenchmark(spec, collector)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
 line 846, in RunBenchmark
    DoRunPhase(spec, collector, detailed_timer)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
 line 689, in DoRunPhase
    samples = spec.BenchmarkRun(spec)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/PerfKitBenchmarker/perfkitbenchmarker/linux_benchmarks/beam_integration_benchmark.py";,>
 line 161, in Run
    job_type=job_type)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/PerfKitBenchmarker/perfkitbenchmarker/providers/gcp/gcp_dpb_dataflow.py";,>
 line 96, in SubmitJob
    assert retcode == 0, "Integration Test Failed."
AssertionError: Integration Test Failed.
2020-05-07 19:09:08,232 f69ea9c4 MainThread beam_integration_benchmark(1/1) 
ERROR    Benchmark 1/1 beam_integration_benchmark (UID: 
beam_integration_benchmark0) failed. Execution will continue.
2020-05-07 19:09:08,232 f69ea9c4 MainThread beam_integration_benchmark(1/1) 
INFO     Benchmark run statuses:
---------------------------------------------------------------------------------
Name                        UID                          Status  Failed 
Substatus
---------------------------------------------------------------------------------
beam_integration_benchmark  beam_integration_benchmark0  FAILED                 
 
---------------------------------------------------------------------------------
Success rate: 0.00% (0/1)
2020-05-07 19:09:08,233 f69ea9c4 MainThread beam_integration_benchmark(1/1) 
INFO     Complete logs can be found at: 
<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/runs/f69ea9c4/pkb.log>
2020-05-07 19:09:08,233 f69ea9c4 MainThread beam_integration_benchmark(1/1) 
INFO     Completion statuses can be found at: 
<https://builds.apache.org/job/beam_PerformanceTests_WordCountIT_Py35/ws/runs/f69ea9c4/completion_statuses.json>
Build step 'Execute shell' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to