Skip to content

Commit 13a21ad

Browse files
authored
Fix record count file non-existed issue (#1833)
1 parent 467bb3f commit 13a21ad

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

gobblin-compaction/src/main/java/gobblin/compaction/verify/CompactionThresholdVerifier.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package gobblin.compaction.verify;
22

3-
import avro.shaded.com.google.common.collect.Lists;
3+
4+
import com.google.common.collect.Lists;
45
import gobblin.compaction.conditions.RecompactionConditionBasedOnRatio;
56
import gobblin.compaction.mapreduce.MRCompactor;
67
import gobblin.compaction.parser.CompactionPathParser;

gobblin-compaction/src/main/java/gobblin/compaction/verify/InputRecordCountHelper.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ public long calculateRecordCount (Collection<Path> paths) throws IOException {
7777
* @return record count
7878
*/
7979
public static long readRecordCount (FileSystem fs, Path dir) throws IOException {
80-
if (!fs.exists(dir)) {
80+
if (!fs.exists(new Path(dir, RECORD_COUNT_FILE))) {
8181
return 0;
8282
}
8383

0 commit comments

Comments
 (0)