File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed
fluss-common/src/main/java/org/apache/fluss/config
fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/tiering Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -95,7 +95,7 @@ public Duration getDataLakeFreshness() {
9595 }
9696
9797 /** Whether auto compaction is enabled. */
98- public boolean getDataLakeAutoCompaction () {
98+ public boolean isDataLakeAutoCompactionEnabled () {
9999 return config .get (ConfigOptions .TABLE_DATALAKE_AUTO_COMPACTION );
100100 }
101101
Original file line number Diff line number Diff line change @@ -49,7 +49,10 @@ public PaimonLakeWriter(
4949 FileStoreTable fileStoreTable =
5050 getTable (
5151 writerInitContext .tablePath (),
52- writerInitContext .tableInfo ().getTableConfig ().getDataLakeAutoCompaction ());
52+ writerInitContext
53+ .tableInfo ()
54+ .getTableConfig ()
55+ .isDataLakeAutoCompactionEnabled ());
5356
5457 List <String > partitionKeys = fileStoreTable .partitionKeys ();
5558
You can’t perform that action at this time.
0 commit comments