Skip to content

Instantly share code, notes, and snippets.

@WonderBeat
Created June 28, 2023 11:31
Show Gist options
  • Save WonderBeat/6ba7210e32104b613b7898c484ab29bc to your computer and use it in GitHub Desktop.
Save WonderBeat/6ba7210e32104b613b7898c484ab29bc to your computer and use it in GitHub Desktop.
"Flink-RocksDBStateDataTransfer-thread-1" #570511 daemon prio=5 os_prio=0 cpu=40891.60ms elapsed=80173.33s tid=0x00007fb857d21000 nid=0x98839 waiting on condition [0x00007fb6b56f2000]
java.lang.Thread.State: TIMED_WAITING (sleeping)
at java.lang.Thread.sleep(java.base@11.0.18/Native Method)
at org.apache.hadoop.fs.s3a.Invoker.retryUntranslated(Invoker.java:441)
at org.apache.hadoop.fs.s3a.Invoker.retry(Invoker.java:318)
at org.apache.hadoop.fs.s3a.WriteOperationHelper.finalizeMultipartUpload(WriteOperationHelper.java:353)
at org.apache.hadoop.fs.s3a.WriteOperationHelper.completeMPUwithRetries(WriteOperationHelper.java:396)
at org.apache.hadoop.fs.s3a.S3ABlockOutputStream$MultiPartUpload.lambda$complete$1(S3ABlockOutputStream.java:886)
at org.apache.hadoop.fs.s3a.S3ABlockOutputStream$MultiPartUpload$$Lambda$2906/0x000000084099c440.apply(Unknown Source)
at org.apache.hadoop.fs.statistics.impl.IOStatisticsBinding.trackDurationOfInvocation(IOStatisticsBinding.java:464)
at org.apache.hadoop.fs.s3a.S3ABlockOutputStream$MultiPartUpload.complete(S3ABlockOutputStream.java:884)
at org.apache.hadoop.fs.s3a.S3ABlockOutputStream$MultiPartUpload.access$1200(S3ABlockOutputStream.java:691)
at org.apache.hadoop.fs.s3a.S3ABlockOutputStream.close(S3ABlockOutputStream.java:415)
at org.apache.hadoop.fs.FSDataOutputStream$PositionCache.close(FSDataOutputStream.java:77)
at org.apache.hadoop.fs.FSDataOutputStream.close(FSDataOutputStream.java:106)
at org.apache.flink.fs.s3hadoop.common.HadoopDataOutputStream.close(HadoopDataOutputStream.java:52)
at org.apache.flink.core.fs.ClosingFSDataOutputStream.close(ClosingFSDataOutputStream.java:64)
at org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory$FsCheckpointStateOutputStream.closeAndGetHandle(FsCheckpointStreamFactory.java:406)
- locked <0x00000000e2038e90> (a org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory$FsCheckpointStateOutputStream)
at org.apache.flink.contrib.streaming.state.RocksDBStateUploader.uploadLocalFileToCheckpointFs(RocksDBStateUploader.java:147)
at org.apache.flink.contrib.streaming.state.RocksDBStateUploader.lambda$createUploadFutures$0(RocksDBStateUploader.java:105)
at org.apache.flink.contrib.streaming.state.RocksDBStateUploader$$Lambda$2828/0x00000008409dd840.get(Unknown Source)
at org.apache.flink.util.function.CheckedSupplier.lambda$unchecked$0(CheckedSupplier.java:32)
at org.apache.flink.util.function.CheckedSupplier$$Lambda$2829/0x00000008409ddc40.get(Unknown Source)
at java.util.concurrent.CompletableFuture$AsyncSupply.run(java.base@11.0.18/Unknown Source)
at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.18/Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.18/Unknown Source)
at java.lang.Thread.run(java.base@11.0.18/Unknown Source)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment