This is an automated email from the ASF dual-hosted git repository.
englefly pushed a commit to branch 2.0.13-tebu
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 9f840dc1aa21076cfd6138a30aed8b1ce2e7bcb2
Author: Jibing Li <jibi...@gmail.com>
AuthorDate: Tue Aug 27 19:12:44 2024 +0800
Revert "Add log"
This reverts commit 4797229431462aa99582685ae6da4b6101d8efcf.
---
.../main/java/org/apache/doris/qe/StmtExecutor.java | 20 +-------------------
.../org/apache/doris/statistics/AnalysisJob.java | 1 -
.../apache/doris/statistics/OlapAnalysisTask.java | 3 ---
3 files changed, 1 insertion(+), 23 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
index 340d7bf1596..342b38892da 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
@@ -205,7 +205,6 @@ import java.io.IOException;
import java.io.StringReader;
import java.nio.ByteBuffer;
import java.util.ArrayList;
-import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
@@ -1598,15 +1597,7 @@ public class StmtExecutor {
}
isSendFields = true;
}
- List<ByteBuffer> rows = batch.getBatch().getRows();
- for (ByteBuffer row : rows) {
- try {
- if (rows.size() == 1 && row.array().length < 100) {
- LOG.info("User bytes from BE [{}]",
Arrays.toString(row.array()));
- }
- } catch (Exception e) {
- LOG.info("Fail to print User bytes from BE {}",
e.getMessage());
- }
+ for (ByteBuffer row : batch.getBatch().getRows()) {
channel.sendOnePacket(row);
}
profile.getSummaryProfile().freshWriteResultConsumeTime();
@@ -2810,15 +2801,6 @@ public class StmtExecutor {
for (int i = 0; i < columns.size(); i++) {
String value = queryBuffer.readStringWithLength();
- if (rows.size() == 1 && columns.size() == 2) {
- try {
- LOG.info("Internal bytes from BE [{}]",
Arrays.toString(buffer.array()));
- LOG.info("Internal bytes after slice [{}]",
Arrays.toString(queryBuffer.data()));
- LOG.info("Internal query value: [{}]", value);
- } catch (Exception e) {
- LOG.info("Fail to print internal bytes from BE {}",
e.getMessage());
- }
- }
values.add(value);
}
ResultRow resultRow = new ResultRow(values);
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJob.java
b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJob.java
index 984e03fffa0..cc1a15aa0d1 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJob.java
@@ -134,7 +134,6 @@ public class AnalysisJob {
} catch (Exception t) {
throw new RuntimeException("Failed to analyze: " +
t.getMessage());
}
- LOG.debug("INSERT INTO sql : [{}]", insertStmt);
}
updateTaskState(AnalysisState.FINISHED, "");
queryFinished.clear();
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/statistics/OlapAnalysisTask.java
b/fe/fe-core/src/main/java/org/apache/doris/statistics/OlapAnalysisTask.java
index c9d02ecde2b..073000d9eb2 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/statistics/OlapAnalysisTask.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/statistics/OlapAnalysisTask.java
@@ -118,7 +118,6 @@ public class OlapAnalysisTask extends BaseAnalysisTask {
? basicStats.get(0) : null);
String max = StatisticsUtil.escapeSQL(basicStats != null &&
basicStats.getValues().size() > 1
? basicStats.get(1) : null);
- LOG.debug("Min value is [{}], max value is [{}]", min, max);
boolean limitFlag = false;
long rowsToSample = pair.second;
@@ -179,7 +178,6 @@ public class OlapAnalysisTask extends BaseAnalysisTask {
col.getName(), params.get("rowCount"), rowsToSample,
params.get("scaleFactor"),
limitFlag, tbl.isDistributionColumn(col.getName()),
tbl.isPartitionColumn(col.getName()), col.isKey(),
isSingleUniqueKey());
- LOG.debug("Sample analyze sql: [{}]", sql);
runQuery(sql);
}
}
@@ -203,7 +201,6 @@ public class OlapAnalysisTask extends BaseAnalysisTask {
stmtExecutor = new StmtExecutor(context.connectContext, sql);
ResultRow resultRow = stmtExecutor.executeInternalQuery().get(0);
if (LOG.isDebugEnabled()) {
- LOG.debug("Min max result row: {}", resultRow.toString());
LOG.debug("Cost time in millisec: " + (System.currentTimeMillis()
- startTime)
+ " Min max SQL: " + sql + " QueryId: " +
DebugUtil.printId(stmtExecutor.getContext().queryId()));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
