File tree Expand file tree Collapse file tree 2 files changed +10
-0
lines changed
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner Expand file tree Collapse file tree 2 files changed +10
-0
lines changed Original file line number Diff line number Diff line change @@ -195,10 +195,15 @@ private void initReaderAsynchronously() {
195195 LOG .info (
196196 "Start to download kv snapshot files to local directory for bucket {}." ,
197197 tableBucket );
198+ long startTime = System .currentTimeMillis ();
198199 remoteFileDownloader .transferAllToDirectory (
199200 fsPathAndFileNames ,
200201 snapshotLocalDirectory ,
201202 closeableRegistry );
203+ LOG .info (
204+ "Download kv snapshot files to local directory for bucket {} cost {} ms." ,
205+ tableBucket ,
206+ System .currentTimeMillis () - startTime );
202207 snapshotFilesReader =
203208 new SnapshotFilesReader (
204209 kvFormat ,
Original file line number Diff line number Diff line change @@ -158,10 +158,15 @@ void fetchOnce() throws Exception {
158158 LOG .info (
159159 "Start to download remote log segment file {} to local." ,
160160 fsPathAndFileName .getFileName ());
161+ long startTime = System .currentTimeMillis ();
161162 remoteFileDownloader .transferAllToDirectory (
162163 Collections .singletonList (fsPathAndFileName ),
163164 segmentPath ,
164165 new CloseableRegistry ());
166+ LOG .info (
167+ "Download remote log segment file {} to local cost {} ms." ,
168+ fsPathAndFileName .getFileName (),
169+ System .currentTimeMillis () - startTime );
165170 File localFile = new File (segmentPath .toFile (), fsPathAndFileName .getFileName ());
166171 scannerMetricGroup .remoteFetchBytes ().inc (localFile .length ());
167172 String segmentId = request .segment .remoteLogSegmentId ().toString ();
You can’t perform that action at this time.
0 commit comments