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 4797229431462aa99582685ae6da4b6101d8efcf
Author: Jibing Li <jibi...@gmail.com>
AuthorDate: Mon Aug 26 13:34:34 2024 +0800
Add log
---
.../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, 23 insertions(+), 1 deletion(-)
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 342b38892da..340d7bf1596 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,6 +205,7 @@ 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;
@@ -1597,7 +1598,15 @@ public class StmtExecutor {
}
isSendFields = true;
}
- for (ByteBuffer row : batch.getBatch().getRows()) {
+ 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());
+ }
channel.sendOnePacket(row);
}
profile.getSummaryProfile().freshWriteResultConsumeTime();
@@ -2801,6 +2810,15 @@ 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 cc1a15aa0d1..984e03fffa0 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,6 +134,7 @@ 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 073000d9eb2..c9d02ecde2b 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,6 +118,7 @@ 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;
@@ -178,6 +179,7 @@ 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);
}
}
@@ -201,6 +203,7 @@ 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
