[HUDI-2384] Change log file size config to long (#3577)
This commit is contained in:
@@ -292,7 +292,7 @@ public class HoodieStorageConfig extends HoodieConfig {
|
|||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
public Builder logFileMaxSize(int logFileSize) {
|
public Builder logFileMaxSize(long logFileSize) {
|
||||||
storageConfig.setValue(LOGFILE_MAX_SIZE, String.valueOf(logFileSize));
|
storageConfig.setValue(LOGFILE_MAX_SIZE, String.valueOf(logFileSize));
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1391,8 +1391,8 @@ public class HoodieWriteConfig extends HoodieConfig {
|
|||||||
return getInt(HoodieStorageConfig.LOGFILE_DATA_BLOCK_MAX_SIZE);
|
return getInt(HoodieStorageConfig.LOGFILE_DATA_BLOCK_MAX_SIZE);
|
||||||
}
|
}
|
||||||
|
|
||||||
public int getLogFileMaxSize() {
|
public long getLogFileMaxSize() {
|
||||||
return getInt(HoodieStorageConfig.LOGFILE_MAX_SIZE);
|
return getLong(HoodieStorageConfig.LOGFILE_MAX_SIZE);
|
||||||
}
|
}
|
||||||
|
|
||||||
public double getParquetCompressionRatio() {
|
public double getParquetCompressionRatio() {
|
||||||
|
|||||||
Reference in New Issue
Block a user