我是一个比较新的sqooping过程，所以请原谅我的无知。我一直在尝试将数据源中的一个表作为parquet文件进行sqoop，并创建一个impala表（也作为parquet），在其中插入sqooped数据。代码运行时没有问题，但当我尝试选择几行进行测试时，出现了错误：

.../EWT_CALL_PROF_DIM_SQOOP/ec2fe2b0-c9fa-4ef9-91f8-46cf0e12e272.parquet' has an incompatible Parquet schema for column 'dru_id.test_ewt_call_prof_dim_parquet.call_prof_sk_id'. Column type: INT, Parquet schema: optional byte_array CALL_PROF_SK_ID [i:0 d:1 r:0]

我在模仿我在cloudera指南上找到的过程here:https://www.cloudera.com/documentation/enterprise/5-8-x/topics/impala_create_table.html. 主要是“内外表”部分。我一直在努力避免用一个特定的Parquet文件来推断模式，因为每个月都会用一个bash脚本来启动整个过程（如果我使用多个Map器，我也想不出一种方法来将它指向一个文件）。
这是我使用的代码。我觉得我要么错过了一些小而愚蠢的事情，要么我把所有重大的事情都搞砸了，却没有意识到这一点。感谢所有的帮助。谢谢！

sqoop import -Doraoop.import.hint=" " \
    --options-file /home/kemri/pass.txt \
    --verbose \
    --connect jdbc:oracle:thin:@ldap://oid:389/cn=OracleContext,dc=[employer],dc=com/EWSOP000 \
    --username [userid] \
    --num-mappers 1 \
    --target-dir hdfs://nameservice1/data/res/warehouse/finance/[dru_userid]/EWT_CALL_PROF_DIM_SQOOP \
    --delete-target-dir \
    --table DMPROD.EWT_CALL_PROF_DIM \
    --direct \
    --null-string '\\N' \
    --null-non-string '\\N' \
    --as-parquetfile 

impala-shell -k -i hrtimpslb.[employer].com

create external table test_EWT_CALL_PROF_DIM_parquet(
CALL_PROF_SK_ID INT,
SRC_SKL_CD_ID STRING,
SPLIT_NM STRING,
SPLIT_DESC STRING,
CLM_SYS_CD STRING,
CLM_SYS_NM STRING,
LOB_CD STRING,
LOB_NM STRING,
CAT_IND STRING,
CALL_TY_CD STRING,
CALL_TY_NM STRING,
CALL_DIR_CD STRING,
CALL_DIR_NM STRING,
LANG_CD STRING,
LANG_NM STRING,
K71_ATOMIC_TS TIMESTAMP)
stored as parquet location '/data/res/warehouse/finance/[dru_userid]/EWT_CALL_PROF_DIM_SQOOP';