See <https://ci-beam.apache.org/job/beam_LoadTests_Python_ParDo_Dataflow_Streaming/593/display/redirect?page=changes>
Changes: [yathu] [BEAM-14375] Fix Java Wordcount Dataflow postcommit [Robert Bradshaw] Allow arithmetic between deferred scalars. [noreply] [BEAM-14390] Set user-agent when pulling licenses to avoid 403s (#17521) [noreply] [BEAM-8688] Upgrade GCSIO to 2.2.6 (#17486) [noreply] [BEAM-14253] patch SubscriptionPartitionLoader to work around a dataflow [noreply] Add website link log to notify user of pre-build workflow. (#17498) [noreply] [BEAM-11105] Add timestamp observing watermark estimation (#17476) [noreply] Merge pull request #17487 from Adding user-agent to GCS client in Python [noreply] [BEAM-10265] Display error message if trying to infer recursive schema [noreply] [BEAM-12575] Upgraded ipykernel from v5 to v6 (#17526) [noreply] [BEAM-11105] Add docs + CHANGES.md entry for Go Watermark Estimation [noreply] Merge pull request #17380 from [BEAM-14314][BEAM-9532] Add last_updated ------------------------------------------ [...truncated 79.40 KB...] INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.410Z: JOB_MESSAGE_DETAILED: Fusing consumer ref_AppliedPTransform_Read-synthetic-SDFBoundedSourceReader-ParDo-SDFBoundedSourceDoFn-_6/SplitWithSizing into ref_AppliedPTransform_Read-synthetic-SDFBoundedSourceReader-ParDo-SDFBoundedSourceDoFn-_6/PairWithRestriction INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.445Z: JOB_MESSAGE_DETAILED: Fusing consumer Measure time: Start into ref_AppliedPTransform_Read-synthetic-SDFBoundedSourceReader-ParDo-SDFBoundedSourceDoFn-_6/ProcessElementAndRestrictionWithSizing INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.492Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 0 into Measure time: Start INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.522Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 1 into Step: 0 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.545Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 2 into Step: 1 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.622Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 3 into Step: 2 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.644Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 4 into Step: 3 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.706Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 5 into Step: 4 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.733Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 6 into Step: 5 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.765Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 7 into Step: 6 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.790Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 8 into Step: 7 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.821Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 9 into Step: 8 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.853Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 10 into Step: 9 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.917Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 11 into Step: 10 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.952Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 12 into Step: 11 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.975Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 13 into Step: 12 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:39.996Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 14 into Step: 13 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.019Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 15 into Step: 14 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.042Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 16 into Step: 15 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.067Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 17 into Step: 16 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.101Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 18 into Step: 17 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.132Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 19 into Step: 18 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.166Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 20 into Step: 19 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.202Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 21 into Step: 20 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.236Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 22 into Step: 21 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.267Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 23 into Step: 22 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.300Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 24 into Step: 23 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.333Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 25 into Step: 24 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.366Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 26 into Step: 25 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.400Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 27 into Step: 26 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.424Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 28 into Step: 27 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.457Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 29 into Step: 28 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.477Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 30 into Step: 29 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.509Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 31 into Step: 30 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.545Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 32 into Step: 31 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.577Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 33 into Step: 32 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.599Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 34 into Step: 33 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.633Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 35 into Step: 34 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.668Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 36 into Step: 35 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.719Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 37 into Step: 36 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.751Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 38 into Step: 37 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.772Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 39 into Step: 38 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.796Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 40 into Step: 39 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.818Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 41 into Step: 40 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.855Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 42 into Step: 41 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.916Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 43 into Step: 42 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.938Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 44 into Step: 43 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.963Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 45 into Step: 44 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:40.998Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 46 into Step: 45 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.030Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 47 into Step: 46 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.078Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 48 into Step: 47 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.100Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 49 into Step: 48 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.132Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 50 into Step: 49 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.167Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 51 into Step: 50 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.202Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 52 into Step: 51 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.234Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 53 into Step: 52 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.267Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 54 into Step: 53 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.301Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 55 into Step: 54 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.326Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 56 into Step: 55 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.358Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 57 into Step: 56 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.391Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 58 into Step: 57 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.424Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 59 into Step: 58 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.460Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 60 into Step: 59 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.492Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 61 into Step: 60 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.525Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 62 into Step: 61 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.558Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 63 into Step: 62 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.594Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 64 into Step: 63 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.619Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 65 into Step: 64 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.644Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 66 into Step: 65 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.668Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 67 into Step: 66 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.720Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 68 into Step: 67 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.748Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 69 into Step: 68 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.778Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 70 into Step: 69 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.812Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 71 into Step: 70 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.845Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 72 into Step: 71 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.871Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 73 into Step: 72 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.918Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 74 into Step: 73 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.951Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 75 into Step: 74 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:41.987Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 76 into Step: 75 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.014Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 77 into Step: 76 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.037Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 78 into Step: 77 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.071Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 79 into Step: 78 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.104Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 80 into Step: 79 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.139Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 81 into Step: 80 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.173Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 82 into Step: 81 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.206Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 83 into Step: 82 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.228Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 84 into Step: 83 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.250Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 85 into Step: 84 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.282Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 86 into Step: 85 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.318Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 87 into Step: 86 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.340Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 88 into Step: 87 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.363Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 89 into Step: 88 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.406Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 90 into Step: 89 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.428Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 91 into Step: 90 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.454Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 92 into Step: 91 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.478Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 93 into Step: 92 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.513Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 94 into Step: 93 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.548Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 95 into Step: 94 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.574Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 96 into Step: 95 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.596Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 97 into Step: 96 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.616Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 98 into Step: 97 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.640Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 99 into Step: 98 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.661Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 100 into Step: 99 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.722Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 101 into Step: 100 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.746Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 102 into Step: 101 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.780Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 103 into Step: 102 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.806Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 104 into Step: 103 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.838Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 105 into Step: 104 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.869Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 106 into Step: 105 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.914Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 107 into Step: 106 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.935Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 108 into Step: 107 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.966Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 109 into Step: 108 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:42.993Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 110 into Step: 109 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.029Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 111 into Step: 110 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.053Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 112 into Step: 111 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.074Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 113 into Step: 112 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.096Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 114 into Step: 113 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.129Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 115 into Step: 114 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.161Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 116 into Step: 115 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.205Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 117 into Step: 116 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.238Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 118 into Step: 117 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.260Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 119 into Step: 118 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.295Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 120 into Step: 119 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.327Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 121 into Step: 120 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.359Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 122 into Step: 121 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.406Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 123 into Step: 122 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.429Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 124 into Step: 123 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.461Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 125 into Step: 124 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.493Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 126 into Step: 125 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.525Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 127 into Step: 126 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.546Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 128 into Step: 127 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.578Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 129 into Step: 128 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.610Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 130 into Step: 129 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.633Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 131 into Step: 130 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.665Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 132 into Step: 131 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.724Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 133 into Step: 132 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.752Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 134 into Step: 133 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.786Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 135 into Step: 134 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.825Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 136 into Step: 135 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.862Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 137 into Step: 136 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.907Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 138 into Step: 137 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.933Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 139 into Step: 138 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.965Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 140 into Step: 139 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:43.986Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 141 into Step: 140 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.010Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 142 into Step: 141 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.040Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 143 into Step: 142 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.071Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 144 into Step: 143 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.100Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 145 into Step: 144 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.132Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 146 into Step: 145 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.157Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 147 into Step: 146 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.202Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 148 into Step: 147 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.231Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 149 into Step: 148 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.266Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 150 into Step: 149 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.298Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 151 into Step: 150 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.322Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 152 into Step: 151 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.349Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 153 into Step: 152 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.376Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 154 into Step: 153 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.400Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 155 into Step: 154 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.426Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 156 into Step: 155 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.464Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 157 into Step: 156 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.499Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 158 into Step: 157 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.521Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 159 into Step: 158 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.554Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 160 into Step: 159 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.592Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 161 into Step: 160 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.622Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 162 into Step: 161 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.656Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 163 into Step: 162 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.708Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 164 into Step: 163 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.732Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 165 into Step: 164 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.758Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 166 into Step: 165 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.795Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 167 into Step: 166 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.823Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 168 into Step: 167 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.855Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 169 into Step: 168 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.924Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 170 into Step: 169 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.957Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 171 into Step: 170 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:44.991Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 172 into Step: 171 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.015Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 173 into Step: 172 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.040Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 174 into Step: 173 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.075Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 175 into Step: 174 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.108Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 176 into Step: 175 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.140Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 177 into Step: 176 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.198Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 178 into Step: 177 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.235Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 179 into Step: 178 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.272Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 180 into Step: 179 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.303Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 181 into Step: 180 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.331Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 182 into Step: 181 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.358Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 183 into Step: 182 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.385Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 184 into Step: 183 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.417Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 185 into Step: 184 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.446Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 186 into Step: 185 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.472Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 187 into Step: 186 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.497Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 188 into Step: 187 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.519Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 189 into Step: 188 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.554Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 190 into Step: 189 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.577Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 191 into Step: 190 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.611Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 192 into Step: 191 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.643Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 193 into Step: 192 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.708Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 194 into Step: 193 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.735Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 195 into Step: 194 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.755Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 196 into Step: 195 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.779Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 197 into Step: 196 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.811Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 198 into Step: 197 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.832Z: JOB_MESSAGE_DETAILED: Fusing consumer Step: 199 into Step: 198 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.854Z: JOB_MESSAGE_DETAILED: Fusing consumer Measure time: End into Step: 199 INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:45.998Z: JOB_MESSAGE_BASIC: Running job using Streaming Engine INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:46.039Z: JOB_MESSAGE_DEBUG: Workflow config is missing a default resource spec. INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:46.068Z: JOB_MESSAGE_DEBUG: Adding StepResource setup and teardown to workflow graph. INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:46.102Z: JOB_MESSAGE_DEBUG: Adding workflow start and stop steps. INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:46.124Z: JOB_MESSAGE_DEBUG: Assigning stage ids. INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:46.176Z: JOB_MESSAGE_DEBUG: Starting **** pool setup. INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:46.211Z: JOB_MESSAGE_DEBUG: Starting **** pool setup. INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:15:46.246Z: JOB_MESSAGE_BASIC: Starting 5 ****s in us-central1-b... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2022-05-03_06_15_29-8406346651115031513 is in state JOB_STATE_RUNNING INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:16:08.679Z: JOB_MESSAGE_DETAILED: Autoscaling: Raised the number of ****s to 5 so that the pipeline can catch up with its backlog and keep up with its input rate. INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:16:25.309Z: JOB_MESSAGE_BASIC: Your project already contains 100 Dataflow-created metric descriptors, so new user metrics of the form custom.googleapis.com/* will not be created. However, all user metrics are also available in the metric dataflow.googleapis.com/job/user_counter. If you rely on the custom metrics, you can 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:2022-05-03T13:16:42.182Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-03T13:24:42.951Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1 FATAL: command execution failed java.io.IOException: Backing channel 'apache-beam-jenkins-14' is disconnected. at hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:216) at hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:286) at com.sun.proxy.$Proxy132.isAlive(Unknown Source) at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1213) at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1205) at hudson.Launcher$ProcStarter.join(Launcher.java:522) at hudson.plugins.gradle.Gradle.perform(Gradle.java:317) at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20) at hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:806) at hudson.model.Build$BuildExecution.build(Build.java:198) at hudson.model.Build$BuildExecution.doRun(Build.java:163) at hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:514) at hudson.model.Run.execute(Run.java:1888) at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43) at hudson.model.ResourceController.execute(ResourceController.java:99) at hudson.model.Executor.run(Executor.java:432) Caused by: hudson.remoting.Channel$OrderlyShutdown: Command Close created at at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1320) at hudson.remoting.Channel$1.handle(Channel.java:607) at hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:81) Caused by: Command Close created at at hudson.remoting.Command.<init>(Command.java:70) at hudson.remoting.Channel$CloseCommand.<init>(Channel.java:1313) at hudson.remoting.Channel$CloseCommand.<init>(Channel.java:1311) at hudson.remoting.Channel.close(Channel.java:1487) at hudson.remoting.Channel.close(Channel.java:1454) at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1319) ... 2 more Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure ERROR: apache-beam-jenkins-14 is offline; cannot locate jdk_1.8_latest --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
