tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Enhancement] Remove legacy code (#22127) 

Signed-off-by: sduzh <zhuming9011@qq.com>
This commit is contained in:
Alex Zhu 2023-04-21 15:23:02 +08:00 committed by GitHub
parent 1317f59d3f
commit c0888d9f09
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
fe/fe-core/src/main/java/com/starrocks/lake/compaction/CompactionScheduler.java
View File

@ -386,26 +386,6 @@ public class CompactionScheduler extends Daemon {
}
context.setVisibleStateWaiter(waiter);
context.setCommitTs(System.currentTimeMillis());
if (LOG.isDebugEnabled()) {
long numInputBytes = 0;
long numInputRows = 0;
long numOutputBytes = 0;
long numOutputRows = 0;
for (Future<CompactResponse> responseFuture : context.getResponseList()) {
CompactResponse response = responseFuture.get();
numInputBytes += response.numInputBytes;
numInputRows += response.numInputRows;
numOutputBytes += response.numOutputBytes;
numOutputRows += response.numOutputRows;
}
LOG.debug("Committed compaction. {} inputBytes={} inputRows={} outputBytes={} outputRows={} time={}",
context.getDebugString(),
numInputBytes,
numInputRows,
numOutputBytes,
numOutputRows,
(context.getCommitTs() - context.getStartTs()));
}
}
private void abortTransactionIgnoreError(long dbId, long txnId, String reason) {

10
gensrc/proto/lake_service.proto
View File

@ -62,11 +62,11 @@ message CompactRequest {
message CompactResponse {
repeated int64 failed_tablets = 1;
optional int64 execution_time = 2; // ms
optional int64 num_input_bytes = 3;
optional int64 num_input_rows = 4;
optional int64 num_output_bytes = 5;
optional int64 num_output_rows = 6;
// optional int64 execution_time = 2; // ms
// optional int64 num_input_bytes = 3;
// optional int64 num_input_rows = 4;
// optional int64 num_output_bytes = 5;
// optional int64 num_output_rows = 6;
optional StatusPB status = 7;
}