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 2021/04/07 12:06:13 UTC
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #7041
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7041/display/redirect?page=changes>
Changes:
[Kyle Weaver] [BEAM-12095] Add unit tests for path_to_beam_jar(artifact_id).
------------------------------------------
[...truncated 38.54 MB...]
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0G262q07m5sJ8Cxvjm4Yovlf3m4Yov",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0G4IfhsPven/8BgIiL+OgphtaL+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.eventTimestamp",
2021-04-07T12:06:10.086Z Waiting for main pipeline to 'finish'
2021-04-07T12:06:10.086Z DONE SessionSideInputJoin
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "ueLgAw==",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4FgN6Dj/mB6uoBo9iv+OgpxaWw+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4Fp7aBrdnYsYgCyf/m4YovlIfn4Yov",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "discarded",
"PTRANSFORM": "SessionSideInputJoin.DevNull/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "0A8=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newPersons",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "events",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "8C4=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newAuctions",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "bids",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "9AM=",
"labels": {
"NAMESPACE": "source",
"NAME": "elements_read",
"PTRANSFORM": "NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessKeyedElements/SplittableParDoViaKeyedWorkItems.ProcessElements"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "records",
"PTRANSFORM": "SessionSideInputJoin.Format/ParMultiDo(Anonymous)"
}
}]
}
}
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 35ac530a0a4faf7228a179a56652166e, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
INFO: JobManager for job 8826f879f67aea0ade032fb88cd9bf0a with leader id b9faa89cf4db879cc89b8cb9b8274baf lost leadership.
2021-04-07T12:06:10.089Z 1 samples not enough to calculate steady-state event rate
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 148e974c763ed937c0f57e93a2411329, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: d2b54e1534c03ddc55732e954a12beae, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 9fc27e691192437a49452b14a5093f9c, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 50d612d5e56ea4d1df4421d629fbc4b2, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 4962685341c25301f9b786dabe417577, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 1bc55a35036063a8094d9660bd594e3e, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: cac8ea95a3efd92467101e57d82c7c2f, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: bc2b49e4906a1c7984f2da666e7a5d6b, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 6649a31872bb65de992f614a15cb9766, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 38f05d5c9c591bea4fa43b2ba1184014, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: cba0ec6ec87ad9bcb6b4acc5a349a5ed, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 4443b2e3aed405a885a32bc662063402, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: c3b75f2d6880444567a3e262f689ce0a, jobId: 8826f879f67aea0ade032fb88cd9bf0a).
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-4a357ffb-ab2e-49a1-b17f-82c4801fce27
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-ae6d131d-18c7-4926-8b4c-7d61ec1107d5
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-f6ce2efc-d821-449e-9e87-44c7a36c3346
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:38571
Apr 07, 2021 12:06:10 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
> Task :sdks:java:testing:nexmark:run FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:testing:nexmark:run'.
> Process 'command '/usr/lib/jvm/java-8-openjdk-amd64/bin/java'' finished with non-zero exit value 1
* 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1m 29s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/zmgmlwxi6nv74
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
Jenkins build is back to normal :
beam_PostCommit_Java_Nexmark_Flink #7047
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7047/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #7046
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7046/display/redirect?page=changes>
Changes:
[Kyle Weaver] [BEAM-10925] Refactor ZetaSqlJavaUdfTypeTest.
[Boyuan Zhang] SDF bounded wrapper returns None when any exception happen in the
[Steve Niemitz] [BEAM-12126] Fix DirectRunner not respecting use_deprecated_reads
[randomstep] [BEAM-12092] Bump jedis to 3.5.2
[noreply] [BEAM-11227] Try reverting #14295: Moving from vendored gRPC 1.26 to
[noreply] Merge pull request #14446 from [BEAM-10854] Fix PeriodicImpulse for
------------------------------------------
[...truncated 38.49 MB...]
INFO: __metricscontainers : {
"metrics": {
"attempted": [{
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "ltyPBg==",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0Gja2+nvT1sp8C2sXTlYsvgMvTlYsv",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0G4IfhsPven/8BgIiL+OgphtaL+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "ueLgAw==",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4FgN6Dj/mB6uoBo9iv+OgpxaWw+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
2021-04-08T18:18:24.086Z Waiting for main pipeline to 'finish'
2021-04-08T18:18:24.086Z DONE SessionSideInputJoin
"NAME": "result.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4FkZDKrOv7s4gCyczTlYsvvNPTlYsv",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "discarded",
"PTRANSFORM": "SessionSideInputJoin.DevNull/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "0A8=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newPersons",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "events",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "8C4=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newAuctions",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "bids",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "9AM=",
"labels": {
"NAMESPACE": "source",
"NAME": "elements_read",
"PTRANSFORM": "NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessKeyedElements/SplittableParDoViaKeyedWorkItems.ProcessElements"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "records",
"PTRANSFORM": "SessionSideInputJoin.Format/ParMultiDo(Anonymous)"
}
}]
}
}
2021-04-08T18:18:24.087Z 1 samples not enough to calculate steady-state event rate
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: f050024ff1a82ba1b614d0a686f39a7c, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 2a16b528eebf6db805c530d4f5c6ff42, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 0e4a654036ece6541b07ed4062ca5992, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 3234df1f9b9b0a1d445a5060cf7b4ac1, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 8bc54d89b90790df0e9608f002e6f57a, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 08ad1637834ca31c406c11758ac736e7, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 174e51e41781d011a9e427162e8b1475, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: e7b5661c624431b65ffee8496f52e849, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 540db6662487ea223a85984db48f1531, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: e76cf4b6285a948f1fbe9465ef263e0b, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 79575ad6fb8a4b038b5ef84238e043ef, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: c8217dbbf1d35fc0702afb47646f5515, jobId: 9999114564df6a8dbf89a2525f8d6d7e).
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-ba759ca9-bf5b-41ed-82a3-095356e3980d
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-9397a836-7779-4e25-851a-bfab4b97e5be
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-d38c4337-159d-4edc-a5ca-9c6b52823608
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:37659
Apr 08, 2021 6:18:24 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
> Task :sdks:java:testing:nexmark:run FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:testing:nexmark:run'.
> Process 'command '/usr/lib/jvm/java-8-openjdk-amd64/bin/java'' finished with non-zero exit value 1
* 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1m 31s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/zomtacq6lhr5c
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
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #7045
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7045/display/redirect>
Changes:
------------------------------------------
[...truncated 38.52 MB...]
"attempted": [{
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "ltyPBg==",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0G8vjk6Py0sp8CjuaBi4svnOuBi4sv",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0G4IfhsPven/8BgIiL+OgphtaL+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "ueLgAw==",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.bytes",
2021-04-08T12:06:33.249Z "PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4FgN6Dj/mB6uoBo9iv+OgpxaWw+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4F/MPZ7ozAs4gCru2Bi4svjPSBi4sv",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "discarded",
"PTRANSFORM": "SessionSideInputJoin.DevNull/ParMultiDo(Anonymous)"
}
Waiting for main pipeline to 'finish'
2021-04-08T12:06:33.250Z DONE SessionSideInputJoin
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "0A8=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newPersons",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "events",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "8C4=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newAuctions",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "bids",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "9AM=",
"labels": {
"NAMESPACE": "source",
"NAME": "elements_read",
"PTRANSFORM": "NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessKeyedElements/SplittableParDoViaKeyedWorkItems.ProcessElements"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "records",
"PTRANSFORM": "SessionSideInputJoin.Format/ParMultiDo(Anonymous)"
}
}]
}
}
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 4862177b25b26bd1eddf2c25a1e8cf24, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
2021-04-08T12:06:33.251Z 1 samples not enough to calculate steady-state event rate
Apr 08, 2021 12:06:33 PM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 9edec070de76d3a02d7be534e8fe3f64, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: d0108948abfb8d0f872c66ee673a1059, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 30e2df89f9068d7583a462c0188594b6, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 824304bd9b51c3676f2e98e9c447f439, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: fc5c6c8619b80fd073e609bb7b52edee, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 1b581f44aefd8dfb71a60c83a2eaf700, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: dcf2e19a7a1234c63ea8f130a4706021, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 962283d697f6d3f688c6812e56446eee, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 041f98ead3f6b8d409ca8f19a6fb7cc8, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 9716b4861fff7d6d1be7ffae04d247a2, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 3ebc40d8ec8642247440be9b7fff7e1e, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 9701083d7ead9b464452d0121e57a05c, jobId: 207ade371dbbfdc6ff3dd7c03a5ef121).
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-9cf1d840-3105-4449-ba9f-e7af7c576efb
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-8165faff-f426-4db7-a445-4d4c38ee03cc
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-b4a6e288-742a-4037-9518-c66e3d26bd3a
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:33471
Apr 08, 2021 12:06:33 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
> Task :sdks:java:testing:nexmark:run FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:testing:nexmark:run'.
> Process 'command '/usr/lib/jvm/java-8-openjdk-amd64/bin/java'' finished with non-zero exit value 1
* 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1m 38s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/fndammdbym7oa
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
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #7044
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7044/display/redirect?page=changes>
Changes:
[Ismaël Mejía] [BEAM-11948] Drop support for Flink 1.8 and 1.9
[noreply] [BEAM-7372] remove usage of future package and unnecessary builtins
[noreply] [BEAM-7372] cleanup codes for py2 compatibility from
------------------------------------------
[...truncated 38.51 MB...]
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0GzYWYqKH2sZ8CnMnegIsvus7egIsv",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0G4IfhsPven/8BgIiL+OgphtaL+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "ueLgAw==",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4FgN6Dj/mB6uoBo9iv+OgpxaWw+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4F3rnwwrOGs4gCrNDegIsv5dXegIsv",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "discarded",
"PTRANSFORM": "SessionSideInputJoin.DevNull/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "0A8=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newPersons",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "events",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "8C4=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newAuctions",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "bids",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "9AM=",
"labels": {
"NAMESPACE": "source",
"NAME": "elements_read",
"PTRANSFORM": "NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessKeyedElements/SplittableParDoViaKeyedWorkItems.ProcessElements"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "records",
"PTRANSFORM": "SessionSideInputJoin.Format/ParMultiDo(Anonymous)"
}
}]
}
}
2021-04-08T06:07:24.408Z Waiting for main pipeline to 'finish'
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 1581fee9d546d5b4f6b30d7c6ebfee4e, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: ae9594f52189fd63729e72abfa28cbdd, jobId: 6b41b1617e68323ad89d60403d98daee).
2021-04-08T06:07:24.408Z DONE SessionSideInputJoin
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 843c13ae4faa79391a02ca71233abae3, jobId: 6b41b1617e68323ad89d60403d98daee).
2021-04-08T06:07:24.410Z 1 samples not enough to calculate steady-state event rate
Apr 08, 2021 6:07:24 AM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 539cd67286ce5e5684bd9f873bab7e0b, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 30a47edc6d762b13685a48a8c648374a, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 3c101e2eb4bca772f5dba0793fac2410, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 9320d2ce380b70ebe64db893b3c26c22, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: e600f0281fbee1a454dcf074b680672b, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: f88b8d89ff3d859448a80321303907e8, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 1164438f55d8139cfbc0b973759476db, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: b3fc4cc71258003acf83ad055b46294d, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: e8f54c70b1282cace6ddaa2dc88da6e9, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 5e278fcd6929eddd0afa0b7aebf8c19f, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 4deb1160050c6d145edc50f2b7ad21e9, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 72d90b0f4096c76aa650e3b8ef87875e, jobId: 6b41b1617e68323ad89d60403d98daee).
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-3635e763-fda6-4b8a-b259-9396d93180d7
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-a114c570-8f97-4f33-b0d0-b3d9b0484c6c
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-85bbe99c-b3c8-4ee5-8d2d-3016de37ac66
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:33145
Apr 08, 2021 6:07:24 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
> Task :sdks:java:testing:nexmark:run FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:testing:nexmark:run'.
> Process 'command '/usr/lib/jvm/java-8-openjdk-amd64/bin/java'' finished with non-zero exit value 1
* 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1m 28s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/f6nkz4e74xb4q
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
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #7043
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7043/display/redirect?page=changes>
Changes:
[noreply] Update WriteToBigQuery multiple destinations doc
[randomstep] [BEAM-11900] Bump libthrift to 0.14.0
[randomstep] [BEAM-11900] Bump libthrift to 0.14.1
[kawaigin] [BEAM-10708] Read/Write Intermediate PCollections
[kawaigin] Fix lint
[kawaigin] Fix based on comments
[kawaigin] Added clear method to InMemoryCache because tests might be flaky when a
[noreply] Fix: Allow BigQuery tableIds with hyphens (#14125)
[noreply] Merge pull request #14394 from [BEAM-11277] Add method to check if two
[kawaigin] Avoid using interactive_environment module in the test because
[noreply] [BEAM-449] Support PCollectionList in PAssert (#14322)
[kawaigin] [BEAM-11045] Avoid broken deps
[kawaigin] Added back the setUp as additional cleanup routine before each test.
[noreply] [BEAM-11742] Use pyarrow schema instead column names when creating
------------------------------------------
[...truncated 38.52 MB...]
"NAME": "event.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0Gs7XX05K5sZ8CzvPc9oovnvnc9oov",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0G4IfhsPven/8BgIiL+OgphtaL+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "ueLgAw==",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
2021-04-08T00:17:25.648Z Waiting for main pipeline to 'finish'
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4FgN6Dj/mB6uoBo9iv+OgpxaWw+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4FtNLW0pbOsogCufrc9oov/oDd9oov",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "discarded",
"PTRANSFORM": "SessionSideInputJoin.DevNull/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "0A8=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newPersons",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
2021-04-08T00:17:25.648Z }, {
"urn": "beam:metric:user:sum_int64:v1",
DONE SessionSideInputJoin
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "events",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "8C4=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newAuctions",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "bids",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "9AM=",
"labels": {
"NAMESPACE": "source",
"NAME": "elements_read",
"PTRANSFORM": "NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessKeyedElements/SplittableParDoViaKeyedWorkItems.ProcessElements"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "records",
"PTRANSFORM": "SessionSideInputJoin.Format/ParMultiDo(Anonymous)"
}
}]
}
}
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: ad5d689a6190e8038f5a62118f3125af, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 115cc52b0933bfdd880f85be05cc7547, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
INFO: JobManager for job 9c2b4dd2df7bdf9e1177a05f8dede877 with leader id 875a109e7cb6b554c461972f59cb423d lost leadership.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 01fa0fddb3a310adb5b9b2df2a98dfb3, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
2021-04-08T00:17:25.654Z 1 samples not enough to calculate steady-state event rate
Apr 08, 2021 12:17:25 AM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: f8dea08786ec39d5be7b48ebf1f92b0d, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 44a8ff739896f3670402be082efe3b19, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 373fafa23512b525ac58c104f74c9416, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 7c5201b256f290ee6518f67b045ae594, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 598e3d2dbdf5b9d9afd57892d6c5d7be, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: e6ba8d083de5dcd0ace69b583bc89b05, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: bbe70e6345b977708cf516d471cfb3d6, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 7445e02ca143b842e666daaaf2aa6938, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 26d0d0dbf67abbe706005e5a28506bcb, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: c1ad2d5c412a437aeb5d3841b3b9d3f8, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 52c6ca613be8a5e67f1f18c11cfd0436, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 2ccd2e50c402d05cba4a5c70f3548fb0, jobId: 9c2b4dd2df7bdf9e1177a05f8dede877).
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-a1bb55d3-676f-442d-9c91-86ccbc256f65
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-558b58e9-cdb1-4255-9da5-eaa7d72defd7
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-a306b38b-c3b9-4910-a5ef-1179edac74b6
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:43493
Apr 08, 2021 12:17:25 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
> Task :sdks:java:testing:nexmark:run FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:testing:nexmark:run'.
> Process 'command '/usr/lib/jvm/java-8-openjdk-amd64/bin/java'' finished with non-zero exit value 1
* 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1m 29s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/utshzhnln6hfm
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
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #7042
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7042/display/redirect?page=changes>
Changes:
[Kyle Weaver] [BEAM-10925] Java UDF type tests for input refs.
[randomstep] [BEAM-12066] Bump classgraph to 4.8.104
[Kyle Weaver] [BEAM-12102] Catch and rethrow Calcite CannotPlanException.
[noreply] [BEAM-11961] InfluxDBIOIT failing with unauthorized error (#14215)
[noreply] Add DataFrame API changes to CHANGES.md (#14454)
------------------------------------------
[...truncated 38.50 MB...]
"type": "beam:metrics:sum_int64:v1",
"payload": "ltyPBg==",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0GqdmFwaT6sJ8CkdC27IovltW27Iov",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "oI0G4IfhsPven/8BgIiL+OgphtaL+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Events",
"NAME": "event.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Monitor/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "ueLgAw==",
2021-04-07T18:17:26.982Z Waiting for main pipeline to 'finish'
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.bytes",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
2021-04-07T18:17:26.982Z DONE SessionSideInputJoin
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.elements",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4FgN6Dj/mB6uoBo9iv+OgpxaWw+Ogp",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.eventTimestamp",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:distribution_int64:v1",
"type": "beam:metrics:distribution_int64:v1",
"payload": "4M4F8N+UnKyUsogCtte27Iovt9227Iov",
"labels": {
"NAMESPACE": "SessionSideInputJoin.Results",
"NAME": "result.processingTime",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Debug/ParMultiDo(Monitor)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "discarded",
"PTRANSFORM": "SessionSideInputJoin.DevNull/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "0A8=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newPersons",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
2021-04-07T18:17:26.983Z 1 samples not enough to calculate steady-state event rate
"payload": "oI0G",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "events",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "8C4=",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "newAuctions",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "bids",
"PTRANSFORM": "SessionSideInputJoin/SessionSideInputJoin.Snoop/ParMultiDo(Anonymous)"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "9AM=",
"labels": {
"NAMESPACE": "source",
"NAME": "elements_read",
"PTRANSFORM": "NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessKeyedElements/SplittableParDoViaKeyedWorkItems.ProcessElements"
}
}, {
"urn": "beam:metric:user:sum_int64:v1",
"type": "beam:metrics:sum_int64:v1",
"payload": "4M4F",
"labels": {
"NAMESPACE": "SessionSideInputJoin",
"NAME": "records",
"PTRANSFORM": "SessionSideInputJoin.Format/ParMultiDo(Anonymous)"
}
}]
}
}
Apr 07, 2021 6:17:26 PM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: cfa49dd03a5a451470117f572f721206, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 62b78285a269fb1e051186f63df116b9, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
INFO: JobManager for job 16388ca2b2d0bfd4bf06ca089be0ea58 with leader id 9764e1e1067f18880d991a7edfdc4027 lost leadership.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: a47bacd3e19d3bacec49565ebcb0ff95, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: f6cb2d3905b1156ad12acc3fb249775e, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 9e1991ec9b9e103ea9afb748a608e7d1, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 9f22601e245220d40af20be9bff3ce9e, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: f02d2b4c39805c20c44b4ab7c114ace5, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 10e0040b0121a4b1fe0a6470b1782c95, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: e021dabf8a36b6907ce2d204ab021a8f, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 460ef4b0c283e394cb7daff42655a5c1, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: 4463c53ac85d0a2ec5c2836a6c529526, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: bf9af63ffe3e9de24fb7969850ca142b, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:26 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{managedMemory=8.000mb (8388608 bytes), networkMemory=4.000mb (4194304 bytes)}, allocationId: e67fe5d86b83fdccd9c02037a3c11841, jobId: 16388ca2b2d0bfd4bf06ca089be0ea58).
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-bed987cb-4508-45d1-9587-2ace8e86efd4
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-1de2e21f-94f7-4ce8-bbed-4756c00178fa
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-a2150d0c-32de-435f-a935-5da2c36e8a4c
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:36967
Apr 07, 2021 6:17:27 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
> Task :sdks:java:testing:nexmark:run FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:testing:nexmark:run'.
> Process 'command '/usr/lib/jvm/java-8-openjdk-amd64/bin/java'' finished with non-zero exit value 1
* 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1m 31s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/7cel4v6mt6hao
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