(fluss) branch main updated: [lake/tiering] fallback to Flink's `io.tmp.dir` when `client.scanner.io.tmpdir` is not set. (#2859)

[yuxia]

This is an automated email from the ASF dual-hosted git repository.

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new acd9632d9 [lake/tiering] fallback to Flink's `io.tmp.dir` when 
`client.scanner.io.tmpdir` is not set. (#2859)
acd9632d9 is described below

commit acd9632d9389a7cdd877ceea39b8df1cc7b8924a
Author: Junfan Zhang <zus...@apache.org>
AuthorDate: Fri Mar 13 15:13:44 2026 +0800

    [lake/tiering] fallback to Flink's `io.tmp.dir` when 
`client.scanner.io.tmpdir` is not set. (#2859)
    
    Co-authored-by: Junfan Zhang <zhangjun...@qiyi.com>
---
 .../java/org/apache/fluss/flink/tiering/source/TieringSource.java    | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/TieringSource.java
 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/TieringSource.java
index 04448c193..649b75870 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/TieringSource.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/TieringSource.java
@@ -44,7 +44,9 @@ import 
org.apache.flink.streaming.api.graph.StreamGraphHasherV2;
 
 import java.nio.charset.StandardCharsets;
 
+import static org.apache.fluss.config.ConfigOptions.CLIENT_SCANNER_IO_TMP_DIR;
 import static 
org.apache.fluss.flink.tiering.source.TieringSourceOptions.POLL_TIERING_TABLE_INTERVAL;
+import static 
org.apache.fluss.flink.utils.FlinkConnectorOptionsUtils.getClientScannerIoTmpDir;
 
 /**
  * The flink source implementation for tiering data from Fluss to downstream 
lake.
@@ -110,6 +112,9 @@ public class TieringSource<WriteResult>
             SourceReaderContext sourceReaderContext) {
         
FutureCompletingBlockingQueue<RecordsWithSplitIds<TableBucketWriteResult<WriteResult>>>
                 elementsQueue = new FutureCompletingBlockingQueue<>();
+        flussConf.set(
+                CLIENT_SCANNER_IO_TMP_DIR,
+                getClientScannerIoTmpDir(flussConf, 
sourceReaderContext.getConfiguration()));
         Connection connection = ConnectionFactory.createConnection(flussConf);
         return new TieringSourceReader<>(
                 elementsQueue, sourceReaderContext, connection, 
lakeTieringFactory);