-
-
Save zenhao/5f22ca084717bae3194555398dad332d to your computer and use it in GitHub Desktop.
flink-presto
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Starting Job Manager | |
| config file: | |
| jobmanager.rpc.address: fps-flink-jobmanager | |
| jobmanager.rpc.port: 6123 | |
| jobmanager.web.port: 8081 | |
| blob.server.port: 6124 | |
| query.server.port: 6125 | |
| jobmanager.heap.mb: 1024 | |
| taskmanager.heap.mb: 1024 | |
| taskmanager.memory.preallocate: false | |
| taskmanager.numberOfTaskSlots: 1 | |
| parallelism.default: 1 | |
| fs.hdfs.hadoopconf: /opt/flink_1.5.0/conf | |
| state.backend: rocksdb | |
| state.backend.fs.checkpointdir: s3://zendesk-usw2-fraud-prevention-staging/pod999/checkpoints/ | |
| state.checkpoints.dir: s3://zendesk-usw2-fraud-prevention-staging/pod999/checkpoints-meta/ | |
| state.savepoints.dir: s3://zendesk-usw2-fraud-prevention-staging/pod999/savepoints/ | |
| s3.access-key: xxx | |
| s3.secret-key: yyy | |
| s3.server-side-encryption-algorithm: AES256 | |
| s3.endpoint: s3.amazonaws.com | |
| taskmanager.log.path: /tmp/flink_logs/flink_console.log | |
| web.log.path: /tmp/flink_logs/flink_console.log | |
| akka.log.lifecycle.events: true | |
| high-availability: zookeeper | |
| high-availability.cluster-id: /flink | |
| high-availability.storageDir: s3://zendesk-usw2-fraud-prevention-staging/pod999/ha-recovery | |
| high-availability.zookeeper.quorum: zoo1.com:2181,zoo2.com:2181,zoo3.com:2181,zoo4.com:2181,zoo5.com:2181 | |
| high-availability.zookeeper.path.root: /fraud_prevention_service | |
| high-availability.jobmanager.port: 6123 | |
| metrics.scope.jm: fps.flink.jobmanager | |
| metrics.scope.tm: fps.flink.taskmanager | |
| metrics.scope.jm.job: fps.flink.jobmanager.job | |
| metrics.scope.tm.job: fps.flink.taskmanager.job | |
| metrics.scope.task: fps.flink.taskmanager.task | |
| metrics.scope.operator: fps.flink.taskmanager.operator | |
| metrics.reporters: dogstatsd | |
| metrics.reporter.dogstatsd.class: com.zendesk.fraud_prevention.metrics.DogStatsDReporter | |
| metrics.reporter.dogstatsd.lowercase: false | |
| metrics.reporter.dogstatsd.host: 169.254.1.1 | |
| metrics.reporter.dogstatsd.port: 8125 | |
| metrics.reporter.dogstatsd.tags: kube_namespace:pod999,kube_pod:fps-flink-jobmanager-2228349685-l4ht6,kube_project:fraud-prevention-service,kube_role:flink-jobmanager,pod:pod999 | |
| metrics.reporter.dogstatsd.verbose: false | |
| env.java.opts: -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=6235 -Dcom.sun.management.jmxremote.rmi.port=6235 -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.local.only=false -Dcom.sun.management.jmxremote.ssl=false -Djava.rmi.server.hostname=10.230.70.161 -XX:+UseG1GC -XX:+PrintAdaptiveSizePolicy -Dcom.amazonaws.services.s3.enableV4 | |
| taskmanager.exit-on-fatal-akka-error: true | |
| Starting standalonesession as a console application on host fps-flink-jobmanager-2228349685-l4ht6. | |
| 0.104: [G1Ergonomics (Heap Sizing) expand the heap, requested expansion amount: 1073741824 bytes, attempted expansion amount: 1073741824 bytes] | |
| Jun 05, 2018 6:05:29 PM sun.rmi.server.UnicastServerRef logCall | |
| FINER: RMI TCP Connection(1)-10.230.70.161: [10.230.70.161: sun.rmi.registry.RegistryImpl[0:0:0, 0]: void rebind(java.lang.String, java.rmi.Remote)] | |
| 2018-06-05 18:05:32,823 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -------------------------------------------------------------------------------- | |
| 2018-06-05 18:05:32,825 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting StandaloneSessionClusterEntrypoint (Version: 1.5.0, Rev:c61b108, Date:24.05.2018 @ 14:54:44 UTC) | |
| 2018-06-05 18:05:32,825 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - OS current user: flink | |
| 2018-06-05 18:05:35,911 INFO success: jobmanager entered RUNNING state, process has stayed up for > than 10 seconds (startsecs) | |
| 2018-06-05 18:05:35,911 INFO success: jstatd entered RUNNING state, process has stayed up for > than 10 seconds (startsecs) | |
| 2018-06-05 18:05:36,311 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable | |
| 2018-06-05 18:05:37,320 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Current Hadoop/Kerberos user: flink | |
| 2018-06-05 18:05:37,320 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.8/25.151-b12 | |
| 2018-06-05 18:05:37,320 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Maximum heap size: 1024 MiBytes | |
| 2018-06-05 18:05:37,320 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JAVA_HOME: /usr/lib/jvm/java-1.8-openjdk | |
| 2018-06-05 18:05:37,323 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Hadoop version: 2.7.3 | |
| 2018-06-05 18:05:37,323 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM Options: | |
| 2018-06-05 18:05:37,323 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Xms1024m | |
| 2018-06-05 18:05:37,323 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Xmx1024m | |
| 2018-06-05 18:05:37,323 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dcom.sun.management.jmxremote | |
| 2018-06-05 18:05:37,323 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dcom.sun.management.jmxremote.port=6235 | |
| 2018-06-05 18:05:37,323 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dcom.sun.management.jmxremote.rmi.port=6235 | |
| 2018-06-05 18:05:37,323 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dcom.sun.management.jmxremote.authenticate=false | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dcom.sun.management.jmxremote.local.only=false | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dcom.sun.management.jmxremote.ssl=false | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Djava.rmi.server.hostname=10.230.70.161 | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -XX:+UseG1GC | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -XX:+PrintAdaptiveSizePolicy | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dcom.amazonaws.services.s3.enableV4 | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dlog4j.configuration=file:/opt/flink_1.5.0/conf/log4j-console.properties | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dlogback.configurationFile=file:/opt/flink_1.5.0/conf/logback-console.xml | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Program Arguments: | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - --configDir | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - /opt/flink_1.5.0/conf | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - --executionMode | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - cluster | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - --host | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - cluster | |
| 2018-06-05 18:05:37,324 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Classpath: /opt/flink_1.5.0/lib/flink-libs-assembly-0.1.0.jar:/opt/flink_1.5.0/lib/flink-python_2.11-1.5.0.jar:/opt/flink_1.5.0/lib/flink-s3-fs-presto-1.5.0.jar:/opt/flink_1.5.0/lib/flink-shaded-hadoop2-uber-1.5.0.jar:/opt/flink_1.5.0/lib/log4j-1.2.17.jar:/opt/flink_1.5.0/lib/slf4j-log4j12-1.7.7.jar:/opt/flink_1.5.0/lib/flink-dist_2.11-1.5.0.jar::/opt/flink_1.5.0/conf: | |
| 2018-06-05 18:05:37,325 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -------------------------------------------------------------------------------- | |
| 2018-06-05 18:05:37,326 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Registered UNIX signal handlers for [TERM, HUP, INT] | |
| 2018-06-05 18:05:37,417 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.address, fps-flink-jobmanager | |
| 2018-06-05 18:05:37,417 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.port, 6123 | |
| 2018-06-05 18:05:37,417 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.web.port, 8081 | |
| 2018-06-05 18:05:37,418 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: blob.server.port, 6124 | |
| ..... | |
| 2018-06-05 18:12:46,880 INFO org.apache.flink.fs.s3presto.shaded.com.amazonaws.latency - ServiceName=[Amazon S3], AWSErrorCode=[AccessDenied], StatusCode=[403], ServiceEndpoint=[https://zendesk-usw2-fraud-prevention-staging.s3-us-west-2.amazonaws.com], Exception=[org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.model.AmazonS3Exception: Access Denied (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: C4DD98BC463B7A43), S3 Extended Request ID: xuya3hNhPy7Q8oJfbN1c2fz7Z4Y/dphYfEpVLwzhB4dMsz07iUwWWR4S713mN6xNNL9dgU0eYAc=], RequestType=[InitiateMultipartUploadRequest], AWSRequestID=[C4DD98BC463B7A43], HttpClientPoolPendingCount=0, RetryCapacityConsumed=0, HttpClientPoolAvailableCount=1, RequestCount=1, Exception=1, HttpClientPoolLeasedCount=0, ClientExecuteTime=[367.614], HttpClientSendRequestTime=[0.301], HttpRequestTime=[366.003], RequestSigningTime=[0.353], CredentialsRequestTime=[0.003, 0.002], HttpClientReceiveResponseTime=[100.213], | |
| 2018-06-05 18:12:46,885 ERROR org.apache.flink.runtime.blob.BlobServerConnection - PUT operation failed | |
| java.io.IOException: org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.model.AmazonS3Exception: Access Denied (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: C4DD98BC463B7A43), S3 Extended Request ID: xuya3hNhPy7Q8oJfbN1c2fz7Z4Y/dphYfEpVLwzhB4dMsz07iUwWWR4S713mN6xNNL9dgU0eYAc= | |
| at org.apache.flink.fs.s3presto.shaded.com.facebook.presto.hive.PrestoS3FileSystem$PrestoS3OutputStream.uploadObject(PrestoS3FileSystem.java:1036) | |
| at org.apache.flink.fs.s3presto.shaded.com.facebook.presto.hive.PrestoS3FileSystem$PrestoS3OutputStream.close(PrestoS3FileSystem.java:987) | |
| at org.apache.flink.fs.s3presto.shaded.org.apache.hadoop.fs.FSDataOutputStream$PositionCache.close(FSDataOutputStream.java:72) | |
| at org.apache.flink.fs.s3presto.shaded.org.apache.hadoop.fs.FSDataOutputStream.close(FSDataOutputStream.java:106) | |
| at org.apache.flink.fs.s3presto.shaded.org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream.close(HadoopDataOutputStream.java:52) | |
| at org.apache.flink.runtime.blob.FileSystemBlobStore.put(FileSystemBlobStore.java:76) | |
| at org.apache.flink.runtime.blob.FileSystemBlobStore.put(FileSystemBlobStore.java:69) | |
| at org.apache.flink.runtime.blob.BlobUtils.moveTempFileToStore(BlobUtils.java:443) | |
| at org.apache.flink.runtime.blob.BlobServer.moveTempFileToStore(BlobServer.java:707) | |
| at org.apache.flink.runtime.blob.BlobServerConnection.put(BlobServerConnection.java:351) | |
| at org.apache.flink.runtime.blob.BlobServerConnection.run(BlobServerConnection.java:114) | |
| Caused by: org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.model.AmazonS3Exception: Access Denied (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: C4DD98BC463B7A43), S3 Extended Request ID: xuya3hNhPy7Q8oJfbN1c2fz7Z4Y/dphYfEpVLwzhB4dMsz07iUwWWR4S713mN6xNNL9dgU0eYAc= | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1587) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1257) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1029) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:741) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:715) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:697) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:665) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:647) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:511) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:4227) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:4174) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.AmazonS3Client.initiateMultipartUpload(AmazonS3Client.java:3061) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadCallable.initiateMultipartUpload(UploadCallable.java:360) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadCallable.uploadInParts(UploadCallable.java:180) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadCallable.call(UploadCallable.java:123) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadMonitor.call(UploadMonitor.java:143) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadMonitor.call(UploadMonitor.java:48) | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| 2018-06-05 18:12:46,887 ERROR org.apache.flink.runtime.webmonitor.handlers.JarRunHandler - Exception occurred in REST handler. | |
| org.apache.flink.runtime.rest.handler.RestHandlerException: org.apache.flink.util.FlinkException: Could not upload job jar files. | |
| at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$3(JarRunHandler.java:141) | |
| at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870) | |
| at java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852) | |
| at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) | |
| at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1595) | |
| at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39) | |
| at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415) | |
| at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
| at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
| at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
| at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
| Caused by: java.util.concurrent.CompletionException: org.apache.flink.util.FlinkException: Could not upload job jar files. | |
| at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$0(JarRunHandler.java:121) | |
| at java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1105) | |
| at java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1070) | |
| ... 8 more | |
| Caused by: org.apache.flink.util.FlinkException: Could not upload job jar files. | |
| ... 11 more | |
| Caused by: java.io.IOException: PUT operation failed: Server side error: org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.model.AmazonS3Exception: Access Denied (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: C4DD98BC463B7A43), S3 Extended Request ID: xuya3hNhPy7Q8oJfbN1c2fz7Z4Y/dphYfEpVLwzhB4dMsz07iUwWWR4S713mN6xNNL9dgU0eYAc= | |
| at org.apache.flink.runtime.blob.BlobClient.putInputStream(BlobClient.java:445) | |
| at org.apache.flink.runtime.blob.BlobClient.uploadJarFiles(BlobClient.java:554) | |
| at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$0(JarRunHandler.java:119) | |
| ... 10 more | |
| Caused by: java.io.IOException: Server side error: org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.model.AmazonS3Exception: Access Denied (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: C4DD98BC463B7A43), S3 Extended Request ID: xuya3hNhPy7Q8oJfbN1c2fz7Z4Y/dphYfEpVLwzhB4dMsz07iUwWWR4S713mN6xNNL9dgU0eYAc= | |
| at org.apache.flink.runtime.blob.BlobClient.receiveAndCheckPutResponse(BlobClient.java:513) | |
| at org.apache.flink.runtime.blob.BlobClient.putInputStream(BlobClient.java:441) | |
| ... 12 more | |
| Caused by: java.io.IOException: org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.model.AmazonS3Exception: Access Denied (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: C4DD98BC463B7A43), S3 Extended Request ID: xuya3hNhPy7Q8oJfbN1c2fz7Z4Y/dphYfEpVLwzhB4dMsz07iUwWWR4S713mN6xNNL9dgU0eYAc= | |
| at org.apache.flink.fs.s3presto.shaded.com.facebook.presto.hive.PrestoS3FileSystem$PrestoS3OutputStream.uploadObject(PrestoS3FileSystem.java:1036) | |
| at org.apache.flink.fs.s3presto.shaded.com.facebook.presto.hive.PrestoS3FileSystem$PrestoS3OutputStream.close(PrestoS3FileSystem.java:987) | |
| at org.apache.flink.fs.s3presto.shaded.org.apache.hadoop.fs.FSDataOutputStream$PositionCache.close(FSDataOutputStream.java:72) | |
| at org.apache.flink.fs.s3presto.shaded.org.apache.hadoop.fs.FSDataOutputStream.close(FSDataOutputStream.java:106) | |
| at org.apache.flink.fs.s3presto.shaded.org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream.close(HadoopDataOutputStream.java:52) | |
| at org.apache.flink.runtime.blob.FileSystemBlobStore.put(FileSystemBlobStore.java:76) | |
| at org.apache.flink.runtime.blob.FileSystemBlobStore.put(FileSystemBlobStore.java:69) | |
| at org.apache.flink.runtime.blob.BlobUtils.moveTempFileToStore(BlobUtils.java:443) | |
| at org.apache.flink.runtime.blob.BlobServer.moveTempFileToStore(BlobServer.java:707) | |
| at org.apache.flink.runtime.blob.BlobServerConnection.put(BlobServerConnection.java:351) | |
| at org.apache.flink.runtime.blob.BlobServerConnection.run(BlobServerConnection.java:114) | |
| Caused by: org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.model.AmazonS3Exception: Access Denied (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: C4DD98BC463B7A43), S3 Extended Request ID: xuya3hNhPy7Q8oJfbN1c2fz7Z4Y/dphYfEpVLwzhB4dMsz07iUwWWR4S713mN6xNNL9dgU0eYAc= | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1587) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1257) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1029) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:741) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:715) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:697) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:665) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:647) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:511) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:4227) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:4174) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.AmazonS3Client.initiateMultipartUpload(AmazonS3Client.java:3061) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadCallable.initiateMultipartUpload(UploadCallable.java:360) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadCallable.uploadInParts(UploadCallable.java:180) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadCallable.call(UploadCallable.java:123) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadMonitor.call(UploadMonitor.java:143) | |
| at org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.transfer.internal.UploadMonitor.call(UploadMonitor.java:48) | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment