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

Changes:

[Heejong Lee] [BEAM-14471] Adding testcases and examples for xlang Python

[Heejong Lee] update

[Heejong Lee] add DataframeTransform wrapper

[noreply] Fix -- linting issue (#17738)

[noreply] Fix 'NoneType' object has no attribute error

[noreply] [BEAM-12308] change expected value in kakfa IT (#17740)

[noreply] [BEAM-14053] [CdapIO] Add wrapper class for CDAP plugin (#17150)

[noreply] [BEAM-14129] Clean up PubsubLiteIO by removing options that no longer

[noreply] [BEAM-14496] Ensure that precombine is inheriting one of the 
timestamps

[noreply] [BEAM-14139] Remove unused Flink 1.11 directory (#17750)

[noreply] [BEAM-14044] Allow ModelLoader to forward BatchElements args (#17527)


------------------------------------------
[...truncated 244.61 KB...]
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:16:57.714Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:17:25.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-25T22:18:03.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-25T22:18:38.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-25T22:19:06.237Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:19:34.381Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:20:09.558Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:20:38.770Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:21:05.934Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:21:36.052Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:22:08.183Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:22:37.324Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:23:05.523Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:23:39.668Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:24:11.847Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:24:43.952Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:25:16.094Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:25:49.237Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:26:17.384Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:26:49.499Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:27:17.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-25T22:27:46.726Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:28:14.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-25T22:28:48.978Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:29:16.142Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:29:46.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-25T22:30:20.406Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:30:48.517Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:31:17.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-25T22:31:46.745Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:32:24.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-25T22:32:58.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-25T22:33:25.162Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:33:58.314Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:34:24.413Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:34:56.538Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:35:29.678Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:35:58.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-25T22:36:25.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-25T22:36:59.982Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:37:29.095Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:37:58.221Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:38:29.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-25T22:38:56.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-25T22:39:29.625Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:39:58.745Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:40:35.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-25T22:41:08.013Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:41:37.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-25T22:42:05.272Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:42:39.392Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:43:07.545Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:43:36.657Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:44:03.776Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:44:35.917Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:45:10.078Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:45:37.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-25T22:46:09.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-25T22:46: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-25T22:47:13.608Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:47:46.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-25T22:48:14.861Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:48:46.982Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:49:14.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-25T22:49:47.202Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:50:15.302Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:50:49.468Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:51:16.563Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:51:44.659Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:52:17.775Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:52:44.867Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:53:17.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-25T22:53:51.108Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:54:25.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-25T22:54:57.327Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:55:28.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-25T22:55:56.538Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:56:25.654Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:56:57.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-25T22:57:26.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-25T22:57:55.069Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:58:27.178Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T22:58:58.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-25T22:59:35.442Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:00:03.570Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:00:36.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-25T23:01:04.856Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:01:37.964Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:02:05.081Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:02:37.219Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:03:06.336Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:03:38.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-25T23:04:05.641Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:04:37.766Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:05:06.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-25T23:05:40.006Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:06:07.117Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:06:43.247Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:07:15.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-25T23:07:44.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-25T23:08:16.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-25T23:08:48.766Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:09:15.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-25T23:09:48.997Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:10:18.115Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:10:46.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-25T23:11:18.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-25T23:11:47.435Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:12:25.580Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:12:57.700Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:13:23.787Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:13:56.901Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:14:25Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:14:58.120Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:15:25.217Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:15:58.331Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:16:30.434Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:16:57.542Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:17:37.730Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:18:03.834Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:18:36.957Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:19:06.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-25T23:19: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-25T23:20:06.356Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:20:39.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-25T23:21:08.608Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:21:35.700Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:22:07.842Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:22:36.946Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:23:15.189Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:23:48.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-25T23:24:16.435Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:24:44.531Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:25:18.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-25T23:25:47.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-25T23:26:17.991Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:26:45.122Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:27:17.710Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:27:44.882Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:28:16.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-25T23:28:49.238Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:29:18.428Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:29:45.519Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:30:19.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-25T23:30:57.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-25T23:31:24.897Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:31:59.043Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:32:25.157Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:32:59.278Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:33:26.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-25T23:33:54.463Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:34:26.567Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:34:58.669Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:35:24.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-25T23:35:57.885Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:36:25.969Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:36:59.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-25T23:37:26.203Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:37:58.341Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:38:26.435Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:38:59.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-25T23:39:33.643Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:40:08.749Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:40:36.866Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:41:05.951Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:41:34.085Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:42:06.193Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:42:39.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-25T23:43:06.413Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:43:38.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-25T23:44:05.595Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:44:39.699Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:45:05.817Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:45:36.947Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:46:06.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-25T23:46:39.164Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:47:07.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-25T23:47:48.429Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:48:16.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-25T23:48:45.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-25T23:49:19.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-25T23:49:47.885Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:50:15.986Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:50:46.165Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:51:18.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-25T23:51:45.370Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:52:20.476Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:52:50.578Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:53:17.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-25T23:53:52.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-25T23:54:24.941Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:54:58.073Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:55:25.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-25T23:55:55.298Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:56:27.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-25T23:56:58.541Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:57:27.654Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:57:54.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-25T23:58:26.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-25T23:58:54.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-25T23:59:29.116Z: 
JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot 
decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-25T23:59:58.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-26T00:00:25.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:Job 
2022-05-25_10_51_21-3455011832847235589 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-25_10_51_21-3455011832847235589?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 6h 10m 31s
15 actionable tasks: 3 executed, 12 up-to-date

Publishing build scan...
https://gradle.com/s/6efn45lvqnvvy

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