private void initColumns() throws UserException {
        paramCreateContext.tupleDescriptor = analyzer.getDescTbl().createTupleDescriptor("StreamLoadScanNode");
        Load.initColumns(dstTable, streamLoadInfo.getColumnExprDescs(), null /* no hadoop function */,
                exprsByName, analyzer, paramCreateContext.tupleDescriptor, slotDescByName,
                paramCreateContext.params, true, useVectorizedLoad, Lists.newArrayList(),
                streamLoadInfo.getFormatType() == TFileFormatType.FORMAT_JSON, streamLoadInfo.isPartialUpdate());
    }
@Test(expected = DdlException.class)
    public void testLoadInitColumnsMappingColumnNotExist() throws UserException {
        List<Column> columns = Lists.newArrayList();
        columns.add(new Column("c1", Type.INT, true, null, false, null, ""));
        columns.add(new Column("c2", ScalarType.createVarchar(10), true, null, false, null, ""));
        Table table = new Table(1L, "table0", TableType.OLAP, columns);
        List<ImportColumnDesc> columnExprs = Lists.newArrayList();
        columnExprs.add(new ImportColumnDesc("c3", new FunctionCallExpr("func", Lists.newArrayList())));
        Load.initColumns(table, columnExprs, null, null, null, null, null, null);
    }