github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-03 04:11:44 +08:00
Code Issues Projects Releases Wiki Activity

S3 is removed from the parameter names in CloudImportJobTestCase.

Browse Source
This commit is contained in:
Szabolcs Vasas 2019-01-15 14:14:23 +01:00
parent 6b329762c2
commit 511d3f9565
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/test/org/apache/sqoop/cloud/CloudImportJobTestCase.java
View File

@ -170,17 +170,17 @@ protected void insertInputDataIntoTableForMerge(List<List<Object>> inputData) {
insertRecordsIntoTableWithColTypesAndNames(dataSet.getColumnNamesForMerge(), dataSet.getColumnTypesForMerge(), inputData); insertRecordsIntoTableWithColTypesAndNames(dataSet.getColumnNamesForMerge(), dataSet.getColumnTypesForMerge(), inputData);
} }
protected void failIfOutputFilePathContainingPatternExists(FileSystem s3Client, Path targetDirPath, String pattern) throws IOException { protected void failIfOutputFilePathContainingPatternExists(FileSystem cloudFileSystem, Path targetDirPath, String pattern) throws IOException {
List<Path> outputFilesWithPathContainingPattern = FileSystemUtil.findFilesWithPathContainingPattern(targetDirPath, List<Path> outputFilesWithPathContainingPattern = FileSystemUtil.findFilesWithPathContainingPattern(targetDirPath,
s3Client.getConf(), pattern); cloudFileSystem.getConf(), pattern);
if (outputFilesWithPathContainingPattern.size() != 0) { if (outputFilesWithPathContainingPattern.size() != 0) {
fail("No output file was expected with pattern" + pattern); fail("No output file was expected with pattern" + pattern);
} }
} }
protected void failIfOutputFilePathContainingPatternDoesNotExists(FileSystem s3Client, Path targetDirPath, String pattern) throws IOException { protected void failIfOutputFilePathContainingPatternDoesNotExists(FileSystem cloudFileSystem, Path targetDirPath, String pattern) throws IOException {
List<Path> outputFilesWithPathContainingPattern = FileSystemUtil.findFilesWithPathContainingPattern(targetDirPath, List<Path> outputFilesWithPathContainingPattern = FileSystemUtil.findFilesWithPathContainingPattern(targetDirPath,
s3Client.getConf(), pattern); cloudFileSystem.getConf(), pattern);
if (outputFilesWithPathContainingPattern.size() == 0) { if (outputFilesWithPathContainingPattern.size() == 0) {
fail("No output file was found with pattern" + pattern); fail("No output file was found with pattern" + pattern);
} }