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

Changes:

[tuyarer] [BEAM-13577] Beam Select's uniquifyNames function loses nullability of

[Steve Niemitz] [BEAM-13689] Output token elements when BQ batch writes 
complete.

[noreply] [BEAM-13699] Replace fnv with maphash. (#16573)

[noreply] [BEAM-13693] Bump

[noreply] [BEAM-10206] Remove Fatalf calls in non-test goroutines for


------------------------------------------
[...truncated 62.45 KB...]

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-cf0a5309-6834-4735-a335-e6500eb4edbd

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-7121558c-ca16-44c8-bc84-e1494ddbaee0

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-5ffb8ca3-8d00-4845-94a8-e3e06455a74e
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-8056463e-c6fd-4cc1-9cc9-54f452ba7bb4
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-79572bf0-8b1f-45f2-afb3-22e8ad99c691
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-fca37a92-77c8-4a5a-99dd-a785b9059d99

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-a674715c-b43d-4bcc-85e7-36110d611f63
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-28de9f2f-f89a-40e2-a722-c5608f7827ec
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-3d70bb95-3b87-40a7-96a0-a5c785f4a400
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-3a5aaee8-4b57-434d-b546-913cc726df6f

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-2049299c-569a-4369-8029-7d1e078e9cc8
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-d58e0a61-63fb-4ef2-af27-3bca535df426

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-67d92dab-6403-442f-ab96-f53883e0eb3a
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-30145643-7aca-4ee0-ba61-67664f714f3c

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-869894a7-edf4-4576-bc43-017950413765

org.apache.beam.sdk.transforms.PerKeyOrderingTest > 
testMultipleStatefulOrderingWithShuffle FAILED
    java.lang.UnsupportedOperationException at PerKeyOrderingTest.java:280

org.apache.beam.sdk.transforms.PerKeyOrderingTest > 
testSingleCallOrderingWithoutShuffle FAILED
    java.lang.IllegalStateException at PerKeyOrderingTest.java:193

org.apache.beam.sdk.transforms.PerKeyOrderingTest > 
testSingleCallOrderingWithShuffle FAILED
    java.lang.IllegalStateException at PerKeyOrderingTest.java:135

org.apache.beam.sdk.transforms.PerKeyOrderingTest > 
testMultipleStatefulOrderingWithoutShuffle FAILED
    java.lang.UnsupportedOperationException at PerKeyOrderingTest.java:321
[shutdown-hook-0] INFO org.apache.spark.SparkContext - Invoking stop() from 
shutdown hook
[dispatcher-event-loop-3] INFO org.apache.spark.MapOutputTrackerMasterEndpoint 
- MapOutputTrackerMasterEndpoint stopped!
[shutdown-hook-0] INFO org.apache.spark.storage.memory.MemoryStore - 
MemoryStore cleared
[shutdown-hook-0] INFO org.apache.spark.storage.BlockManager - BlockManager 
stopped
[shutdown-hook-0] INFO org.apache.spark.storage.BlockManagerMaster - 
BlockManagerMaster stopped
[dispatcher-event-loop-0] INFO 
org.apache.spark.scheduler.OutputCommitCoordinator$OutputCommitCoordinatorEndpoint
 - OutputCommitCoordinator stopped!
[shutdown-hook-0] INFO org.apache.spark.SparkContext - Successfully stopped 
SparkContext
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-98878528-2456-49c4-9891-b3b6319414c2

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch

org.apache.beam.sdk.transforms.PerKeyOrderingTest > 
testMultipleStatefulOrderingWithShuffle FAILED
    java.lang.UnsupportedOperationException at PerKeyOrderingTest.java:280
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-177ddf04-7e7d-492a-89c2-ab46c1005b73

org.apache.beam.sdk.transforms.PerKeyOrderingTest > 
testSingleCallOrderingWithoutShuffle FAILED
    java.lang.IllegalStateException at PerKeyOrderingTest.java:193
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-726953d0-9b0d-4ec4-b74b-a95e9b899bf4

org.apache.beam.sdk.transforms.PerKeyOrderingTest > 
testSingleCallOrderingWithShuffle FAILED
    java.lang.IllegalStateException at PerKeyOrderingTest.java:135

org.apache.beam.sdk.transforms.PerKeyOrderingTest > 
testMultipleStatefulOrderingWithoutShuffle FAILED
    java.lang.UnsupportedOperationException at PerKeyOrderingTest.java:321
[shutdown-hook-0] INFO org.apache.spark.SparkContext - Invoking stop() from 
shutdown hook
[dispatcher-event-loop-0] INFO org.apache.spark.MapOutputTrackerMasterEndpoint 
- MapOutputTrackerMasterEndpoint stopped!
[shutdown-hook-0] INFO org.apache.spark.storage.memory.MemoryStore - 
MemoryStore cleared
[shutdown-hook-0] INFO org.apache.spark.storage.BlockManager - BlockManager 
stopped
[shutdown-hook-0] INFO org.apache.spark.storage.BlockManagerMaster - 
BlockManagerMaster stopped
[dispatcher-event-loop-0] INFO 
org.apache.spark.scheduler.OutputCommitCoordinator$OutputCommitCoordinatorEndpoint
 - OutputCommitCoordinator stopped!
[shutdown-hook-0] INFO org.apache.spark.SparkContext - Successfully stopped 
SparkContext
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-04e42b46-6ea5-40f0-97e2-22082a10ac69

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-76c0dc79-3ba9-4a01-ac01-d68cfcf5a34f
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-3b5d63fb-c61a-49f0-b47c-8da50587e6a3
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-9f5651a5-5ecf-43d7-ae5d-db7a32341dc8

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-c6c65d1f-4413-4c0e-b7e7-c646483e6a7b
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-3f4c1e36-2c32-4648-98f3-6a81a7d59b00

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-bf9087ab-781b-44f8-b9b2-f2efc6052a00
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-7a1cf611-fb55-4f6a-b67a-10b53fafe44d

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-ed67ba67-643c-41a6-803d-162a4c0c2904

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-57e69fb2-a67b-451d-8e42-9c6fd2293115
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-8b08dbe1-c750-4869-b3f1-84b23b824c2b

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-8f0ae1a2-ee5a-4cb0-8e4b-c90ed540cea5
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-e4726777-371b-4246-8e8b-3316e9adb550
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-db541e61-1272-4de5-ab82-e4c0ffd596fa

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-e07bedca-82c2-4a8f-8793-4d160869ec9d

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-9569f086-66e6-4b3e-9606-f88a726d0fda

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-e3884c0b-c92f-4c06-9301-c56492d1ebc7
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-0c2e31d0-c5e3-4cfd-8b3e-f36aa68c6c94

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-16340d7b-5b1b-47ff-8af1-b9fafc2fb9dc
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-a2c320dc-a910-486a-9731-1b8648813a2d

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-c50acf50-15af-4bfc-9b5c-a4aea1293a83
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-9edbb212-4d71-4d2c-8263-ed689f23e9d2
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-3cfd54cf-3a54-4557-88d2-ef9caed0eb5d

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-e07e68c9-f587-44bd-bf14-733385aad498
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-bc127c5a-5c8c-4985-a174-fc534caf173d
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-bdee7369-7858-4ff5-ae20-8c8db8e96ccc

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-ed8cbfab-bc40-4cc6-bb2d-ee128dbf2a56
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-61333cff-abee-4529-b8cf-5ef30aa523a6

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-58c15a7a-a90e-49f7-8a13-fe477d84aba0
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-676e3514-b796-41a6-85db-3d69d6f73338

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-25d6e17c-f5bf-4116-9a75-010a254b488f

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-8a0b9ea6-b85d-4794-a7ec-aa4a01c7d438

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-b8f118a3-adaf-4a7c-a686-b49239192d3b

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-5f5bcc1c-6815-43f6-ace1-c478cf91fedd

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-8f338b77-9cc6-4dc2-a2c7-3aef387420f1

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Shutdown 
hook called
[shutdown-hook-0] INFO org.apache.spark.util.ShutdownHookManager - Deleting 
directory /tmp/spark-9f90c942-41a0-48d6-94eb-958fcc7dd22f

> Task :runners:spark:2:validatesStructuredStreamingRunnerBatch FAILED

221 tests completed, 4 failed, 1 skipped

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch

221 tests completed, 4 failed, 1 skipped

> Task :runners:spark:3:validatesStructuredStreamingRunnerBatch FAILED

FAILURE: Build completed with 2 failures.

1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task 
':runners:spark:2:validatesStructuredStreamingRunnerBatch'.
> There were failing tests. See the report at: 
> file://<https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming/ws/src/runners/spark/2/build/reports/tests/validatesStructuredStreamingRunnerBatch/index.html>

* 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.
==============================================================================

2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task 
':runners:spark:3:validatesStructuredStreamingRunnerBatch'.
> There were failing tests. See the report at: 
> file://<https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming/ws/src/runners/spark/3/build/reports/tests/validatesStructuredStreamingRunnerBatch/index.html>

* 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

BUILD FAILED in 21m 39s
142 actionable tasks: 95 executed, 45 from cache, 2 up-to-date

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

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