See 
<https://ci-beam.apache.org/job/beam_LoadTests_Python_CoGBK_Dataflow_Streaming/620/display/redirect?page=changes>

Changes:

[johnjcasey] [BEAM-14448] add datastore test

[yathu] [BEAM-14423] Add test cases for BigtableIO.BigtableWriterFn fails due to

[Pablo Estrada] Revert "Merge pull request #17517 from [BEAM-14383] Improve 
"FailedRows"

[noreply] [BEAM-14229] Fix SyntheticUnboundedSource duplication from checkpoint

[noreply] [BEAM-14347] Rename registration package to register (#17603)

[noreply] [BEAM-11104] Add self-checkpointing integration test (#17590)

[noreply] [BEAM-5492] Python Dataflow integration tests should export the 
pipeline

[noreply] [BEAM-14396] Bump httplib2 upper bound. (#17602)

[noreply] [BEAM-11104] Add self-checkpointing to CHANGES.md (#17612)

[noreply] [BEAM-14081] [CdapIO] Add context classes for CDAP plugins (#17104)


------------------------------------------
[...truncated 82.10 KB...]
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:16:14.321Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:16:44.466Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:17:16.603Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:17:44.739Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:18:16.881Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:18:47.987Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:19:18.110Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:19:46.216Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:20:17.389Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:20:47.479Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:21:15.588Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:21:44.695Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:22:17.868Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:22:48.992Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:23:17.099Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:23:46.222Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:24:19.337Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:24:51.454Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:25:26.607Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:25:59.778Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:26:33.925Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:27:02.055Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:27:35.209Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:28:02.310Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:28:35.427Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:29:02.576Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:29:35.695Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:30:03.862Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:30:34.977Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:31:08.109Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:31:35.252Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:32:07.349Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:32:36.440Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:33:08.530Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:33:34.624Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:34:07.771Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:34:35.916Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:35:09.047Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:35:36.163Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:36:09.361Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:36:47.491Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:37:14.593Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:37:44.694Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:38:16.844Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:38:44.954Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:39:17.062Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:39:44.160Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:40:38.511Z: 
JOB_MESSAGE_BASIC: Worker configuration: n1-highmem-4 in us-central1-b.
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:40:55.183Z: 
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-11T18:43:27.625Z: 
JOB_MESSAGE_BASIC: Worker configuration: n1-highmem-4 in us-central1-b.
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:43:48.657Z: 
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-11T18:43:49.087Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:44:19.281Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:44:49.458Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:45:19.664Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:45:47.989Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:46:24.182Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:46:58.560Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:47:26.695Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:47:53.820Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:48:26.060Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:48:57.293Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:49:25.412Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:49:58.011Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:50:24.264Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:50:59.505Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:51:26.750Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:51:54.925Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:52:26.104Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:52:57.573Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:53:25.796Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:53:58.945Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:54:26.102Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:54:58.367Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:55:25.474Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:55:57.615Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:56:25.891Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:57:01.030Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:57:29.422Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:57:55.592Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:58:27.825Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:58:57.026Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T18:59:34.277Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:00:02.618Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:00:34.914Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:01:02.086Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:01:35.329Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:02:05.644Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:02:33.959Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:03:07.215Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:03:33.431Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:04:05.721Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:04:37.896Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:05:05.098Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:05:37.300Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:06:04.628Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:06:36.927Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:07:11.106Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:07:38.261Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:08:05.460Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:08:35.695Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:09:09.869Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:09:37.074Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:10:09.282Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:10:46.493Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:11:16.879Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:11:42.062Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:12:14.303Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:12:45.592Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:13:18.068Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:13:46.218Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:14:13.390Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:14:44.598Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:15:17.874Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:15:47.200Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:16:15.498Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:16:46.833Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:17:14.024Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:17:46.168Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:18:17.404Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:18:45.762Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:19:19.989Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:19:48.358Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:20:16.683Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:20:49.883Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:21:17.107Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:21:45.281Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:22:17.536Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:22:48.715Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:23:28.236Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:23:55.396Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:24:24.616Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:24:59.062Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:25:27.270Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:25:56.509Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:26:23.665Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:26:56.954Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:27:24.139Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:27:56.330Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:28:25.535Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:28:54.761Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:29:27.091Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:30:00.502Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:30:28.704Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:30:56.896Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:31:36.100Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:32:02.290Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:32:35.606Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:33:04.086Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:33:36.211Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:34:02.376Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:34:36.597Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:35:02.814Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:35:38.175Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:36:04.467Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:36:37.717Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:37:05.960Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:37:38.319Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:38:05.568Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:38:42.785Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:39:14.022Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:39:47.359Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:40:16.511Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:40:42.638Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:41:14.812Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:41:47.093Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:42:15.214Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:42:46.507Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:43:18.763Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:43:44.961Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:44:18.166Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:44:46.374Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:45:19.650Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:45:47.865Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:46:19.067Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:46:45.374Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:47:15.522Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:47:47.849Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:48:16.002Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:48:49.220Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:49:28.548Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:49:55.647Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:50:28.797Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:50:55.955Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:51:28.214Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:51:56.329Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:52:27.525Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:52:55.827Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:53:28.075Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:53:56.319Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:54:29.512Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:55:02.675Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:55:34.815Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:56:06.305Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:56:36.510Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:57:04.626Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:57:37.798Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:58:04.111Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:58:36.535Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:59:04.697Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T19:59:37.065Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T20:00:08.312Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-11T20:00:37.459Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:Job 
2022-05-11_09_40_45-10380058571437625942 is in state JOB_STATE_CANCELLING
Traceback (most recent call last):
  File "/usr/lib/python3.7/runpy.py", line 193, in _run_module_as_main
    "__main__", mod_spec)
  File "/usr/lib/python3.7/runpy.py", line 85, in _run_code
    exec(code, run_globals)
  File 
"<https://ci-beam.apache.org/job/beam_LoadTests_Python_CoGBK_Dataflow_Streaming/ws/src/sdks/python/apache_beam/testing/load_tests/co_group_by_key_test.py";,>
 line 144, in <module>
    CoGroupByKeyTest().run()
  File 
"<https://ci-beam.apache.org/job/beam_LoadTests_Python_CoGBK_Dataflow_Streaming/ws/src/sdks/python/apache_beam/testing/load_tests/load_test.py";,>
 line 151, in run
    self.result.wait_until_finish(duration=self.timeout_ms)
  File 
"<https://ci-beam.apache.org/job/beam_LoadTests_Python_CoGBK_Dataflow_Streaming/ws/src/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py";,>
 line 1664, in wait_until_finish
    '{}'.format(consoleUrl))
AssertionError: Job did not reach to a terminal state after waiting 
indefinitely. Console URL: 
https://console.cloud.google.com/dataflow/jobs/<RegionId>/2022-05-11_09_40_45-10380058571437625942?project=<ProjectId>

> Task :sdks:python:apache_beam:testing:load_tests:run FAILED

FAILURE: Build failed with an exception.

* Where:
Build file 
'<https://ci-beam.apache.org/job/beam_LoadTests_Python_CoGBK_Dataflow_Streaming/ws/src/sdks/python/apache_beam/testing/load_tests/build.gradle'>
 line: 58

* What went wrong:
Execution failed for task ':sdks:python:apache_beam:testing:load_tests:run'.
> error occurred

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 8.0.

You can use '--warning-mode all' to show the individual deprecation warnings 
and determine if they come from your own scripts or plugins.

See 
https://docs.gradle.org/7.4/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 3h 22m 1s
15 actionable tasks: 9 executed, 4 from cache, 2 up-to-date

Publishing build scan...
https://gradle.com/s/o6z5pgfyfryhc

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure


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

Reply via email to