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/06 00:18:27 UTC
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #7035
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7035/display/redirect?page=changes>
Changes:
[chamikaramj] Updates Dataflow worker pool config to include all environments used by
[Kyle Weaver] [BEAM-10925] Roundtrip tests for literals through Java UDF.
[Ismaël Mejía] [BEAM-4106] Add FileStagingOptions and merge staging file options
[Kyle Weaver] [BEAM-12095] Fix Spark job server path.
[noreply] remove typo in encoding.go
[Kyle Weaver] [BEAM-10925] Simplify test setup.
[noreply] [BEAM-12060] Remove overwriting jenkins property. (#14432)
------------------------------------------
[...truncated 38.53 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": "oI0GnbWmy7PCrZ8CutCtpIovpdetpIov",
"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-06T00:18:24.656Z Waiting for main pipeline to 'finish'
2021-04-06T00:18:24.656Z DONE SessionSideInputJoin
"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": "4M4F3tnm29P/rogCstetpIov+t2tpIov",
"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-06T00:18:24.658Z 1 samples not enough to calculate steady-state event rate
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
INFO: JobManager for job 47c5affbb17765f853063dd2dca750c4 with leader id 9dc659267fc7f40149b41dca58914f06 lost leadership.
Apr 06, 2021 12:18:24 AM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 06, 2021 12:18: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: 97ae00610a6fe491dcbcf84359dfaaf3, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: 80028ff5639d89eac6c410910c0fe7d9, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: 6af25041e34751a9351ea47ee324f1ff, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: 73093c1b1ba847aa56d4ff298a38d752, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: 282b222d4c145c6a100e32df8d9b8975, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: 18b1d1bb7c5329d3ca2e3d050b1b77dd, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: 004adcd3208c885bcb3a62822f4a3c73, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: c7b6d639a804a579fa9d91a572294fd3, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: c8186c64d5ac2980d47d106b06271054, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: 97ac48ca252099f3df1bebd1a990a497, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: e169fff282fa0c468c6a2b703fb2a156, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18:24 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: 5e8c3258d94a8ebd07e1cd32bbfc2bd7, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: 79b805d32df774db1260715d1998333f, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18: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: 1ffa0fcf292783774f3841e4e83f2599, jobId: 47c5affbb17765f853063dd2dca750c4).
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-7ad50b41-91fc-4b2a-88fe-0c86b0d72269
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-2305c204-bb30-48f2-8355-25f7b1737582
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-8ceb5200-05c3-4231-98f8-672ef419d814
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 06, 2021 12:18:24 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:39911
Apr 06, 2021 12:18: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/75vriprjhtaj4
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
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #7041
Posted by Apache Jenkins Server <je...@builds.apache.org>.
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
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #7040
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7040/display/redirect?page=changes>
Changes:
[MATTHEW.Ouyang] [BEAM-12059] include literal T in DATETIME format
[suztomo] protobuf-java to be in-line with libraries-bom 16.3.0
[suztomo] Removing unused variable google_auth_version
[noreply] Merge pull request #14388 from [BEAM-7372] remove codes for py2
[noreply] Merge pull request #14365 from [BEAM-10884] - Adding tests to
------------------------------------------
[...truncated 38.51 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": "oI0Gi9/tgOL8r58ChaXu14ov/qnu14ov",
"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": "4M4FgPu9ju+gsYgCmazu14ov5rPu14ov",
"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",
2021-04-07T06:18:38.972Z Waiting for main pipeline to 'finish'
2021-04-07T06:18:38.972Z DONE SessionSideInputJoin
"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 6:18:38 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: cdd9cf5eeefa75a81fa675be08b37adb, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
2021-04-07T06:18:38.973Z 1 samples not enough to calculate steady-state event rate
Apr 07, 2021 6:18:38 AM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 07, 2021 6:18:38 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: 50d884b5762b81bc6c55de0a5b821521, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 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: 42223db29c9e19ae5b4243a8042d25cf, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 07, 2021 6:18:38 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: 5f2c79d82e7157bfce4f59b973d16775, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 07, 2021 6:18:38 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: ea2f34bbd473e23ae787216b317c2d84, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 AM 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:18:38 AM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 07, 2021 6:18:38 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: beb1490b11e194251493f7fdf317e34d, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 07, 2021 6:18:38 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: 067836ccce96af0f4cf53864a7213ab7, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 07, 2021 6:18:38 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: 10c7e6c5f23b3b464892445847694e93, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 AM 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:18:38 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: 453aee23852d18e78aa67b2aaa4e8ae0, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 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: ed832d16bd25949ad05fd41c95bbd70a, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 07, 2021 6:18:38 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: 03fff107e2419b2bf05106e1171819a2, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 6:18:38 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: d55bd6e2441c94395af384767c7ec1df, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 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: ef0947772eb9304edd16ba967240a155, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 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: 4474681a11952e70d0c71e99293f4df5, jobId: 462fec4becfaad5d34870cd9d9c9cad7).
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-7f0b5019-6915-4062-a58d-7a9823ff982b
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-7bebd523-4071-43d6-a467-5e43cc242bc8
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-e4a9ce32-6cd8-413a-902f-f65861f951be
Apr 07, 2021 6:18:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 07, 2021 6:18:39 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 07, 2021 6:18:39 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 07, 2021 6:18:39 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 07, 2021 6:18:39 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 07, 2021 6:18:39 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 07, 2021 6:18:39 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:39789
Apr 07, 2021 6:18:39 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 32s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/6ch5ya5t44hva
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 #7039
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7039/display/redirect?page=changes>
Changes:
[heejong] [BEAM-12051] fix target/go-licenses: no such file or directory
[Kyle Weaver] [BEAM-11483] Ignore windowed GBK tests in Spark portable streaming.
[Kyle Weaver] [BEAM-12095] Fix Spark job server in uber jar path as well.
[kawaigin] [BEAM-12096] Attempt to fix flaky test
[kawaigin] Added logging of potential ImportError
[kawaigin] Use PropertyMock to replace the global singleton current_env()
[kawaigin] Changed warning logs about not in REPL env to error level and fixed a
[noreply] [BEAM-9547] Raise WontImplementError for a few more operations (#14330)
[noreply] [BEAM-11544] BQML pattern (#13644)
[noreply] [BEAM-11574] Enable cross-language integration tests on Dataflow
[noreply] [BEAM-11585] Select.flattenedSchema doesn't flatten nested array fields
[noreply] Updating Go tests on PR template. (#14442)
[noreply] [BEAM-7372] cleanup codes for py2 compatibility from
------------------------------------------
[...truncated 38.54 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": "oI0GmNuH2rC8r58C1oSozYov+YiozYov",
"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": "4M4F6+2vi9HlsIgC/YuozYovn5KozYov",
"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-07T00:09:56.280Z Waiting for main pipeline to 'finish'
2021-04-07T00:09:56.280Z DONE SessionSideInputJoin
Apr 07, 2021 12:09:56 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: 1c8ee2df30ac4373c1fca21e64bba173, jobId: f3fe3f5208534acca04747fb4968da6a).
2021-04-07T00:09:56.283Z 1 samples not enough to calculate steady-state event rate
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
INFO: JobManager for job f3fe3f5208534acca04747fb4968da6a with leader id a58d84c0c3e9e99300fb259dbe74462b lost leadership.
Apr 07, 2021 12:09:56 AM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 07, 2021 12:09:56 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: 4eb2e7cfbf7ce28969f33c16bb3dfb16, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 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: c5a5ead99c250a8d11d894b1b9f6c7c0, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 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: 17bd6b646cf4dd34e5154045fefca9d9, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 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: d07de40f51dc0b82fa904e785b0da2e4, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 07, 2021 12:09:56 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: d0e5e574b4ca9321e2a261a095650712, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 07, 2021 12:09:56 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: 052a73da26e8305fd3fabd5f53f75cc5, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 AM 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:09:56 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: d4eb23fb8fe5faec1e044b3aae25bb57, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 07, 2021 12:09:56 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: 161556e70d30e775c0d3e8066ab59181, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 07, 2021 12:09:56 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: 04680e2647a7da3408a833bd094b4994, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 07, 2021 12:09:56 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: 6c2fccb52c97b40530c2c4ce8dabf1f8, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 AM 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:09:56 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 07, 2021 12:09:56 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: 00ce84a81de62d4b71adf6244cc7221f, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 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: 943059bd3a35561257f32ad6504d8d3e, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 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: 546e66a7dd3cf16f1b57d1ddfda220ee, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 07, 2021 12:09:56 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: 4224b05f77b98af61a403ba2f4a9f043, jobId: f3fe3f5208534acca04747fb4968da6a).
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-220b92d9-b120-44b5-b3a9-ad6ff238a111
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-e4b05d62-309a-4648-bd8b-519ffdadc549
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-f90c092d-3b83-4f94-90ed-48b127bcc6cb
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 07, 2021 12:09:56 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:38489
Apr 07, 2021 12:09:56 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 33s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/upchz7z2jcqc2
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 #7038
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7038/display/redirect?page=changes>
Changes:
[noreply] [BEAM-7372] Remove dead py<3.6 paths (#14436)
------------------------------------------
[...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": "oI0G+vHslO/8rp8Cz4v0woovrpD0woov",
"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": "4M4F7Oi2/JmrsIgCxJP0wooviJv0woov",
"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-06T18:06:13.915Z Waiting for main pipeline to 'finish'
2021-04-06T18:06:13.915Z DONE SessionSideInputJoin
"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 06, 2021 6:06:13 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: c28b799761dc1db48b32c7d5ca2ec750, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
INFO: JobManager for job c7709bafcd4ab86b5b73323ae6bd9416 with leader id 84bf2670be9ae312cd73c074d9f44306 lost leadership.
Apr 06, 2021 6:06:13 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: 99add5b0cf98398d7a382f59acc193e6, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
2021-04-06T18:06:13.917Z 1 samples not enough to calculate steady-state event rate
Apr 06, 2021 6:06:13 PM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 06, 2021 6:06:13 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: 47f2401b435974c1cfbae41656c180d2, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 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: c4643ebdff5fd20c68b55f747954f330, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 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: 8a875fdf1f1d5a59cb9c1584090143d5, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 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: 2a79df3d13d895cc9ce77a2a251489dc, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 06, 2021 6:06:13 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: be18ba2d8e9fcdbeef4c8c25339c2596, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 06, 2021 6:06:13 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: 757f3af214b8e89c47e7433948380df6, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 06, 2021 6:06:13 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: 0db9cb8a3d4a200e24171410016a3041, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 06, 2021 6:06:13 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: e6f4c2ac86ff9c5e0445ea6ac97a8757, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 06, 2021 6:06:13 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: 9b116487d36866d037bc743938d658e1, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 6:06:13 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: 0cc461f54278edc0acb3f8218eb325f6, jobId: c7709bafcd4ab86b5b73323ae6bd9416).
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-cf03bd93-25ae-4b7f-afbc-e266bca05d61
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-99380df1-5630-44ea-89fa-ca18fae22f68
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-5364f6b9-dff2-4aaa-98de-ce977aa47e6d
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 06, 2021 6:06:13 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:36003
Apr 06, 2021 6:06:13 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/npockuhzflqzu
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 #7037
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7037/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": "oI0Gj9aNrYC+rp8C9dnNuIovmN/NuIov",
"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)"
2021-04-06T12:06:13.382Z Waiting for main pipeline to 'finish'
2021-04-06T12:06:13.382Z DONE SessionSideInputJoin
}
}, {
"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": "4M4Fzt628K7xr4gCxeHNuIov9ejNuIov",
"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 06, 2021 12:06:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
INFO: JobManager for job 4079f79b7a222ed542e614e97f7e6b18 with leader id a67122abb8b5de4dd8709b96a3a54a23 lost leadership.
Apr 06, 2021 12:06:13 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: b2eb2d4123e92bd418681e36cdc07d2c, jobId: 4079f79b7a222ed542e614e97f7e6b18).
2021-04-06T12:06:13.384Z 1 samples not enough to calculate steady-state event rate
Apr 06, 2021 12:06:13 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: e82648781e823f50cbc7c5b65acbbad0, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 PM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 06, 2021 12:06:13 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: ff701b1156a9cb32929f12031d3ee6f1, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 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: 1f1b2ca7243627c153f2c52b94d1122f, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 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: 1466611b600bd58ec329726c1b9a4549, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 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: 47c94a1ef420cda5a6173ad249e59702, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 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: a5751ea5b083998576bc7589f6f353c0, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 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: 0bff203c43a9563489457a7900af8e3f, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 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: ed46b1131b03b860151155c605201e75, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 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: aa485c6c735b0ba2619512752ecbe180, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 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: 05f6c121423a4de6a39c45ee8e8a3829, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 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: 3ab67933846718060654f95c2ec5ad94, jobId: 4079f79b7a222ed542e614e97f7e6b18).
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-fcf319d5-c0e4-4c14-9587-10743fbe868c
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-bc3cc798-6cae-4355-a14b-945cf53e5a6b
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-df1ee043-3960-43f5-b43a-7e442111e85f
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 06, 2021 12:06:13 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:38187
Apr 06, 2021 12:06:13 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 33s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/pwhuqw25a54b6
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 #7036
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/7036/display/redirect?page=changes>
Changes:
[kileysok] Optimize reservoir sampling calculation
------------------------------------------
[...truncated 38.46 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": "oI0G2u/loKn/rZ8CsZmrroov456rroov",
"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": "4M4F7q+IyNm3r4gCw6Crroov96arroov",
"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-06T06:07:16.361Z Waiting for main pipeline to 'finish'
2021-04-06T06:07:16.361Z DONE SessionSideInputJoin
Apr 06, 2021 6:07:16 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: 777b3dfdfca6068feaca9bad09b71474, jobId: 70cb977effc03eca29d7a354ff848bd9).
2021-04-06T06:07:16.363Z 1 samples not enough to calculate steady-state event rate
Apr 06, 2021 6:07:16 AM org.apache.beam.sdk.testutils.metrics.MetricsReader getCounterMetric
SEVERE: Failed to get metric fatal, from namespace SessionSideInputJoin
Apr 06, 2021 6:07:16 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: 04d52a183681907bb2bf62d581b78f7a, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: 1933330cdb77cab14cf66c6a33163082, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: 9854675d6694e0d5bd72d2c96190e691, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: b2698a0c711cbbb9774e875a25e59b02, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: 9d4a8f63504b16243455f658ce4476b6, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: 5224497a38fc7fd5f5ea3a3d27f7198a, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: 5b33d09d09908792eed48d67dad9abfb, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: 2e219e934124eff9c2b6a656ec3bdf6a, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: c894128360802d449769d7b5d50d781d, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: c965bb85829c00e3213a98a42cfc16a2, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 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: 7361d4b79703fccb10fc60c046e2e73f, jobId: 70cb977effc03eca29d7a354ff848bd9).
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
INFO: Shut down complete.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent closeAsyncInternal
INFO: Closing components.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.dispatcher.Dispatcher terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl close
INFO: Closing the SlotManager.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl suspend
INFO: Suspending the SlotManager.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator shutDown
INFO: Shutting down back pressure request coordinator.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_58.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-io-9848896a-7c12-4ced-877e-1e7071613146
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-831b0b4d-d5b0-4d7b-8617-ddbc141188b2
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO: Shutting down the kvState service and its components.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory /tmp/flink-dist-cache-927cb53c-41b3-4d78-808b-44da0d105aed
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_56.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$7
INFO: Stopped Akka RPC service.
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Apr 06, 2021 6:07:16 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:43273
Apr 06, 2021 6:07:16 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 31s
112 actionable tasks: 2 executed, 110 up-to-date
Publishing build scan...
https://gradle.com/s/ylxeky2d5bhky
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