Skip to content

Commit 581a407

Browse files
committed
add log
1 parent 676ac65 commit 581a407

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

fe/fe-core/src/main/java/org/apache/doris/datasource/maxcompute/source/MaxComputeScanNode.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,8 @@
6262
import com.aliyun.odps.table.read.split.impl.IndexedInputSplit;
6363
import jline.internal.Log;
6464
import lombok.Setter;
65+
import org.apache.logging.log4j.LogManager;
66+
import org.apache.logging.log4j.Logger;
6567

6668
import java.io.ByteArrayOutputStream;
6769
import java.io.IOException;
@@ -88,6 +90,8 @@ public class MaxComputeScanNode extends FileQueryScanNode {
8890
static final DateTimeFormatter dateTime3Formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS");
8991
static final DateTimeFormatter dateTime6Formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSSSSS");
9092

93+
private static final Logger LOG = LogManager.getLogger(MaxComputeScanNode.class);
94+
9195
private final MaxComputeExternalTable table;
9296
private Predicate filterPredicate;
9397
List<String> requiredPartitionColumns = new ArrayList<>();
@@ -355,6 +359,9 @@ private Predicate convertExprToOdpsPredicate(Expr expr) throws AnalysisException
355359

356360
String columnName = convertSlotRefToColumnName(expr.getChild(0));
357361
if (!table.getColumnNameToOdpsColumn().containsKey(columnName)) {
362+
Map<String, com.aliyun.odps.Column> columnMap = table.getColumnNameToOdpsColumn();
363+
LOG.warn("ColumnNameToOdpsColumn size=" + columnMap.size()
364+
+ ", keys=[" + String.join(", ", columnMap.keySet()) + "]");
358365
throw new AnalysisException("Column " + columnName + " not found in table, can not push "
359366
+ "down predicate to MaxCompute " + table.getName());
360367
}
@@ -415,6 +422,9 @@ private Predicate convertExprToOdpsPredicate(Expr expr) throws AnalysisException
415422
if (odpsOp != null) {
416423
String columnName = convertSlotRefToColumnName(expr.getChild(0));
417424
if (!table.getColumnNameToOdpsColumn().containsKey(columnName)) {
425+
Map<String, com.aliyun.odps.Column> columnMap = table.getColumnNameToOdpsColumn();
426+
LOG.warn("ColumnNameToOdpsColumn size=" + columnMap.size()
427+
+ ", keys=[" + String.join(", ", columnMap.keySet()) + "]");
418428
throw new AnalysisException("Column " + columnName + " not found in table, can not push "
419429
+ "down predicate to MaxCompute " + table.getName());
420430
}

0 commit comments

Comments
 (0)