You are viewing a plain text version of this content. The canonical link for it is here.

Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2022/05/06 20:00:48 UTC

Build failed in Jenkins: beam_LoadTests_Python_CoGBK_Dataflow_Streaming #615

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

Changes:

[kevinsijo] Setting up a basic directory

[kevinsijo] Mirroring Python SDK's directory structure

[kerrydc] Adds initial tests

[kevinsijo] 'runners' is the correct directory name

[Pablo Estrada] sketching the core API for JS SDK

[jonathanlui] add .gitignore for node/ts project

[Robert Bradshaw] Worker directory.

[Robert Bradshaw] Fix complile errors with explicit any for callables.

[Robert Bradshaw] Add worker entry point.

[Robert Bradshaw] Add proto generation code.

[Robert Bradshaw] Add generated proto files.

[Robert Bradshaw] Attempts to get ts protos to compile.

[Robert Bradshaw] Exclude ts protos for now.

[Robert Bradshaw] More changes to get ts protos working.

[Robert Bradshaw] Update scripts and config to get protos compiling.

[Robert Bradshaw] Update geenrated files.

[jonathanlui] add build and clean script to compile ts

[Robert Bradshaw] Generate server for loopback worker.

[Robert Bradshaw] Generated grpc servers for loopback.

[Robert Bradshaw] Add typescript formatter.

[Robert Bradshaw] Loopback server (that does nothing).

[Robert Bradshaw] Working server.

[Pablo Estrada] Starting expansion of primitive transforms

[Pablo Estrada] Starting to implement and support standard coders

[Robert Bradshaw] Also generate grpc clients.

[Robert Bradshaw] Basic implementation of worker harness.

[Pablo Estrada] fix the build

[Robert Bradshaw] Add some missing files for worker harness.

[Robert Bradshaw] Refactor operators to use registration.

[jonathanlui] enable ts in mocha

[jonathanlui] update readme

[jonathanlui] --save-dev @types/mocha

[jonathanlui] translate core_test.js to typescript

[Robert Bradshaw] Encapsulate worker service in a class.

[Kenneth Knowles] Port standard_coders_test to typescript (superficially)

[Pablo Estrada] Starting the proto translation of Impulse, ParDo, GBK

[Robert Bradshaw] Add some tests for the worker code.

[Robert Bradshaw] Fixing old lock file error.

[Pablo Estrada] Adding transform names and fixing GBK coder issue

[Robert Bradshaw] npx tsfmt -r src/apache_beam/base.ts src/apache_beam/transforms/core.ts

[Kenneth Knowles] switch to import style require() statements

[Kenneth Knowles] Add Coder interface using protobufjs classes

[Kenneth Knowles] BytesCoder with some failures

[noreply] Added GeneralObjectCoder and using it as coder for most transforms (#9)

[Kenneth Knowles] Fix order of arguments to deepEqual

[Kenneth Knowles] Encode expected encoding as binary

[Robert Bradshaw] Refactor API to allow for composites.

[jrmccluskey] Initial setup for automated Java expansion startup

[jrmccluskey] Update exp_service.ts

[Kenneth Knowles] Fix up coder deserialization

[Robert Bradshaw] Simplify GBK coder computation.

[Robert Bradshaw] Remove top-level PValue.

[Pablo Estrada] Make tests green

[Robert Bradshaw] Rename PValueish to PValue.

[jonathanlui] node runner

[jonathanlui] whitespaces

[Robert Bradshaw] Make Runner.run async.

[jonathanlui] bson and fast-deep-equal should not be listed as devdependency

[jrmccluskey] Add basic Dockerfile that starts ExternalWorkerPool

[Robert Bradshaw] Direct runner.

[kevinsijo] Testing expansion service communication

[Robert Bradshaw] Added flatten, assertion checkers.

[Pablo Estrada] progress on basic coders

[Robert Bradshaw] Fixing the build.

[Robert Bradshaw] Cleanup, simplify access.

[Pablo Estrada] Adding limited support for KVCoder and IterableCoder

[Robert Bradshaw] Introduce PipelineContext.

[Robert Bradshaw] Add toProto to all coders.

[Robert Bradshaw] Some work with coders.

[Robert Bradshaw] Remove debug logging.

[Robert Bradshaw] Use coders over data channel.

[Kenneth Knowles] explicitly sequence sub-coder serializations

[Kenneth Knowles] no more need to extend FakeCoder

[Kenneth Knowles] actually advance reader

[Kenneth Knowles] autoformat

[Kenneth Knowles] protobufjs already can write and read signed varints

[Kenneth Knowles] with improved test harness, kv has many more failures

[Kenneth Knowles] read bytescoder from correct position

[Kenneth Knowles] no more fake coders

[Kenneth Knowles] varint examples all work

[Kenneth Knowles] simplify coder value parsing

[Kenneth Knowles] global window coder

[Kenneth Knowles] fix swapEndian32

[Robert Bradshaw] Add P(...) operator.

[kevinsijo] Implementing RowCoder encoding.

[jrmccluskey] remove unused container dir

[kevinsijo] Corrected sorting of encoded positions to reflect an argsort instead.

[Robert Bradshaw] Populate environments.

[kevinsijo] Implementing RowCoder decoding.

[Kenneth Knowles] preliminary unbounded iterable coder

[Kenneth Knowles] friendlier description of standard coder test case

[Kenneth Knowles] fix test harness; iterable works

[jrmccluskey] first pass at boot.go

[jonathanlui] update package-lock.json

[jonathanlui] make NodeRunner a subclass of Runner

[jonathanlui] add waitUntilFinish interface member

[Pablo Estrada] Adding double coder

[Kenneth Knowles] scaffolding for windowed values

[Pablo Estrada] Adding type information to PColleciton and PTransform

[jonathanlui] fix direct runner

[Pablo Estrada] Adding typing information for DoFns

[Kenneth Knowles] add interval window

[Robert Bradshaw] Export PValue.

[Robert Bradshaw] Add CombineFn interface.

[Robert Bradshaw] Typed flatten.

[jonathanlui] add runAsync method to base.Runner

[Kenneth Knowles] add Long package

[Pablo Estrada] Adding more types. Making PValue typed

[Kenneth Knowles] instant coder draft

[Robert Bradshaw] Return job state from direct runner.

[Kenneth Knowles] type instant = long

[jonathanlui] implement NodeRunner.runPipeline

[Kenneth Knowles] autoformat

[kevinsijo] Completed implementation of basic row coder

[Kenneth Knowles] Fix IntervalWindowCoder, almost

[Kenneth Knowles] fix interval window coder

[Kenneth Knowles] autoformat

[Robert Bradshaw] loopback runner works

[Kenneth Knowles] move core element types into values.ts

[Kenneth Knowles] just build object directly to be cool

[Robert Bradshaw] GBK working on ULR.

[Robert Bradshaw] Async transforms.

[Robert Bradshaw] External transform grpah splicing.

[Kenneth Knowles] progress on windowed value: paneinfo encoding

[Robert Bradshaw] Fix merge.

[Robert Bradshaw] autoformat

[Kenneth Knowles] full windowed value coder

[kerrydc] Updates tests to use correct types, adds generics where needed to DoFns

[Robert Bradshaw] Add serialization librarires.'

[Robert Bradshaw] Add Split() PTransform, for producing multiple outputs from a single

[Robert Bradshaw] Schema-encoded external payloads.

[kevinsijo] Adding Schema inference from JSON

[Pablo Estrada] Removing unused directories

[Pablo Estrada] Support for finishBundle and improving typing annotations.

[Pablo Estrada] A base implementation of combiners with GBK/ParDo

[Robert Bradshaw] Fully propagate windowing information in both remote and direct runner.

[Robert Bradshaw] Make args and kwargs optional for python external transform.

[Robert Bradshaw] Infer schema for external transforms.

[Pablo Estrada] Implementing a custom combine fn as an example. Small fixes

[Robert Bradshaw] Fix missing windowing information in combiners.

[Robert Bradshaw] PostShuffle needn't group by key as that's already done.

[Robert Bradshaw] Guard pre-combine for global window only.

[Robert Bradshaw] WindowInto

[Robert Bradshaw] Fix optional kwargs.

[Robert Bradshaw] A couple of tweaks for js + py

[Robert Bradshaw] Add windowing file.

[Robert Bradshaw] CombineBy transform, stand-alone WordCount.

[Robert Bradshaw] cleanup

[Robert Bradshaw] Actually fix optional external kwargs.

[Robert Bradshaw] Demo2, textio read.

[Robert Bradshaw] Add command lines for starting up the servers.

[Robert Bradshaw] Run prettier on the full codebase.

[Robert Bradshaw] Update deps.

[Pablo Estrada] Adding docstrings for core.ts. Prettier dependency

[Pablo Estrada] Documenting coder interfaces

[Pablo Estrada] Added documentation for a few standard coders

[Robert Bradshaw] Unified grouping and combining.

[Robert Bradshaw] Allow PCollection ids to be lazy.

[Robert Bradshaw] Reorganize module structure.

[Robert Bradshaw] A couple more renames.

[Robert Bradshaw] Simplify.

[Robert Bradshaw] Consolidation.

[Robert Bradshaw] Fix build.

[Robert Bradshaw] Add optional context to ParDo.

[Robert Bradshaw] fixup: iterable coder endian sign issue

[Robert Bradshaw] omit context for map(console.log)

[Robert Bradshaw] Fix ReadFromText coders.

[Robert Bradshaw] Flesh out README with overview and current state.

[noreply] Readme typo

[Robert Bradshaw] Two more TODOs.

[noreply] Add a pointer to the example wordcount to the readme.

[Pablo Estrada] Documenting coders and implementing unknown-length method

[Robert Bradshaw] UIID dependency.

[Robert Bradshaw] Artifact handling.

[Robert Bradshaw] Properly wait on data channel for bundle completion.

[Robert Bradshaw] Automatic java expansion service startup.

[Robert Bradshaw] Process promises.

[Robert Bradshaw] Implement side inputs.

[Robert Bradshaw] Cleanup.

[Robert Bradshaw] Put complex constext stuff in its own file.

[Robert Bradshaw] Rename BoundedWindow to just Window.

[Robert Bradshaw] Alternative splitter class.

[Pablo Estrada] Documenting internal functions

[Robert Bradshaw] Take a pass clarifying the TODOs.

[Robert Bradshaw] Sql transform wrapper.

[Robert Bradshaw] Incorporate some feedback into the TODOs.

[Robert Bradshaw] More TODOs.

[Robert Bradshaw] Remove app placeholder.

[Robert Bradshaw] Apache license headers.

[Robert Bradshaw] More TODOs

[jankuehle] Suggestions for TypeScript todos

[dannymccormick] Add actions for typescript sdk

[dannymccormick] Fix test command

[noreply] Add missing version

[dannymccormick] Fix codecovTest command

[noreply] Only do prettier check on linux

[noreply] Only get codecov on linux

[Robert Bradshaw] Resolve some comments.

[Robert Bradshaw] Fix compile errors.

[Robert Bradshaw] Prettier.

[Robert Bradshaw] Re-order expandInternal arguments pending unification.

[Robert Bradshaw] More consistent and stricter PTransform naming.

[Robert Bradshaw] Notes on explicit, if less idiomatic, use of classes.

[Robert Bradshaw] Let DoFn be an interface rather than a class.

[Robert Bradshaw] Provide DoFn context to start and finish bundle.

[Robert Bradshaw] Optional promise code simplification.

[Robert Bradshaw] Cleanup todos.

[Robert Bradshaw] Avoid any type where not needed.

[Robert Bradshaw] Apache RAT excludes for typescript.

[Robert Bradshaw] Remove empty READMEs.

[Robert Bradshaw] Add licences statement to readme files.

[Robert Bradshaw] More RAT fixes.

[Robert Bradshaw] Another unsupported coder.

[Robert Bradshaw] Remove debugging code.

[noreply] Fix automatic naming with code coverage.

[Robert Bradshaw] Coders cleanup.

[Robert Bradshaw] Add tests for RowCoder.

[Robert Bradshaw] Normalize capitalization, comments.

[Robert Bradshaw] Install typescript closure packages.

[Robert Bradshaw] npm audit fix

[Robert Bradshaw] Move more imports out of base.

[Robert Bradshaw] Changes needed to compile with ts closure plugin.

[Robert Bradshaw] Use ttsc and ts-closure-transform plugin.

[Robert Bradshaw] Serialization registration to actually get serialization working.

[Robert Bradshaw] Container images working on local runner.

[Robert Bradshaw] Add a portable job server that proxies the Dataflow backend. (#17189)

[Robert Bradshaw] Improvements to dataflow job service for non-Python jobs.

[Robert Bradshaw] Get dataflow working.

[Robert Bradshaw] User friendly pipeline options.

[Robert Bradshaw] Less classes, more functions.

[Robert Bradshaw] Add new nullable standard coder.

[Robert Bradshaw] Make Apache Rat happy.

[Robert Bradshaw] Disable broken codecov.

[Robert Bradshaw] Remove last uses of base.ts.

[Robert Bradshaw] Remove unneedd file.

[Robert Bradshaw] Remove more uneeded/unused files.

[Robert Bradshaw] Cleanup tests.

[Robert Bradshaw] Minor cleanups to coder tests.

[Robert Bradshaw] Addressing issues from the review.

[noreply] Apply suggestions from code review.

[Robert Bradshaw] Post-merge fixes.

[Robert Bradshaw] Update tests to use our actual serialization libraries.

[Robert Bradshaw] Another pass at TODOs, removing finished items.

[noreply] [BEAM-14173] Fix Go Loadtests on Dataflow & partial fix for Flink

[noreply] Upgrade python sdk container requirements. (#17549)

[noreply] Merge pull request #17497: [BEAM-11205] Update GCP Libraries BOM version

[noreply] [BEAM-12603] Add retry on grpc data channel and remove retry from test.

[noreply] Merge pull request #17359: [BEAM-14303] Add a way to exclude output

[Kenneth Knowles] Add parameter for service account impersonation in GCP credentials

[noreply] [BEAM-14347] Allow users to optimize DoFn execution with a single

[noreply] [BEAM-5878] Add (failing) kwonly-argument test (#17509)

[noreply] Merge pull request #17490 from [BEAM-14370] [Website] Add new page about


------------------------------------------
[...truncated 81.31 KB...]
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:16:58.800Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:17:28.938Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:18:02.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-06T18:18:29.188Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:19:01.296Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:19:29.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-06T18:20:01.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-06T18:20:28.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-06T18:21:00.748Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:21:32.853Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:22:08.996Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:22:36.092Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:23:06.197Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:23:38.313Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:24:10.433Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:24:38.552Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:25:10.701Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:25:36.794Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:26:09.919Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:26:37.012Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:27:09.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-06T18:27:40.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-06T18:28:11.347Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:28:43.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-06T18:29:08.565Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:29:40.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-06T18:30:07.757Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:30:40.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-06T18:31:13.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-06T18:31:39.145Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:32:10.269Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:32:46.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-06T18:33:17.496Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:33:45.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-06T18:34:16.711Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:34:48.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-06T18:35:15.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-06T18:35:46.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-06T18:36:19.194Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:36:51.292Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:37:25.407Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:37:55.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-06T18:38:28.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-06T18:39:00.740Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:39:27.848Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:39:58.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-06T18:40:26.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-06T18:41:03.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-06T18:41:30.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-06T18:41:56.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-06T18:42:27.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-06T18:42:57.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-06T18:43:28.703Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:43:59.804Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:44:27.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-06T18:45:01.064Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:45:29.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-06T18:46:07.287Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:46:38.387Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:47:06.489Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:47:39.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-06T18:48:06.682Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:48:38.809Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:49:05.909Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:49:38.035Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:50:10.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-06T18:50:37.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-06T18:51:09.373Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:51:40.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-06T18:52:06.552Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:52:39.692Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:53:11.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-06T18:53:38.938Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:54:10.049Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:54:39.143Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:55:12.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-06T18:55:39.352Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:56:16.472Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:56:47.569Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:57:16.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-06T18:57:48.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-06T18:58:16.876Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:58:49.020Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T18:59:24.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-06T19:00:00.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-06T19:00:32.379Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:00:59.489Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:01:31.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-06T19:01:59.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-06T19:02:31.845Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:03:00.001Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:03:32.150Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:04:16.350Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:04:48.461Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:05:15.583Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:05:47.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-06T19:06:20.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-06T19:06:47.919Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:07:20.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-06T19:07:48.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-06T19:08:20.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-06T19:08:46.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-06T19:09:18.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-06T19:09:46.583Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:10:17.690Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:10:50.804Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:11:18.889Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:11:49.996Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:12:18.076Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:12:51.197Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:13:18.286Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:13:51.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-06T19:14:17.465Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:14:51.609Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:15:18.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-06T19:15:47.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-06T19:16:18.933Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:16:52.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-06T19:17:26.196Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:17:59.355Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:18:32.453Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:18:58.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-06T19:19:32.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-06T19:19:59.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-06T19:20:35.915Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:21:09.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-06T19:21:37.141Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:22:11.257Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:22:44.380Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:23:16.484Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:23:48.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-06T19:24:19.687Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:24:48.790Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:25:15.880Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:25:49.025Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:26:21.144Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:26:48.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-06T19:27:19.352Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:27:50.469Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:28:17.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-06T19:28:49.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-06T19:29:21.794Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:29: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-06T19:30:23.017Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:30:50.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-06T19:31:22.232Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:31:49.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-06T19:32:17.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-06T19:32:52.623Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:33:17.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-06T19:33:48.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-06T19:34:20.984Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:34:53.119Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:35:27.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-06T19:36:00.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-06T19:36:27.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-06T19:36:56.556Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:37:27.671Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:37:55.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-06T19:38:27.857Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:39:00.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-06T19:39:27.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-06T19:39:58.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-06T19:40:30.268Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:40:56.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-06T19:41:27.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-06T19:42:00.555Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:42:26.640Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:42:57.732Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:43:29.841Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:43:58Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:44:30.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-06T19:45:02.205Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:45:32.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-06T19:45:59.383Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:46:30.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-06T19:47:02.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-06T19:47:39.735Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:48:06.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-06T19:48:38.931Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:49:11.053Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:49:38.150Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:50:10.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-06T19:50:37.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-06T19:51:09.483Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:51:37.572Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:52:08.671Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:52:38.800Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:53:10.895Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:53:38.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-06T19:54:10.114Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:54:42.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-06T19:55:09.307Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:55:42.490Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:56:18.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-06T19:56:49.713Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:57:15.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-06T19:57:46.894Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:58:18.034Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:58:49.167Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:59:25.284Z: JOB_MESSAGE_ERROR: generic::invalid_argument: Last primary index cannot decrease from previous split, was 0 and is now -1
INFO:apache_beam.runners.dataflow.dataflow_runner:2022-05-06T19:59:56.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-06T20:00:27.484Z: JOB_MESSAGE_ERROR: 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-06_09_39_44-3350849901515936975 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 1660, in wait_until_finish
    'Job did not reach to a terminal state after waiting indefinitely.')
AssertionError: Job did not reach to a terminal state after waiting indefinitely.

> 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 17s
15 actionable tasks: 9 executed, 4 from cache, 2 up-to-date

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

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

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org