[ 
https://issues.apache.org/jira/browse/FLINK-16633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Robert Metzger resolved FLINK-16633.
------------------------------------
    Fix Version/s: 1.11.0
       Resolution: Fixed

Resolved in master in b226cbd1f595b405f5da376fa3d22e1850fbf4e1

> CI builds without S3 credentials fail
> -------------------------------------
>
>                 Key: FLINK-16633
>                 URL: https://issues.apache.org/jira/browse/FLINK-16633
>             Project: Flink
>          Issue Type: Bug
>          Components: Build System / Azure Pipelines, FileSystems
>    Affects Versions: 1.11.0
>            Reporter: Robert Metzger
>            Assignee: Robert Metzger
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.11.0
>
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> Pull request builds on Azure don't have access to the S3 credentials (through 
> environment variables).
> They fail with the following errors:
> {code}
> 2020-03-17T02:42:24.4186165Z [ERROR] Tests run: 7, Failures: 0, Errors: 7, 
> Skipped: 0, Time elapsed: 0.645 s <<< FAILURE! - in 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase
> 2020-03-17T02:42:24.4187582Z [ERROR] 
> testResumeAfterCommit(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase)
>   Time elapsed: 0.11 s  <<< ERROR!
> 2020-03-17T02:42:24.4188593Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4189408Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4190152Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.prepare(HadoopS3RecoverableWriterExceptionITCase.java:120)
> 2020-03-17T02:42:24.4190798Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4191529Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4192258Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.prepare(HadoopS3RecoverableWriterExceptionITCase.java:120)
> 2020-03-17T02:42:24.4192689Z 
> 2020-03-17T02:42:24.4193119Z [ERROR] 
> testResumeAfterCommit(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase)
>   Time elapsed: 0.11 s  <<< ERROR!
> 2020-03-17T02:42:24.4193704Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4194461Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4195299Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.cleanup(HadoopS3RecoverableWriterExceptionITCase.java:130)
> 2020-03-17T02:42:24.4195945Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4196588Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4197307Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.cleanup(HadoopS3RecoverableWriterExceptionITCase.java:130)
> 2020-03-17T02:42:24.4197697Z 
> 2020-03-17T02:42:24.4198135Z [ERROR] 
> testResumeWithWrongOffset(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4198791Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4199755Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4200466Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.prepare(HadoopS3RecoverableWriterExceptionITCase.java:120)
> 2020-03-17T02:42:24.4201169Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4201834Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4202578Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.prepare(HadoopS3RecoverableWriterExceptionITCase.java:120)
> 2020-03-17T02:42:24.4203010Z 
> 2020-03-17T02:42:24.4203579Z [ERROR] 
> testResumeWithWrongOffset(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:24.4204201Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4204884Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4205769Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.cleanup(HadoopS3RecoverableWriterExceptionITCase.java:130)
> 2020-03-17T02:42:24.4206387Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4207038Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4207731Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.cleanup(HadoopS3RecoverableWriterExceptionITCase.java:130)
> 2020-03-17T02:42:24.4208128Z 
> 2020-03-17T02:42:24.4208574Z [ERROR] 
> testExceptionWritingAfterCloseForCommit(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4209199Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4209846Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4210561Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.prepare(HadoopS3RecoverableWriterExceptionITCase.java:120)
> 2020-03-17T02:42:24.4211262Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4211909Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4212667Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.prepare(HadoopS3RecoverableWriterExceptionITCase.java:120)
> 2020-03-17T02:42:24.4213270Z 
> 2020-03-17T02:42:24.4213976Z [ERROR] 
> testExceptionWritingAfterCloseForCommit(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:24.4215187Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4216174Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4217335Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.cleanup(HadoopS3RecoverableWriterExceptionITCase.java:130)
> 2020-03-17T02:42:24.4218162Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4218811Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4219751Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.cleanup(HadoopS3RecoverableWriterExceptionITCase.java:130)
> 2020-03-17T02:42:24.4220133Z 
> 2020-03-17T02:42:24.4220524Z [ERROR] 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase  Time 
> elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:24.4221167Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4221776Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4222539Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.cleanUp(HadoopS3RecoverableWriterExceptionITCase.java:109)
> 2020-03-17T02:42:24.4223186Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4223818Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.getFileSystem(HadoopS3RecoverableWriterExceptionITCase.java:135)
> 2020-03-17T02:42:24.4224649Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterExceptionITCase.cleanUp(HadoopS3RecoverableWriterExceptionITCase.java:109)
> 2020-03-17T02:42:24.4225138Z 
> 2020-03-17T02:42:24.4244002Z [ERROR] Tests run: 16, Failures: 0, Errors: 16, 
> Skipped: 0, Time elapsed: 0.651 s <<< FAILURE! - in 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase
> 2020-03-17T02:42:24.4245484Z [ERROR] 
> testMkdirsReturnsTrueWhenCreatingDirectory(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.106 s  <<< ERROR!
> 2020-03-17T02:42:24.4246427Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4247410Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4248029Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4248676Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4249045Z 
> 2020-03-17T02:42:24.4249509Z [ERROR] 
> testMkdirsReturnsTrueWhenCreatingDirectory(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.106 s  <<< ERROR!
> 2020-03-17T02:42:24.4250207Z java.lang.NullPointerException
> 2020-03-17T02:42:24.4250371Z 
> 2020-03-17T02:42:24.4250811Z [ERROR] 
> testMkdirsFailsWithExistingParentFile(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4251528Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4252098Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4252769Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4253384Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4253748Z 
> 2020-03-17T02:42:24.4254188Z [ERROR] 
> testMkdirsFailsWithExistingParentFile(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4254773Z java.lang.NullPointerException
> 2020-03-17T02:42:24.4254946Z 
> 2020-03-17T02:42:24.4255377Z [ERROR] 
> testMkdirsReturnsTrueForExistingDirectory(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4255992Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4256640Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4257238Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4258010Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4258381Z 
> 2020-03-17T02:42:24.4258794Z [ERROR] 
> testMkdirsReturnsTrueForExistingDirectory(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4259265Z java.lang.NullPointerException
> 2020-03-17T02:42:24.4259476Z 
> 2020-03-17T02:42:24.4260069Z [ERROR] 
> testPathAndScheme(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4260921Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4261716Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4262355Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4262963Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4263450Z 
> 2020-03-17T02:42:24.4263844Z [ERROR] 
> testPathAndScheme(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4264260Z java.lang.NullPointerException
> 2020-03-17T02:42:24.4264413Z 
> 2020-03-17T02:42:24.4265143Z [ERROR] 
> testHomeAndWorkDir(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4266031Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4267039Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4267981Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4268921Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4269308Z 
> 2020-03-17T02:42:24.4269695Z [ERROR] 
> testHomeAndWorkDir(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4270133Z java.lang.NullPointerException
> 2020-03-17T02:42:24.4270288Z 
> 2020-03-17T02:42:24.4270655Z [ERROR] 
> testFileSystemKind(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4271303Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4271841Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4272728Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4273341Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4273698Z 
> 2020-03-17T02:42:24.4274064Z [ERROR] 
> testFileSystemKind(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4274498Z java.lang.NullPointerException
> 2020-03-17T02:42:24.4274765Z 
> 2020-03-17T02:42:24.4275176Z [ERROR] 
> testMkdirsFailsForExistingFile(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4275736Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4276290Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4276995Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4277768Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4278112Z 
> 2020-03-17T02:42:24.4278526Z [ERROR] 
> testMkdirsFailsForExistingFile(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4278971Z java.lang.NullPointerException
> 2020-03-17T02:42:24.4279123Z 
> 2020-03-17T02:42:24.4279553Z [ERROR] 
> testMkdirsCreatesParentDirectories(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4280192Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:24.4280730Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4281383Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:24.4281969Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase.getFileSystem(HadoopS3FileSystemBehaviorITCase.java:60)
> 2020-03-17T02:42:24.4282377Z 
> 2020-03-17T02:42:24.4282797Z [ERROR] 
> testMkdirsCreatesParentDirectories(org.apache.flink.fs.s3hadoop.HadoopS3FileSystemBehaviorITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:24.4283358Z java.lang.NullPointerException
> 2020-03-17T02:42:24.4283511Z 
> 2020-03-17T02:42:24.6650046Z [INFO] Running 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemITCase
> 2020-03-17T02:42:24.9808490Z [INFO] Running 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase
> 2020-03-17T02:42:25.2595666Z [ERROR] Tests run: 1, Failures: 0, Errors: 1, 
> Skipped: 0, Time elapsed: 0.593 s <<< FAILURE! - in 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemITCase
> 2020-03-17T02:42:25.2596561Z [ERROR] 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemITCase  Time elapsed: 0.593 s  
> <<< ERROR!
> 2020-03-17T02:42:25.2597100Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.2597675Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemITCase.setup(HadoopS3FileSystemITCase.java:55)
> 2020-03-17T02:42:25.2598249Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.2598841Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3FileSystemITCase.setup(HadoopS3FileSystemITCase.java:55)
> 2020-03-17T02:42:25.2599168Z 
> 2020-03-17T02:42:25.6533694Z [ERROR] Tests run: 27, Failures: 0, Errors: 27, 
> Skipped: 0, Time elapsed: 0.668 s <<< FAILURE! - in 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase
> 2020-03-17T02:42:25.6534735Z [ERROR] 
> testCloseWithNoData(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.108 s  <<< ERROR!
> 2020-03-17T02:42:25.6535359Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6535930Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6536575Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6537219Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6537792Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6538384Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6539009Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6539642Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6540175Z 
> 2020-03-17T02:42:25.6540552Z [ERROR] 
> testCloseWithNoData(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.109 s  <<< ERROR!
> 2020-03-17T02:42:25.6541479Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6542046Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6542681Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6543303Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6543886Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6544668Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6545075Z 
> 2020-03-17T02:42:25.6545467Z [ERROR] 
> testCommitAfterPersist(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6546001Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6546671Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6547289Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6547916Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6548470Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6549054Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6549675Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6550350Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6550693Z 
> 2020-03-17T02:42:25.6551139Z [ERROR] 
> testCommitAfterPersist(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6551684Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6552224Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6552850Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6553467Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6554044Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6554948Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6555325Z 
> 2020-03-17T02:42:25.6555730Z [ERROR] 
> testRecoverWithEmptyState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6556276Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6556825Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6557467Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6558074Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6558750Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6559330Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6559962Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6560614Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6560961Z 
> 2020-03-17T02:42:25.6561429Z [ERROR] 
> testRecoverWithEmptyState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6561994Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6562533Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6563183Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6563849Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6564454Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6565279Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6565667Z 
> 2020-03-17T02:42:25.6566084Z [ERROR] 
> testRecoverFromIntermWithoutAdditionalState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6566671Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6567202Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6567836Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6568450Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6569032Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6569621Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6570675Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6571362Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6571694Z 
> 2020-03-17T02:42:25.6572114Z [ERROR] 
> testRecoverFromIntermWithoutAdditionalState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6572712Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6573269Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6573904Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6574650Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6575262Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6575918Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6576389Z 
> 2020-03-17T02:42:25.6576854Z [ERROR] 
> testCallingDeleteObjectTwiceDoesNotThroughException(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6577466Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6578013Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6578636Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6579255Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6579817Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6580473Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6581140Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6581834Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6582161Z 
> 2020-03-17T02:42:25.6582616Z [ERROR] 
> testCallingDeleteObjectTwiceDoesNotThroughException(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6583207Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6583764Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6584393Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6585170Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6585780Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6586416Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6586789Z 
> 2020-03-17T02:42:25.6587189Z [ERROR] 
> testCommitAfterNormalClose(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6587737Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6588271Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6588902Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6589516Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6590121Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6590703Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6591389Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6591996Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6592343Z 
> 2020-03-17T02:42:25.6592733Z [ERROR] 
> testCommitAfterNormalClose(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6593375Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6593904Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6594693Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6595335Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6595920Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6596553Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6596930Z 
> 2020-03-17T02:42:25.6597326Z [ERROR] 
> testRecoverWithStateWithMultiPart(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6597899Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6598574Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6599207Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6599814Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6600443Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6601091Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6601701Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6602336Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6602667Z 
> 2020-03-17T02:42:25.6603066Z [ERROR] 
> testRecoverWithStateWithMultiPart(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6603646Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6604188Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6604982Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6605599Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6606174Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6606826Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6607207Z 
> 2020-03-17T02:42:25.6607663Z [ERROR] 
> testRecoverFromIntermWithoutAdditionalStateWithMultiPart(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:25.6608277Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6608827Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6609437Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6610075Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6610733Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6611378Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6611992Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6612600Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6612925Z 
> 2020-03-17T02:42:25.6613378Z [ERROR] 
> testRecoverFromIntermWithoutAdditionalStateWithMultiPart(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6613979Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6614617Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6615320Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6616048Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6616634Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6617264Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6617636Z 
> 2020-03-17T02:42:25.6618025Z [ERROR] 
> testRecoverWithState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:25.6618565Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6619104Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6619746Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6620404Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6620980Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6621597Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6622229Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6622827Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6623172Z 
> 2020-03-17T02:42:25.6623550Z [ERROR] 
> testRecoverWithState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:25.6624108Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6624780Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6625433Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6626040Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6626633Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6627265Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6627725Z 
> 2020-03-17T02:42:25.6628117Z [ERROR] 
> testCleanupRecoverableState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6628686Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6629217Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6629848Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6630504Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6631134Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6631732Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6632346Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6633035Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6633373Z 
> 2020-03-17T02:42:25.6633768Z [ERROR] 
> testCleanupRecoverableState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6634337Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6635068Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6635709Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6636335Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6636913Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6637578Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6638019Z 
> 2020-03-17T02:42:25.6638426Z [ERROR] 
> testCommitAfterRecovery(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6638976Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6639529Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6640196Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6640822Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6641442Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6642030Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6642665Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6643276Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6643613Z 
> 2020-03-17T02:42:25.6644010Z [ERROR] 
> testCommitAfterRecovery(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6644720Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6645275Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6645932Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6646533Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6647134Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6647762Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6648139Z 
> 2020-03-17T02:42:25.6648547Z [ERROR] 
> testRecoverAfterMultiplePersistsState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:25.6649134Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6649666Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6650421Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6651076Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6651658Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6652239Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6652879Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6653483Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6653826Z 
> 2020-03-17T02:42:25.6654233Z [ERROR] 
> testRecoverAfterMultiplePersistsState(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.001 s  <<< ERROR!
> 2020-03-17T02:42:25.6654916Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6655451Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6656110Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6656709Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6657292Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6657950Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6658328Z 
> 2020-03-17T02:42:25.6658760Z [ERROR] 
> testRecoverAfterMultiplePersistsStateWithMultiPart(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6659377Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6659905Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6660590Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6661269Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6661911Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6662500Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6663118Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupLocalDir(HadoopS3RecoverableWriterITCase.java:138)
> 2020-03-17T02:42:25.6663741Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.prepare(HadoopS3RecoverableWriterITCase.java:134)
> 2020-03-17T02:42:25.6664076Z 
> 2020-03-17T02:42:25.6664607Z [ERROR] 
> testRecoverAfterMultiplePersistsStateWithMultiPart(org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase)
>   Time elapsed: 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6665213Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6665753Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6666406Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6667094Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6667679Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6668327Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanupAndCheckTmpCleanup(HadoopS3RecoverableWriterITCase.java:158)
> 2020-03-17T02:42:25.6668690Z 
> 2020-03-17T02:42:25.6669029Z [ERROR] 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase  Time elapsed: 
> 0.002 s  <<< ERROR!
> 2020-03-17T02:42:25.6669521Z java.io.IOException: null uri host. This can be 
> caused by unencoded / in the password string
> 2020-03-17T02:42:25.6670091Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6670733Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanUp(HadoopS3RecoverableWriterITCase.java:123)
> 2020-03-17T02:42:25.6671361Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T02:42:25.6671927Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.getFileSystem(HadoopS3RecoverableWriterITCase.java:174)
> 2020-03-17T02:42:25.6672555Z  at 
> org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.cleanUp(HadoopS3RecoverableWriterITCase.java:123){code}
> Also, the end 2 end tests are failing:
> {code}
> 2020-03-17T03:46:29.1079571Z 
> 2020-03-17T03:46:29.1084340Z 
> org.apache.flink.client.program.ProgramInvocationException: The main method 
> caused an error: java.util.concurrent.ExecutionException: 
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit 
> JobGraph.
> 2020-03-17T03:46:29.1085345Z  at 
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:335)
> 2020-03-17T03:46:29.1086049Z  at 
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:205)
> 2020-03-17T03:46:29.1086659Z  at 
> org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:142)
> 2020-03-17T03:46:29.1088954Z  at 
> org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:664)
> 2020-03-17T03:46:29.1092911Z  at 
> org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:213)
> 2020-03-17T03:46:29.1093723Z  at 
> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:895)
> 2020-03-17T03:46:29.1095120Z  at 
> org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:968)
> 2020-03-17T03:46:29.1095752Z  at 
> java.security.AccessController.doPrivileged(Native Method)
> 2020-03-17T03:46:29.1096250Z  at 
> javax.security.auth.Subject.doAs(Subject.java:422)
> 2020-03-17T03:46:29.1096804Z  at 
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836)
> 2020-03-17T03:46:29.1097517Z  at 
> org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
> 2020-03-17T03:46:29.1098167Z  at 
> org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:968)
> 2020-03-17T03:46:29.1098932Z Caused by: java.lang.RuntimeException: 
> java.util.concurrent.ExecutionException: 
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit 
> JobGraph.
> 2020-03-17T03:46:29.1099822Z  at 
> org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:199)
> 2020-03-17T03:46:29.1100632Z  at 
> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1741)
> 2020-03-17T03:46:29.1101367Z  at 
> org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:90)
> 2020-03-17T03:46:29.1102043Z  at 
> org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:58)
> 2020-03-17T03:46:29.1102869Z  at 
> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1620)
> 2020-03-17T03:46:29.1103466Z  at 
> StreamingFileSinkProgram.main(StreamingFileSinkProgram.java:77)
> 2020-03-17T03:46:29.1103948Z  at 
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2020-03-17T03:46:29.1104447Z  at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2020-03-17T03:46:29.1105005Z  at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2020-03-17T03:46:29.1105525Z  at 
> java.lang.reflect.Method.invoke(Method.java:498)
> 2020-03-17T03:46:29.1106030Z  at 
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:321)
> 2020-03-17T03:46:29.1106468Z  ... 11 more
> 2020-03-17T03:46:29.1106966Z Caused by: 
> java.util.concurrent.ExecutionException: 
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit 
> JobGraph.
> 2020-03-17T03:46:29.1107615Z  at 
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2020-03-17T03:46:29.1108421Z  at 
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> 2020-03-17T03:46:29.1109196Z  at 
> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1736)
> 2020-03-17T03:46:29.1109706Z  ... 20 more
> 2020-03-17T03:46:29.1110142Z Caused by: 
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit 
> JobGraph.
> 2020-03-17T03:46:29.1110767Z  at 
> org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$7(RestClusterClient.java:359)
> 2020-03-17T03:46:29.1111370Z  at 
> java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884)
> 2020-03-17T03:46:29.1111969Z  at 
> java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:866)
> 2020-03-17T03:46:29.1112556Z  at 
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2020-03-17T03:46:29.1113126Z  at 
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> 2020-03-17T03:46:29.1114124Z  at 
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:274)
> 2020-03-17T03:46:29.1114670Z  at 
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2020-03-17T03:46:29.1115820Z  at 
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2020-03-17T03:46:29.1116298Z  at 
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2020-03-17T03:46:29.1116730Z  at 
> java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
> 2020-03-17T03:46:29.1117188Z  at 
> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:943)
> 2020-03-17T03:46:29.1117642Z  at 
> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
> 2020-03-17T03:46:29.1118099Z  at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2020-03-17T03:46:29.1118537Z  at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-03-17T03:46:29.1118915Z  at java.lang.Thread.run(Thread.java:748)
> 2020-03-17T03:46:29.1119564Z Caused by: 
> org.apache.flink.runtime.rest.util.RestClientException: [Internal server 
> error., <Exception on server side:
> 2020-03-17T03:46:29.1120091Z 
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit job.
> 2020-03-17T03:46:29.1120568Z  at 
> org.apache.flink.runtime.dispatcher.Dispatcher.lambda$internalSubmitJob$3(Dispatcher.java:336)
> 2020-03-17T03:46:29.1121079Z  at 
> java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
> 2020-03-17T03:46:29.1122414Z  at 
> java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
> 2020-03-17T03:46:29.1122937Z  at 
> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
> 2020-03-17T03:46:29.1123372Z  at 
> akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
> 2020-03-17T03:46:29.1123965Z  at 
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
> 2020-03-17T03:46:29.1124442Z  at 
> akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> 2020-03-17T03:46:29.1124852Z  at 
> akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> 2020-03-17T03:46:29.1125279Z  at 
> akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> 2020-03-17T03:46:29.1125691Z  at 
> akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> 2020-03-17T03:46:29.1126205Z Caused by: java.lang.RuntimeException: 
> org.apache.flink.runtime.client.JobExecutionException: Could not set up 
> JobManager
> 2020-03-17T03:46:29.1126730Z  at 
> org.apache.flink.util.function.CheckedSupplier.lambda$unchecked$0(CheckedSupplier.java:36)
> 2020-03-17T03:46:29.1127210Z  at 
> java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
> 2020-03-17T03:46:29.1127512Z  ... 6 more
> 2020-03-17T03:46:29.1127830Z Caused by: 
> org.apache.flink.runtime.client.JobExecutionException: Could not set up 
> JobManager
> 2020-03-17T03:46:29.1128573Z  at 
> org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.<init>(JobManagerRunnerImpl.java:152)
> 2020-03-17T03:46:29.1129303Z  at 
> org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:84)
> 2020-03-17T03:46:29.1129881Z  at 
> org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$6(Dispatcher.java:379)
> 2020-03-17T03:46:29.1130394Z  at 
> org.apache.flink.util.function.CheckedSupplier.lambda$unchecked$0(CheckedSupplier.java:34)
> 2020-03-17T03:46:29.1130710Z  ... 7 more
> 2020-03-17T03:46:29.1131072Z Caused by: 
> org.apache.flink.util.FlinkRuntimeException: Failed to create checkpoint 
> storage at checkpoint coordinator side.
> 2020-03-17T03:46:29.1131593Z  at 
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.<init>(CheckpointCoordinator.java:301)
> 2020-03-17T03:46:29.1132112Z  at 
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.<init>(CheckpointCoordinator.java:220)
> 2020-03-17T03:46:29.1132772Z  at 
> org.apache.flink.runtime.executiongraph.ExecutionGraph.enableCheckpointing(ExecutionGraph.java:490)
> 2020-03-17T03:46:29.1133357Z  at 
> org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder.buildGraph(ExecutionGraphBuilder.java:338)
> 2020-03-17T03:46:29.1133916Z  at 
> org.apache.flink.runtime.scheduler.SchedulerBase.createExecutionGraph(SchedulerBase.java:263)
> 2020-03-17T03:46:29.1134458Z  at 
> org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:235)
> 2020-03-17T03:46:29.1134986Z  at 
> org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:223)
> 2020-03-17T03:46:29.1135581Z  at 
> org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:118)
> 2020-03-17T03:46:29.1136099Z  at 
> org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:103)
> 2020-03-17T03:46:29.1136589Z  at 
> org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:281)
> 2020-03-17T03:46:29.1137028Z  at 
> org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:269)
> 2020-03-17T03:46:29.1137573Z  at 
> org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:98)
> 2020-03-17T03:46:29.1138251Z  at 
> org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:40)
> 2020-03-17T03:46:29.1138826Z  at 
> org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.<init>(JobManagerRunnerImpl.java:146)
> 2020-03-17T03:46:29.1139163Z  ... 10 more
> 2020-03-17T03:46:29.1139470Z Caused by: java.io.IOException: null uri host. 
> This can be caused by unencoded / in the password string
> 2020-03-17T03:46:29.1140143Z  at 
> org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory.create(AbstractS3FileSystemFactory.java:163)
> 2020-03-17T03:46:29.1140672Z  at 
> org.apache.flink.core.fs.PluginFileSystemFactory.create(PluginFileSystemFactory.java:61)
> 2020-03-17T03:46:29.1141170Z  at 
> org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(FileSystem.java:468)
> 2020-03-17T03:46:29.1141618Z  at 
> org.apache.flink.core.fs.FileSystem.get(FileSystem.java:389)
> 2020-03-17T03:46:29.1142008Z  at 
> org.apache.flink.core.fs.Path.getFileSystem(Path.java:298)
> 2020-03-17T03:46:29.1142644Z  at 
> org.apache.flink.runtime.state.memory.MemoryBackendCheckpointStorage.<init>(MemoryBackendCheckpointStorage.java:85)
> 2020-03-17T03:46:29.1143267Z  at 
> org.apache.flink.runtime.state.memory.MemoryStateBackend.createCheckpointStorage(MemoryStateBackend.java:295)
> 2020-03-17T03:46:29.1144068Z  at 
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.<init>(CheckpointCoordinator.java:298)
> 2020-03-17T03:46:29.1144448Z  ... 23 more
> 2020-03-17T03:46:29.1144843Z Caused by: java.lang.NullPointerException: null 
> uri host. This can be caused by unencoded / in the password string
> 2020-03-17T03:46:29.1145321Z  at 
> java.util.Objects.requireNonNull(Objects.java:228)
> 2020-03-17T03:46:29.1145777Z  at 
> org.apache.hadoop.fs.s3native.S3xLoginHelper.buildFSURI(S3xLoginHelper.java:69)
> 2020-03-17T03:46:29.1146355Z  at 
> org.apache.hadoop.fs.s3a.S3AFileSystem.setUri(S3AFileSystem.java:467)
> 2020-03-17T03:46:29.1147156Z  at 
> org.apache.hadoop.fs.s3a.S3AFileSystem.initialize(S3AFileSystem.java:234)
> 2020-03-17T03:46:29.1148468Z  at 
> org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory.create(AbstractS3FileSystemFactory.java:126)
> 2020-03-17T03:46:29.1148901Z  ... 30 more
> 2020-03-17T03:46:29.1149032Z 
> 2020-03-17T03:46:29.1149237Z End of exception on server side>]
> 2020-03-17T03:46:29.1149603Z  at 
> org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:390)
> 2020-03-17T03:46:29.1150123Z  at 
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:374)
> 2020-03-17T03:46:29.1150761Z  at 
> java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:966)
> 2020-03-17T03:46:29.1151980Z  at 
> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
> 2020-03-17T03:46:29.1156319Z  ... 4 more
> 2020-03-17T03:46:29.1288717Z Job could not be submitted.
> 2020-03-17T03:46:29.8870683Z 
> 2020-03-17T03:46:30.6358869Z rm: cannot remove 
> '/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-shaded-netty-tcnative-static-*.jar':
>  No such file or directory
> 2020-03-17T03:46:30.8096233Z 
> ad0803bd62b2c6245dcfc51f4a5345bf69f56d60c1bc4827792dda44f72164f0
> 2020-03-17T03:46:30.8578725Z 
> ad0803bd62b2c6245dcfc51f4a5345bf69f56d60c1bc4827792dda44f72164f0
> 2020-03-17T03:46:30.8607224Z [FAIL] Test script contains errors.
> 2020-03-17T03:46:30.8614963Z Checking of logs skipped.
> 2020-03-17T03:46:30.8615321Z 
> 2020-03-17T03:46:30.8616405Z [FAIL] 'Streaming File Sink s3 end-to-end test' 
> failed after 0 minutes and 42 seconds! Test exited with exit code 1
> {code}
> The YARN tests are also affected
> {code}
> [ERROR] Tests run: 2, Failures: 0, Errors: 2, Skipped: 0, Time elapsed: 1.156 
> s <<< FAILURE! - in org.apache.flink.yarn.YarnFileStageTestS3ITCase
> [ERROR] 
> testRecursiveUploadForYarnS3a(org.apache.flink.yarn.YarnFileStageTestS3ITCase)
>   Time elapsed: 0.592 s  <<< ERROR!
> java.io.IOException: Cannot instantiate file system for URI: 
> s3a://$(IT_CASE_S3_BUCKET)/temp/tests-e694ca1f-5578-4b67-b936-7db933e35da0
>       at 
> org.apache.flink.yarn.YarnFileStageTestS3ITCase.testRecursiveUploadForYarn(YarnFileStageTestS3ITCase.java:159)
>       at 
> org.apache.flink.yarn.YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3a(YarnFileStageTestS3ITCase.java:199)
> Caused by: java.lang.NullPointerException: null uri host. This can be caused 
> by unencoded / in the password string
>       at 
> org.apache.flink.yarn.YarnFileStageTestS3ITCase.testRecursiveUploadForYarn(YarnFileStageTestS3ITCase.java:159)
>       at 
> org.apache.flink.yarn.YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3a(YarnFileStageTestS3ITCase.java:199)
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to