LiebingYu opened a new issue, #2832:
URL: https://github.com/apache/fluss/issues/2832

   ### Search before asking
   
   - [x] I searched in the [issues](https://github.com/apache/fluss/issues) and 
found nothing similar.
   
   
   ### Description
   
   **Current Situation:**
   
   `LakeTableHelper` stores the lake table snapshot offset file (used by Paimon 
tiering) to a remote path derived from the global `remote.data.dir` 
configuration, which is injected at construction time:
   
   ```java
   public LakeTableHelper(ZooKeeperClient zkClient, String remoteDataDir) {
       this.zkClient = zkClient;
       this.remoteDataDir = remoteDataDir;
   }
   ```
   
   `storeLakeTableOffsetsFile()` then builds the remote path using this fixed 
`remoteDataDir`:
   
   ```java
   public FsPath storeLakeTableOffsetsFile(TablePath tablePath, 
TableBucketOffsets offsets)
   ```
   
   With the introduction of multiple remote data directories 
(`remote.data.dirs`), each table is assigned its own `remoteDataDir` at 
creation time and persisted in `TableRegistration`. Using the global config 
here means the offset file is always written to `remote.data.dir`, regardless 
of which directory the table was actually assigned to. This is incorrect when 
the table's data resides in a different remote directory.
   
   ### Willingness to contribute
   
   - [x] I'm willing to submit a PR!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to