You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/29 16:07:00 UTC
[jira] [Closed] (FLINK-9012) Shaded Hadoop S3A end-to-end test
failing with S3 bucket in Ireland
[ https://issues.apache.org/jira/browse/FLINK-9012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Nico Kruber closed FLINK-9012.
------------------------------
Resolution: Cannot Reproduce
Fix Version/s: (was: 1.5.0)
Yes, I now tested locally and it was running fine with the same S3 settings. Maybe a temporary glitch with S3.
> Shaded Hadoop S3A end-to-end test failing with S3 bucket in Ireland
> -------------------------------------------------------------------
>
> Key: FLINK-9012
> URL: https://issues.apache.org/jira/browse/FLINK-9012
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 1.5.0
> Reporter: Nico Kruber
> Assignee: Nico Kruber
> Priority: Critical
> Labels: test-stability
>
> https://api.travis-ci.org/v3/job/354259892/log.txt
> {code}
> Found AWS bucket [secure], running Shaded Hadoop S3A e2e tests.
> Flink dist directory: /home/travis/build/NicoK/flink/build-target
> TEST_DATA_DIR: /home/travis/build/NicoK/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-05775180416
> % Total % Received % Xferd Average Speed Time Time Time Current
> Dload Upload Total Spent Left Speed
> 0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0
> 0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0
> 91 493 0 449 0 0 2476 0 --:--:-- --:--:-- --:--:-- 2467
> <?xml version="1.0" encoding="UTF-8"?>
> <Error><Code>TemporaryRedirect</Code><Message>Please re-send this request to the specified temporary endpoint. Continue to use the original request endpoint for future requests.</Message><Bucket>[secure]</Bucket><Endpoint>[secure].s3-eu-west-1.amazonaws.com</Endpoint><RequestId>1FCEC82C3EBF7C7E</RequestId><HostId>NG5dxnXQ0Y5mK2X/m3bU+Z7Fqt0mNVL2JsjyVjGZUmpDmNuBDfKJACh7VI6tCTYEZsw65W057lA=</HostId></Error>Starting cluster.
> Starting standalonesession daemon on host travis-job-087822e3-2f4c-46b7-b9bd-b6d4aba6136c.
> Starting taskexecutor daemon on host travis-job-087822e3-2f4c-46b7-b9bd-b6d4aba6136c.
> Dispatcher/TaskManagers are not yet up
> Waiting for dispatcher REST endpoint to come up...
> Dispatcher/TaskManagers are not yet up
> Waiting for dispatcher REST endpoint to come up...
> Dispatcher/TaskManagers are not yet up
> Waiting for dispatcher REST endpoint to come up...
> Dispatcher/TaskManagers are not yet up
> Waiting for dispatcher REST endpoint to come up...
> Dispatcher/TaskManagers are not yet up
> Waiting for dispatcher REST endpoint to come up...
> Waiting for dispatcher REST endpoint to come up...
> Dispatcher REST endpoint is up.
> Starting execution of program
> ------------------------------------------------------------
> The program finished with the following exception:
> org.apache.flink.client.program.ProgramInvocationException: Could not retrieve the execution result.
> at org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:246)
> at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:458)
> at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:446)
> at org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:62)
> at org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:86)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528)
> at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:420)
> at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:398)
> at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:780)
> at org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:274)
> at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:209)
> at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1019)
> at org.apache.flink.client.cli.CliFrontend.lambda$main$9(CliFrontend.java:1095)
> at java.security.AccessController.doPrivileged(Native Method)
> at javax.security.auth.Subject.doAs(Subject.java:422)
> at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836)
> at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
> at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1095)
> Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
> at org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$4(RestClusterClient.java:341)
> 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.postFire(CompletableFuture.java:561)
> at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:929)
> at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442)
> 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)
> Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.rest.util.RestClientException: [Internal server error.]
> at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
> at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
> at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911)
> at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:953)
> at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
> ... 4 more
> Caused by: org.apache.flink.runtime.rest.util.RestClientException: [Internal server error.]
> at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:226)
> at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:210)
> at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:952)
> ... 5 more
> sort: cannot read: /home/travis/build/NicoK/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-05775180416/out/wc_out*: No such file or directory
> sort: cannot read: /home/travis/build/NicoK/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-05775180416/out/wc_out*: No such file or directory
> /home/travis/build/NicoK/flink/flink-end-to-end-tests/test-scripts/common.sh: line 120: md5: command not found
> FAIL WordCountWithShadedS3A: Output hash mismatch. Got d41d8cd98f00b204e9800998ecf8427e, expected 72a690412be8928ba239c2da967328a5.
> head hexdump of actual:
> head: cannot open ‘/home/travis/build/NicoK/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-05775180416/out/wc_out*’ for reading: No such file or directory
> % Total % Received % Xferd Average Speed Time Time Time Current
> Dload Upload Total Spent Left Speed
> 0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0
> 100 449 0 449 0 0 3602 0 --:--:-- --:--:-- --:--:-- 3620
> <?xml version="1.0" encoding="UTF-8"?>
> <Error><Code>TemporaryRedirect</Code><Message>Please re-send this request to the specified temporary endpoint. Continue to use the original request endpoint for future requests.</Message><Bucket>[secure]</Bucket><Endpoint>[secure].s3-eu-west-1.amazonaws.com</Endpoint><RequestId>01EDA3E95EA237F2</RequestId><HostId>OqyELs/B3uJAp/WNTTJCb3MA8VwgxfPBEx8lqn68kckCo5DD3uETkAKbc4C472PqhURy9Ql8DrE=</HostId></Error>Stopping taskexecutor daemon (pid: 10657) on host travis-job-087822e3-2f4c-46b7-b9bd-b6d4aba6136c.
> Stopping standalonesession daemon (pid: 10342) on host travis-job-087822e3-2f4c-46b7-b9bd-b6d4aba6136c.
> rm: cannot remove ‘/home/travis/build/NicoK/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-05775180416’: No such file or directory
> One or more tests FAILED.
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)