Skip to content

Commit a97ceff

Browse files
committed
cost estimator allow scalar in table expand
1 parent d9ebcf0 commit a97ceff

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/org/apache/sysds/resource/cost/CostEstimator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -822,7 +822,7 @@ public double parseSPInst(SPInstruction inst) throws CostEstimationException {
822822
SparkCostUtils.getMatMulChainInstTime(mmchaininst, input1, input2, input3, output, driverMetrics, executorMetrics);
823823
} else if (inst instanceof CtableSPInstruction) {
824824
CtableSPInstruction tableInst = (CtableSPInstruction) inst;
825-
VarStats input1 = getStats(tableInst.input1.getName());
825+
VarStats input1 = getStatsWithDefaultScalar(tableInst.input1.getName());
826826
VarStats input2 = getStatsWithDefaultScalar(tableInst.input2.getName());
827827
VarStats input3 = getStatsWithDefaultScalar(tableInst.input3.getName());
828828
double loadTime = loadRDDStatsAndEstimateTime(input1) +

0 commit comments

Comments
 (0)