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

Changes:

[Robert Bradshaw] [BEAM-14426] Allow skipping of any output when writing an 
empty

[Robert Bradshaw] Add skip_if_empty attribute to base class to fix test.

[Jan Lukavský] [BEAM-14492] add flinkConfDir to FlinkPipelineOptions

[noreply] Bump cloud.google.com/go/storage from 1.22.0 to 1.22.1 in /sdks

[noreply] [BEAM-14481] Remove unnecessary context (#17737)

[noreply] [BEAM-9324] Fix incompatibility of direct runner with cython (#17728)

[noreply] [BEAM-14503] Add support for Flink 1.15 (#17739)

[noreply] Update Beam website to release 2.39.0 (#17690)

[noreply] [BEAM-14509] Add several flags to dataflow runner (#17752)

[Yichi Zhang] Fix 2.38.0 download page.

[noreply] [BEAM-14494] Fix publish_docker_images.sh (#17756)

[noreply] [BEAM-14336] Re-enable `flight_delays_it_test` with


------------------------------------------
[...truncated 83.14 KB...]
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-26T18:16:38.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-26T18:17:07.274Z: 
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-26T18:17:41.492Z: 
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-26T18:18:08.791Z: 
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-26T18:18:41.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-26T18:19:10.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-26T18:19:39.204Z: 
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-26T18:20:08.345Z: 
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-26T18:20:38.681Z: 
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-26T18:21:08.884Z: 
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-26T18:21:39.039Z: 
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-26T18:22:18.299Z: 
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-26T18:22:50.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-26T18:23:17.734Z: 
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-26T18:23:46.871Z: 
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-26T18:24:20.995Z: 
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-26T18:24:47.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-26T18:25:20.235Z: 
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-26T18:25:47.520Z: 
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-26T18:26:20.689Z: 
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-26T18:26:47.913Z: 
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-26T18:27:27.080Z: 
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-26T18:27:59.199Z: 
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-26T18:28:31.557Z: 
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-26T18:28:58.651Z: 
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-26T18:29:30.746Z: 
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-26T18:29:57.887Z: 
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-26T18:30:29.018Z: 
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-26T18:30:57.248Z: 
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-26T18:31:31.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-26T18:31:59.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-26T18:32:27.630Z: 
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-26T18:33:01.863Z: 
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-26T18:33:30.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-26T18:33:57.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-26T18:34:29.661Z: 
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-26T18:35:01.832Z: 
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-26T18:35:36.980Z: 
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-26T18:36:09.088Z: 
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-26T18:36:38.306Z: 
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-26T18:37:11.648Z: 
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-26T18:37:40.808Z: 
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-26T18:38:07.935Z: 
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-26T18:38:41.274Z: 
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-26T18:39:09.415Z: 
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-26T18:39:42.830Z: 
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-26T18:40:10.928Z: 
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-26T18:40:37.291Z: 
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-26T18:41:11.462Z: 
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-26T18:41:38.546Z: 
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-26T18:42:09.773Z: 
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-26T18:42:46.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-26T18:43:21.101Z: 
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-26T18:43:49.246Z: 
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-26T18:44:20.481Z: 
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-26T18:44:49.905Z: 
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-26T18:45:17.009Z: 
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-26T18:45:50.125Z: 
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-26T18:46:21.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-26T18:46:49.553Z: 
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-26T18:47:21.684Z: 
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-26T18:47:48.843Z: 
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-26T18:48:20.944Z: 
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-26T18:48:48.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-26T18:49:18.255Z: 
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-26T18:50:00.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-26T18:50:29.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-26T18:50:57.871Z: 
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-26T18:51:27.974Z: 
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-26T18:52:00.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-26T18:52:27.213Z: 
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-26T18:53:02.478Z: 
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-26T18:53:29.755Z: 
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-26T18:54:01.870Z: 
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-26T18:54:28.999Z: 
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-26T18:55:01.124Z: 
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-26T18:55:29.306Z: 
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-26T18:56:02.587Z: 
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-26T18:56:41.781Z: 
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-26T18:57:10.137Z: 
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-26T18:57:37.228Z: 
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-26T18:58:10.446Z: 
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-26T18:58:39.561Z: 
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-26T18:59:11.846Z: 
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-26T18:59:39Z: 
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-26T19:00:11.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-26T19:00:40.371Z: 
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-26T19:01:08.506Z: 
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-26T19:01:42.676Z: 
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-26T19:02:20.929Z: 
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-26T19:02:47.032Z: 
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-26T19:03:20.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-26T19:03:50.320Z: 
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-26T19:04:31.487Z: 
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-26T19:05:01.648Z: 
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-26T19:05:28.780Z: 
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-26T19:05:59.007Z: 
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-26T19:06:28.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-26T19:07:00.629Z: 
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-26T19:07:32.765Z: 
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-26T19:07:58.936Z: 
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-26T19:08:29.156Z: 
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-26T19:09:01.276Z: 
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-26T19:09:29.372Z: 
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-26T19:10:10.559Z: 
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-26T19:10:39.693Z: 
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-26T19:11:07.805Z: 
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-26T19:11:40.980Z: 
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-26T19:12:08.146Z: 
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-26T19:12:40.241Z: 
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-26T19:13:08.375Z: 
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-26T19:13:41.487Z: 
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-26T19:14:09.634Z: 
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-26T19:14:40.777Z: 
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-26T19:15:08.973Z: 
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-26T19:15:46.208Z: 
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-26T19:16:19.357Z: 
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-26T19:16:47.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-26T19:17:18.571Z: 
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-26T19:17:51.801Z: 
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-26T19:18:21.079Z: 
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-26T19:18:48.274Z: 
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-26T19:19:21.414Z: 
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-26T19:19:49.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-26T19:20:22.008Z: 
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-26T19:20:50.342Z: 
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-26T19:21:23.574Z: 
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-26T19:21:51.949Z: 
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-26T19:22:20.176Z: 
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-26T19:22:53.301Z: 
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-26T19:23:31.482Z: 
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-26T19:23:59.837Z: 
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-26T19:24:31.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-26T19:24:59.083Z: 
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-26T19:25:31.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-26T19:25:57.317Z: 
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-26T19:26:31.482Z: 
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-26T19:26:58.679Z: 
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-26T19:27:30.821Z: 
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-26T19:27:57.936Z: 
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-26T19:28:36.171Z: 
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-26T19:29:08.416Z: 
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-26T19:29:36.513Z: 
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-26T19:30:09.622Z: 
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-26T19:30:38.733Z: 
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-26T19:31:10.920Z: 
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-26T19:31:43.048Z: 
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-26T19:32:10.213Z: 
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-26T19:32:39.758Z: 
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-26T19:33:10.884Z: 
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-26T19:33:42.039Z: 
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-26T19:34:20.179Z: 
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-26T19:34:47.447Z: 
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-26T19:35:20.557Z: 
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-26T19:35:47.662Z: 
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-26T19:36:15.754Z: 
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-26T19:36:49.887Z: 
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-26T19:37:16.071Z: 
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-26T19:37:48.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-26T19:38:21.596Z: 
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-26T19:38:48.696Z: 
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-26T19:39:17.792Z: 
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-26T19:39:51.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-26T19:40:22.251Z: 
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-26T19:40:59.378Z: 
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-26T19:41:26.503Z: 
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-26T19:41:57.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-26T19:42:28.698Z: 
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-26T19:42:59.829Z: 
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-26T19:43:28.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-26T19:44:01.072Z: 
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-26T19:44:29.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-26T19:45:02.323Z: 
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-26T19:45:28.441Z: 
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-26T19:45:59.681Z: 
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-26T19:46:31.944Z: 
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-26T19:47:01.057Z: 
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-26T19:47:32.326Z: 
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-26T19:48:08.564Z: 
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-26T19:48:36.696Z: 
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-26T19:49:10.826Z: 
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-26T19:49:37.923Z: 
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-26T19:50:11.105Z: 
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-26T19:50:38.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-26T19:51:08.437Z: 
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-26T19:51:37.527Z: 
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-26T19:52:07.636Z: 
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-26T19:52:42.746Z: 
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-26T19:53:10.971Z: 
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-26T19:53:38.131Z: 
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-26T19:54:11.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-26T19:54:50.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-26T19:55:17.504Z: 
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-26T19:55:50.612Z: 
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-26T19:56:18.734Z: 
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-26T19:56:46.924Z: 
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-26T19:57:20.173Z: 
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-26T19:57:49.265Z: 
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-26T19:58:18.415Z: 
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-26T19:58:49.521Z: 
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-26T19:59:17.696Z: 
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-26T19:59:51.806Z: 
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-26T20:00:18.898Z: 
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-26_09_39_36-17069146587298428018 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-26_09_39_36-17069146587298428018?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 22s
15 actionable tasks: 9 executed, 4 from cache, 2 up-to-date

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

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